fields = CollUtil.filter(entities[0].keySet(), StrUtil::isNotBlank);
+ return StatementUtil.prepareStatementForBatch(conn, insert.build(), fields, entities);
}
@Override
@@ -113,7 +116,7 @@ public class AnsiSqlDialect implements Dialect {
/**
* 根据不同数据库在查询SQL语句基础上包装其分页的语句
* 各自数据库通过重写此方法实现最小改动情况下修改分页语句
- *
+ *
* @param find 标准查询语句
* @param page 分页对象
* @return 分页语句
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/H2Dialect.java b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/H2Dialect.java
index 917980049..110aea5f6 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/H2Dialect.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/H2Dialect.java
@@ -2,19 +2,16 @@ package cn.hutool.db.dialect.impl;
import cn.hutool.core.lang.Assert;
import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Entity;
import cn.hutool.db.Page;
import cn.hutool.db.StatementUtil;
import cn.hutool.db.dialect.DialectName;
-import cn.hutool.db.sql.Condition;
-import cn.hutool.db.sql.Query;
import cn.hutool.db.sql.SqlBuilder;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
-import java.util.Arrays;
-import java.util.function.Function;
/**
* H2数据库方言
@@ -39,18 +36,42 @@ public class H2Dialect extends AnsiSqlDialect {
return find.append(" limit ").append(page.getStartPosition()).append(" , ").append(page.getPageSize());
}
- /**
- * 构建用于upsert的PreparedStatement
- *
- * @param conn 数据库连接对象
- * @param entity 数据实体类(包含表名)
- * @param keys 查找字段 如果不提供keys将自动使用主键
- * @return PreparedStatement
- * @throws SQLException SQL执行异常
- */
@Override
public PreparedStatement psForUpsert(Connection conn, Entity entity, String... keys) throws SQLException {
- final SqlBuilder upsert = SqlBuilder.create(wrapper).upsert(entity, this.dialectName(),keys);
- return StatementUtil.prepareStatement(conn, upsert);
+ Assert.notEmpty(keys, "Keys must be not empty for H2 MERGE SQL.");
+ SqlBuilder.validateEntity(entity);
+ final SqlBuilder builder = SqlBuilder.create(wrapper);
+
+ final StringBuilder fieldsPart = new StringBuilder();
+ final StringBuilder placeHolder = new StringBuilder();
+
+ // 构建字段部分和参数占位符部分
+ entity.forEach((field, value)->{
+ if (StrUtil.isNotBlank(field)) {
+ if (fieldsPart.length() > 0) {
+ // 非第一个参数,追加逗号
+ fieldsPart.append(", ");
+ placeHolder.append(", ");
+ }
+
+ fieldsPart.append((null != wrapper) ? wrapper.wrap(field) : field);
+ placeHolder.append("?");
+ builder.addParams(value);
+ }
+ });
+
+ String tableName = entity.getTableName();
+ if (null != this.wrapper) {
+ tableName = this.wrapper.wrap(tableName);
+ }
+ builder.append("MERGE INTO ").append(tableName)
+ // 字段列表
+ .append(" (").append(fieldsPart)
+ // 更新关键字列表
+ .append(") KEY(").append(ArrayUtil.join(keys, ", "))
+ // 更新值列表
+ .append(") VALUES (").append(placeHolder).append(")");
+
+ return StatementUtil.prepareStatement(conn, builder);
}
}
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/MysqlDialect.java b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/MysqlDialect.java
index 3ce7a199a..a52cfa759 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/MysqlDialect.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/MysqlDialect.java
@@ -1,5 +1,6 @@
package cn.hutool.db.dialect.impl;
+import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Entity;
import cn.hutool.db.Page;
import cn.hutool.db.StatementUtil;
@@ -34,17 +35,58 @@ public class MysqlDialect extends AnsiSqlDialect{
}
/**
- * 构建用于upsert的PreparedStatement
+ * 构建用于upsert的{@link PreparedStatement}
+ * MySQL通过主键方式实现Upsert,故keys无效,生成SQL语法为:
+ *
+ * INSERT INTO demo(a,b,c) values(?, ?, ?) ON DUPLICATE KEY UPDATE a=values(a), b=values(b), c=values(c);
+ *
*
* @param conn 数据库连接对象
* @param entity 数据实体类(包含表名)
- * @param keys 查找字段
+ * @param keys 此参数无效
* @return PreparedStatement
* @throws SQLException SQL执行异常
+ * @since 5.7.20
*/
@Override
public PreparedStatement psForUpsert(Connection conn, Entity entity, String... keys) throws SQLException {
- final SqlBuilder upsert = SqlBuilder.create(wrapper).upsert(entity, this.dialectName(),keys);
- return StatementUtil.prepareStatement(conn, upsert);
+ SqlBuilder.validateEntity(entity);
+ final SqlBuilder builder = SqlBuilder.create(wrapper);
+
+ final StringBuilder fieldsPart = new StringBuilder();
+ final StringBuilder placeHolder = new StringBuilder();
+ final StringBuilder updateHolder = new StringBuilder();
+
+ // 构建字段部分和参数占位符部分
+ entity.forEach((field, value)->{
+ if (StrUtil.isNotBlank(field)) {
+ if (fieldsPart.length() > 0) {
+ // 非第一个参数,追加逗号
+ fieldsPart.append(", ");
+ placeHolder.append(", ");
+ updateHolder.append(", ");
+ }
+
+ field = (null != wrapper) ? wrapper.wrap(field) : field;
+ fieldsPart.append(field);
+ updateHolder.append(field).append("=values(").append(field).append(")");
+ placeHolder.append("?");
+ builder.addParams(value);
+ }
+ });
+
+ String tableName = entity.getTableName();
+ if (null != this.wrapper) {
+ tableName = this.wrapper.wrap(tableName);
+ }
+ builder.append("INSERT INTO ").append(tableName)
+ // 字段列表
+ .append(" (").append(fieldsPart)
+ // 更新值列表
+ .append(") VALUES (").append(placeHolder)
+ // 主键冲突后的更新操作
+ .append(") ON DUPLICATE KEY UPDATE ").append(updateHolder);
+
+ return StatementUtil.prepareStatement(conn, builder);
}
}
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/OracleDialect.java b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/OracleDialect.java
index 925889611..037aaf8a0 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/OracleDialect.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/OracleDialect.java
@@ -1,32 +1,44 @@
package cn.hutool.db.dialect.impl;
+import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Page;
import cn.hutool.db.dialect.DialectName;
import cn.hutool.db.sql.SqlBuilder;
/**
* Oracle 方言
- * @author loolly
*
+ * @author loolly
*/
-public class OracleDialect extends AnsiSqlDialect{
+public class OracleDialect extends AnsiSqlDialect {
private static final long serialVersionUID = 6122761762247483015L;
+ /**
+ * 检查字段值是否为Oracle自增字段,自增字段以`.nextval`结尾
+ *
+ * @param value 检查的字段值
+ * @return 是否为Oracle自增字段
+ * @since 5.7.20
+ */
+ public static boolean isNextVal(Object value) {
+ return (value instanceof CharSequence) && StrUtil.endWithIgnoreCase(value.toString(), ".nextval");
+ }
+
public OracleDialect() {
//Oracle所有字段名用双引号包围,防止字段名或表名与系统关键字冲突
//wrapper = new Wrapper('"');
}
-
+
@Override
protected SqlBuilder wrapPageSql(SqlBuilder find, Page page) {
final int[] startEnd = page.getStartEnd();
return find
- .insertPreFragment("SELECT * FROM ( SELECT row_.*, rownum rownum_ from ( ")
- .append(" ) row_ where rownum <= ").append(startEnd[1])//
- .append(") table_alias")//
- .append(" where table_alias.rownum_ > ").append(startEnd[0]);//
+ .insertPreFragment("SELECT * FROM ( SELECT row_.*, rownum rownum_ from ( ")
+ .append(" ) row_ where rownum <= ").append(startEnd[1])//
+ .append(") table_alias")//
+ .append(" where table_alias.rownum_ > ").append(startEnd[0]);//
}
-
+
@Override
public String dialectName() {
return DialectName.ORACLE.name();
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PhoenixDialect.java b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PhoenixDialect.java
index c2ad5bdd5..8064e8982 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PhoenixDialect.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PhoenixDialect.java
@@ -24,6 +24,7 @@ public class PhoenixDialect extends AnsiSqlDialect {
@Override
public PreparedStatement psForUpdate(Connection conn, Entity entity, Query query) throws SQLException {
// Phoenix的插入、更新语句是统一的,统一使用upsert into关键字
+ // Phoenix只支持通过主键更新操作,因此query无效,自动根据entity中的主键更新
return super.psForInsert(conn, entity);
}
@@ -31,4 +32,10 @@ public class PhoenixDialect extends AnsiSqlDialect {
public String dialectName() {
return DialectName.PHOENIX.name();
}
+
+ @Override
+ public PreparedStatement psForUpsert(Connection conn, Entity entity, String... keys) throws SQLException {
+ // Phoenix只支持通过主键更新操作,因此query无效,自动根据entity中的主键更新
+ return psForInsert(conn, entity);
+ }
}
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PostgresqlDialect.java b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PostgresqlDialect.java
index 82f5fe373..1f5a90122 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PostgresqlDialect.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/impl/PostgresqlDialect.java
@@ -1,5 +1,8 @@
package cn.hutool.db.dialect.impl;
+import cn.hutool.core.lang.Assert;
+import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.StrUtil;
import cn.hutool.db.Entity;
import cn.hutool.db.StatementUtil;
import cn.hutool.db.dialect.DialectName;
@@ -28,21 +31,48 @@ public class PostgresqlDialect extends AnsiSqlDialect{
return DialectName.POSTGREESQL.name();
}
- /**
- * 构建用于upsert的PreparedStatement
- *
- * @param conn 数据库连接对象
- * @param entity 数据实体类(包含表名)
- * @param keys 查找字段 必须是有唯一索引的列且不能为空
- * @return PreparedStatement
- * @throws SQLException SQL执行异常
- */
@Override
public PreparedStatement psForUpsert(Connection conn, Entity entity, String... keys) throws SQLException {
- if (null==keys || keys.length==0){
- throw new SQLException("keys不能为空");
+ Assert.notEmpty(keys, "Keys must be not empty for Postgres.");
+ SqlBuilder.validateEntity(entity);
+ final SqlBuilder builder = SqlBuilder.create(wrapper);
+
+ final StringBuilder fieldsPart = new StringBuilder();
+ final StringBuilder placeHolder = new StringBuilder();
+ final StringBuilder updateHolder = new StringBuilder();
+
+ // 构建字段部分和参数占位符部分
+ entity.forEach((field, value)->{
+ if (StrUtil.isNotBlank(field)) {
+ if (fieldsPart.length() > 0) {
+ // 非第一个参数,追加逗号
+ fieldsPart.append(", ");
+ placeHolder.append(", ");
+ updateHolder.append(", ");
+ }
+
+ final String wrapedField = (null != wrapper) ? wrapper.wrap(field) : field;
+ fieldsPart.append(wrapedField);
+ updateHolder.append(wrapedField).append("=EXCLUDED.").append(field);
+ placeHolder.append("?");
+ builder.addParams(value);
+ }
+ });
+
+ String tableName = entity.getTableName();
+ if (null != this.wrapper) {
+ tableName = this.wrapper.wrap(tableName);
}
- final SqlBuilder upsert = SqlBuilder.create(wrapper).upsert(entity, this.dialectName(),keys);
- return StatementUtil.prepareStatement(conn, upsert);
+ builder.append("INSERT INTO ").append(tableName)
+ // 字段列表
+ .append(" (").append(fieldsPart)
+ // 更新值列表
+ .append(") VALUES (").append(placeHolder)
+ // 定义检查冲突的主键或字段
+ .append(") ON CONFLICT (").append(ArrayUtil.join(keys,", "))
+ // 主键冲突后的更新操作
+ .append(") DO UPDATE SET ").append(updateHolder);
+
+ return StatementUtil.prepareStatement(conn, builder);
}
}
diff --git a/hutool-db/src/main/java/cn/hutool/db/sql/SqlBuilder.java b/hutool-db/src/main/java/cn/hutool/db/sql/SqlBuilder.java
index fcf09c671..a2a52634d 100644
--- a/hutool-db/src/main/java/cn/hutool/db/sql/SqlBuilder.java
+++ b/hutool-db/src/main/java/cn/hutool/db/sql/SqlBuilder.java
@@ -7,13 +7,13 @@ import cn.hutool.core.util.StrUtil;
import cn.hutool.db.DbRuntimeException;
import cn.hutool.db.Entity;
import cn.hutool.db.dialect.DialectName;
+import cn.hutool.db.dialect.impl.OracleDialect;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
-import java.util.Map.Entry;
/**
* SQL构建器
@@ -57,6 +57,24 @@ public class SqlBuilder implements Builder {
return create().append(sql);
}
+ /**
+ * 验证实体类对象的有效性
+ *
+ * @param entity 实体类对象
+ * @throws DbRuntimeException SQL异常包装,获取元数据信息失败
+ */
+ public static void validateEntity(Entity entity) throws DbRuntimeException {
+ if (null == entity) {
+ throw new DbRuntimeException("Entity is null !");
+ }
+ if (StrUtil.isBlank(entity.getTableName())) {
+ throw new DbRuntimeException("Entity`s table name is null !");
+ }
+ if (entity.isEmpty()) {
+ throw new DbRuntimeException("No filed and value in this entity !");
+ }
+ }
+
// --------------------------------------------------------------- Static methods end
// --------------------------------------------------------------- Enums start
@@ -87,10 +105,6 @@ public class SqlBuilder implements Builder {
// --------------------------------------------------------------- Enums end
private final StringBuilder sql = new StringBuilder();
- /**
- * 字段列表(仅用于插入和更新)
- */
- private final List fields = new ArrayList<>();
/**
* 占位符对应的值列表
*/
@@ -146,41 +160,29 @@ public class SqlBuilder implements Builder {
// 验证
validateEntity(entity);
- if (null != wrapper) {
- // 包装表名 entity = wrapper.wrap(entity);
- entity.setTableName(wrapper.wrap(entity.getTableName()));
- }
-
final boolean isOracle = DialectName.ORACLE.match(dialectName);// 对Oracle的特殊处理
final StringBuilder fieldsPart = new StringBuilder();
final StringBuilder placeHolder = new StringBuilder();
- boolean isFirst = true;
- String field;
- Object value;
- for (Entry entry : entity.entrySet()) {
- field = entry.getKey();
- value = entry.getValue();
- if (StrUtil.isNotBlank(field) /* && null != value */) {
- if (isFirst) {
- isFirst = false;
- } else {
+ entity.forEach((field, value) -> {
+ if (StrUtil.isNotBlank(field)) {
+ if (fieldsPart.length() > 0) {
// 非第一个参数,追加逗号
fieldsPart.append(", ");
placeHolder.append(", ");
}
- this.fields.add(field);
fieldsPart.append((null != wrapper) ? wrapper.wrap(field) : field);
- if (isOracle && value instanceof String && StrUtil.endWithIgnoreCase((String) value, ".nextval")) {
+ if (isOracle && OracleDialect.isNextVal(value)) {
// Oracle的特殊自增键,通过字段名.nextval获得下一个值
placeHolder.append(value);
} else {
+ // 普通字段使用占位符
placeHolder.append("?");
this.paramValues.add(value);
}
}
- }
+ });
// issue#1656@Github Phoenix兼容
if (DialectName.PHOENIX.match(dialectName)) {
@@ -189,94 +191,18 @@ public class SqlBuilder implements Builder {
sql.append("INSERT INTO ");
}
- sql.append(entity.getTableName())
+ String tableName = entity.getTableName();
+ if (null != this.wrapper) {
+ // 包装表名 entity = wrapper.wrap(entity);
+ tableName = this.wrapper.wrap(tableName);
+ }
+ sql.append(tableName)
.append(" (").append(fieldsPart).append(") VALUES (")//
.append(placeHolder).append(")");
return this;
}
- /**
- * 插入
- * 插入会忽略空的字段名及其对应值,但是对于有字段名对应值为{@code null}的情况不忽略
- *
- * @param entity 实体
- * @param dialectName 方言名,用于对特殊数据库特殊处理
- * @param keys 根据何字段来确认唯一性,不传则用主键
- * @return 自己
- * @since 5.7.21
- */
- public SqlBuilder upsert(Entity entity, String dialectName, String... keys) {
- // 验证
- validateEntity(entity);
-
- if (null != wrapper) {
- // 包装表名 entity = wrapper.wrap(entity);
- entity.setTableName(wrapper.wrap(entity.getTableName()));
- }
-
- final boolean isOracle = DialectName.ORACLE.match(dialectName);// 对Oracle的特殊处理
- final StringBuilder fieldsPart = new StringBuilder();
- final StringBuilder placeHolder = new StringBuilder();
-
- boolean isFirst = true;
- String field;
- Object value;
- for (Entry entry : entity.entrySet()) {
- field = entry.getKey();
- value = entry.getValue();
- if (StrUtil.isNotBlank(field) /* && null != value */) {
- if (isFirst) {
- isFirst = false;
- } else {
- // 非第一个参数,追加逗号
- fieldsPart.append(", ");
- placeHolder.append(", ");
- }
-
- this.fields.add(field);
- fieldsPart.append((null != wrapper) ? wrapper.wrap(field) : field);
- if (isOracle && value instanceof String && StrUtil.endWithIgnoreCase((String) value, ".nextval")) {
- // Oracle的特殊自增键,通过字段名.nextval获得下一个值
- placeHolder.append(value);
- } else {
- placeHolder.append("?");
- this.paramValues.add(value);
- }
- }
- }
-
- // issue#1656@Github Phoenix兼容
- if (DialectName.PHOENIX.match(dialectName)) {
- sql.append("UPSERT INTO ").append(entity.getTableName());
- } else if (DialectName.MYSQL.match(dialectName)) {
- sql.append("INSERT INTO ");
- sql.append(entity.getTableName())
- .append(" (").append(fieldsPart).append(") VALUES (")
- .append(placeHolder).append(") on duplicate key update ")
- .append(ArrayUtil.join(ArrayUtil.map(entity.keySet().toArray(), String.class, (k) -> k + "=values(" + k + ")"), ","));
- } else if (DialectName.H2.match(dialectName)) {
- sql.append("MERGE INTO ").append(entity.getTableName());
- if (null != keys && keys.length > 0) {
- sql.append(" KEY(").append(ArrayUtil.join(keys, ","))
- .append(") VALUES (")
- .append(placeHolder)
- .append(")");
- }
- } else if (DialectName.POSTGREESQL.match(dialectName)) {
- sql.append("INSERT INTO ");
- sql.append(entity.getTableName())
- .append(" (").append(fieldsPart).append(") VALUES (")
- .append(placeHolder).append(") on conflict (")
- .append(ArrayUtil.join(keys,","))
- .append(") do update set ")
- .append(ArrayUtil.join(ArrayUtil.map(entity.keySet().toArray(), String.class, (k) -> k + "=excluded." + k ), ","));
- } else {
- throw new RuntimeException(dialectName + " not support yet");
- }
- return this;
- }
-
/**
* 删除
*
@@ -308,25 +234,22 @@ public class SqlBuilder implements Builder {
// 验证
validateEntity(entity);
+ String tableName = entity.getTableName();
if (null != wrapper) {
// 包装表名
- entity.setTableName(wrapper.wrap(entity.getTableName()));
+ tableName = wrapper.wrap(tableName);
}
- sql.append("UPDATE ").append(entity.getTableName()).append(" SET ");
- String field;
- for (Entry entry : entity.entrySet()) {
- field = entry.getKey();
+ sql.append("UPDATE ").append(tableName).append(" SET ");
+ entity.forEach((field, value) -> {
if (StrUtil.isNotBlank(field)) {
if (paramValues.size() > 0) {
sql.append(", ");
}
- this.fields.add(field);
sql.append((null != wrapper) ? wrapper.wrap(field) : field).append(" = ? ");
- this.paramValues.add(entry.getValue());// 更新不对空做处理,因为存在清空字段的情况
+ this.paramValues.add(value);// 更新不对空做处理,因为存在清空字段的情况
}
- }
-
+ });
return this;
}
@@ -653,24 +576,6 @@ public class SqlBuilder implements Builder {
}
// --------------------------------------------------------------- Builder end
- /**
- * 获得插入或更新的数据库字段列表
- *
- * @return 插入或更新的数据库字段列表
- */
- public String[] getFieldArray() {
- return this.fields.toArray(new String[0]);
- }
-
- /**
- * 获得插入或更新的数据库字段列表
- *
- * @return 插入或更新的数据库字段列表
- */
- public List getFields() {
- return this.fields;
- }
-
/**
* 获得占位符对应的值列表
*
@@ -725,23 +630,5 @@ public class SqlBuilder implements Builder {
return ConditionBuilder.of(conditions).build(this.paramValues);
}
-
- /**
- * 验证实体类对象的有效性
- *
- * @param entity 实体类对象
- * @throws DbRuntimeException SQL异常包装,获取元数据信息失败
- */
- private static void validateEntity(Entity entity) throws DbRuntimeException {
- if (null == entity) {
- throw new DbRuntimeException("Entity is null !");
- }
- if (StrUtil.isBlank(entity.getTableName())) {
- throw new DbRuntimeException("Entity`s table name is null !");
- }
- if (entity.isEmpty()) {
- throw new DbRuntimeException("No filed and value in this entity !");
- }
- }
// --------------------------------------------------------------- private method end
}
diff --git a/hutool-db/src/main/java/cn/hutool/db/sql/Wrapper.java b/hutool-db/src/main/java/cn/hutool/db/sql/Wrapper.java
index 12ee7778d..8851b2eac 100644
--- a/hutool-db/src/main/java/cn/hutool/db/sql/Wrapper.java
+++ b/hutool-db/src/main/java/cn/hutool/db/sql/Wrapper.java
@@ -15,15 +15,19 @@ import java.util.Map.Entry;
/**
* 包装器
* 主要用于字段名的包装(在字段名的前后加字符,例如反引号来避免与数据库的关键字冲突)
- * @author Looly
*
+ * @author Looly
*/
public class Wrapper implements Serializable {
private static final long serialVersionUID = 1L;
- /** 前置包装符号 */
+ /**
+ * 前置包装符号
+ */
private Character preWrapQuote;
- /** 后置包装符号 */
+ /**
+ * 后置包装符号
+ */
private Character sufWrapQuote;
public Wrapper() {
@@ -31,6 +35,7 @@ public class Wrapper implements Serializable {
/**
* 构造
+ *
* @param wrapQuote 单包装字符
*/
public Wrapper(Character wrapQuote) {
@@ -40,6 +45,7 @@ public class Wrapper implements Serializable {
/**
* 包装符号
+ *
* @param preWrapQuote 前置包装符号
* @param sufWrapQuote 后置包装符号
*/
@@ -49,14 +55,17 @@ public class Wrapper implements Serializable {
}
//--------------------------------------------------------------- Getters and Setters start
+
/**
* @return 前置包装符号
*/
public char getPreWrapQuote() {
return preWrapQuote;
}
+
/**
* 设置前置包装的符号
+ *
* @param preWrapQuote 前置包装符号
*/
public void setPreWrapQuote(Character preWrapQuote) {
@@ -69,8 +78,10 @@ public class Wrapper implements Serializable {
public char getSufWrapQuote() {
return sufWrapQuote;
}
+
/**
* 设置后置包装的符号
+ *
* @param sufWrapQuote 后置包装符号
*/
public void setSufWrapQuote(Character sufWrapQuote) {
@@ -81,26 +92,27 @@ public class Wrapper implements Serializable {
/**
* 包装字段名
* 有时字段与SQL的某些关键字冲突,导致SQL出错,因此需要将字段名用单引号或者反引号包装起来,避免冲突
+ *
* @param field 字段名
* @return 包装后的字段名
*/
- public String wrap(String field){
- if(preWrapQuote == null || sufWrapQuote == null || StrUtil.isBlank(field)) {
+ public String wrap(String field) {
+ if (preWrapQuote == null || sufWrapQuote == null || StrUtil.isBlank(field)) {
return field;
}
//如果已经包含包装的引号,返回原字符
- if(StrUtil.isSurround(field, preWrapQuote, sufWrapQuote)){
+ if (StrUtil.isSurround(field, preWrapQuote, sufWrapQuote)) {
return field;
}
//如果字段中包含通配符或者括号(字段通配符或者函数),不做包装
- if(StrUtil.containsAnyIgnoreCase(field, "*", "(", " ", " as ")) {
+ if (StrUtil.containsAnyIgnoreCase(field, "*", "(", " ", " as ")) {
return field;
}
//对于Oracle这类数据库,表名中包含用户名需要单独拆分包装
- if(field.contains(StrUtil.DOT)){
+ if (field.contains(StrUtil.DOT)) {
final Collection target = CollUtil.edit(StrUtil.split(field, CharUtil.DOT, 2), t -> StrUtil.format("{}{}{}", preWrapQuote, t, sufWrapQuote));
return CollectionUtil.join(target, StrUtil.DOT);
}
@@ -111,16 +123,17 @@ public class Wrapper implements Serializable {
/**
* 包装字段名
* 有时字段与SQL的某些关键字冲突,导致SQL出错,因此需要将字段名用单引号或者反引号包装起来,避免冲突
+ *
* @param fields 字段名
* @return 包装后的字段名
*/
- public String[] wrap(String... fields){
- if(ArrayUtil.isEmpty(fields)) {
+ public String[] wrap(String... fields) {
+ if (ArrayUtil.isEmpty(fields)) {
return fields;
}
String[] wrappedFields = new String[fields.length];
- for(int i = 0; i < fields.length; i++) {
+ for (int i = 0; i < fields.length; i++) {
wrappedFields[i] = wrap(fields[i]);
}
@@ -130,11 +143,12 @@ public class Wrapper implements Serializable {
/**
* 包装字段名
* 有时字段与SQL的某些关键字冲突,导致SQL出错,因此需要将字段名用单引号或者反引号包装起来,避免冲突
+ *
* @param fields 字段名
* @return 包装后的字段名
*/
- public Collection wrap(Collection fields){
- if(CollectionUtil.isEmpty(fields)) {
+ public Collection wrap(Collection fields) {
+ if (CollectionUtil.isEmpty(fields)) {
return fields;
}
@@ -142,13 +156,14 @@ public class Wrapper implements Serializable {
}
/**
- * 包装字段名
+ * 包装表名和字段名,此方法返回一个新的Entity实体类
* 有时字段与SQL的某些关键字冲突,导致SQL出错,因此需要将字段名用单引号或者反引号包装起来,避免冲突
+ *
* @param entity 被包装的实体
- * @return 包装后的字段名
+ * @return 新的实体
*/
- public Entity wrap(Entity entity){
- if(null == entity) {
+ public Entity wrap(Entity entity) {
+ if (null == entity) {
return null;
}
@@ -168,14 +183,15 @@ public class Wrapper implements Serializable {
/**
* 包装字段名
* 有时字段与SQL的某些关键字冲突,导致SQL出错,因此需要将字段名用单引号或者反引号包装起来,避免冲突
+ *
* @param conditions 被包装的实体
* @return 包装后的字段名
*/
- public Condition[] wrap(Condition... conditions){
+ public Condition[] wrap(Condition... conditions) {
final Condition[] clonedConditions = new Condition[conditions.length];
- if(ArrayUtil.isNotEmpty(conditions)) {
+ if (ArrayUtil.isNotEmpty(conditions)) {
Condition clonedCondition;
- for(int i = 0; i < conditions.length; i++) {
+ for (int i = 0; i < conditions.length; i++) {
clonedCondition = conditions[i].clone();
clonedCondition.setField(wrap(clonedCondition.getField()));
clonedConditions[i] = clonedCondition;
diff --git a/hutool-db/src/test/java/cn/hutool/db/H2Test.java b/hutool-db/src/test/java/cn/hutool/db/H2Test.java
index 85bd27627..bc7e48dd7 100644
--- a/hutool-db/src/test/java/cn/hutool/db/H2Test.java
+++ b/hutool-db/src/test/java/cn/hutool/db/H2Test.java
@@ -1,6 +1,5 @@
package cn.hutool.db;
-import com.alibaba.druid.support.json.JSONUtils;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;
@@ -40,6 +39,7 @@ public class H2Test {
List query = Db.use(DS_GROUP_NAME).find(Entity.create("test"));
Assert.assertEquals(4, query.size());
}
+
@Test
public void upsertTest() throws SQLException {
Db db=Db.use(DS_GROUP_NAME);
From da4d64fcbcd3f45aa5094f594f60a81b775ef9a5 Mon Sep 17 00:00:00 2001
From: Looly
Date: Sat, 15 Jan 2022 13:26:56 +0800
Subject: [PATCH 07/28] add xugu
---
.../src/main/java/cn/hutool/db/dialect/DialectFactory.java | 3 +++
.../src/main/java/cn/hutool/db/dialect/DriverNamePool.java | 4 ++++
2 files changed, 7 insertions(+)
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/DialectFactory.java b/hutool-db/src/main/java/cn/hutool/db/dialect/DialectFactory.java
index 5f6e76194..42d81cc58 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/DialectFactory.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/DialectFactory.java
@@ -149,6 +149,9 @@ public class DialectFactory implements DriverNamePool{
} else if (nameContainsProductInfo.contains("sybase")) {
// 神州数据库
driver = DRIVER_SYBASE;
+ } else if (nameContainsProductInfo.contains("xugu")) {
+ // 虚谷数据库
+ driver = DRIVER_XUGO;
}
return driver;
diff --git a/hutool-db/src/main/java/cn/hutool/db/dialect/DriverNamePool.java b/hutool-db/src/main/java/cn/hutool/db/dialect/DriverNamePool.java
index 6da118859..56392945a 100644
--- a/hutool-db/src/main/java/cn/hutool/db/dialect/DriverNamePool.java
+++ b/hutool-db/src/main/java/cn/hutool/db/dialect/DriverNamePool.java
@@ -108,5 +108,9 @@ public interface DriverNamePool {
* JDBC 驱动 Sybase
*/
String DRIVER_SYBASE = "com.sybase.jdbc4.jdbc.SybDriver";
+ /**
+ * JDBC 驱动 虚谷
+ */
+ String DRIVER_XUGO = "com.xugu.cloudjdbc.Driver";
}
From 4b44716b5fc78ef0dde8ec1febb4f2dfb30214d3 Mon Sep 17 00:00:00 2001
From: Looly
Date: Sat, 15 Jan 2022 13:30:44 +0800
Subject: [PATCH 08/28] add null ignore for CollectorUtil
---
CHANGELOG.md | 1 +
.../src/main/java/cn/hutool/core/stream/CollectorUtil.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 4a327694d..68ca938c2 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -12,6 +12,7 @@
* 【json 】 JSONGetter增加getBeanList方法
* 【core 】 ObjectUtil 添加三个defaultIfXxxx方法,用于节省CPU及内存损耗(pr#2094@Github)
* 【db 】 增加单条数据原生upsert语义支持(pr#501@Gitee)
+* 【core 】 在CollectorUtil提交Collectors.toMap的对null友好实现,避免NPE(pr#502@Gitee)
*
### 🐞Bug修复
* 【core 】 修复setter重载导致匹配错误(issue#2082@Github)
diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/CollectorUtil.java b/hutool-core/src/main/java/cn/hutool/core/stream/CollectorUtil.java
index 15e0d6d02..82821897d 100644
--- a/hutool-core/src/main/java/cn/hutool/core/stream/CollectorUtil.java
+++ b/hutool-core/src/main/java/cn/hutool/core/stream/CollectorUtil.java
@@ -18,7 +18,7 @@ import java.util.stream.Collector;
/**
* 可变的汇聚操作{@link Collector} 相关工具封装
*
- * @author looly
+ * @author looly, VampireAchao
* @since 5.6.7
*/
public class CollectorUtil {
From 749c0f8727c0e7140ca1897bd1030a5bf37b1a30 Mon Sep 17 00:00:00 2001
From: Looly
Date: Sat, 15 Jan 2022 19:22:40 +0800
Subject: [PATCH 09/28] fix bug
---
CHANGELOG.md | 1 +
.../hutool/core/bean/copier/BeanCopier.java | 1 +
.../core/date/TemporalAccessorUtil.java | 21 +++++++--
.../main/java/cn/hutool/json/JSONObject.java | 1 -
.../java/cn/hutool/json/Issue2090Test.java | 43 +++++++++++++++++++
.../java/cn/hutool/json/JSONObjectTest.java | 1 +
6 files changed, 64 insertions(+), 4 deletions(-)
create mode 100755 hutool-json/src/test/java/cn/hutool/json/Issue2090Test.java
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 68ca938c2..de4449f8f 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -20,6 +20,7 @@
* 【core 】 修复OS中的拼写错误(pr#500@Gitee)
* 【core 】 修复CustomKeyMap的merge失效问题(issue#2086@Github)
* 【core 】 修复FileUtil.appendLines换行问题(issue#I4QCEZ@Gitee)
+* 【core 】 修复java.time.Month解析问题(issue#2090@Github)
-------------------------------------------------------------------------------------------------------------
# 5.7.19 (2022-01-07)
diff --git a/hutool-core/src/main/java/cn/hutool/core/bean/copier/BeanCopier.java b/hutool-core/src/main/java/cn/hutool/core/bean/copier/BeanCopier.java
index 1b9afc7cf..c3f4cb35c 100644
--- a/hutool-core/src/main/java/cn/hutool/core/bean/copier/BeanCopier.java
+++ b/hutool-core/src/main/java/cn/hutool/core/bean/copier/BeanCopier.java
@@ -35,6 +35,7 @@ public class BeanCopier implements Copier, Serializable {
private static final long serialVersionUID = 1L;
/** 源对象 */
+ @SuppressWarnings("NonSerializableFieldInSerializableClass")
private final Object source;
/** 目标对象 */
private final T dest;
diff --git a/hutool-core/src/main/java/cn/hutool/core/date/TemporalAccessorUtil.java b/hutool-core/src/main/java/cn/hutool/core/date/TemporalAccessorUtil.java
index 1d9baef32..034f4868b 100644
--- a/hutool-core/src/main/java/cn/hutool/core/date/TemporalAccessorUtil.java
+++ b/hutool-core/src/main/java/cn/hutool/core/date/TemporalAccessorUtil.java
@@ -7,6 +7,7 @@ import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
+import java.time.Month;
import java.time.OffsetDateTime;
import java.time.OffsetTime;
import java.time.ZoneId;
@@ -40,7 +41,8 @@ public class TemporalAccessorUtil extends TemporalUtil{
}
/**
- * 格式化日期时间为指定格式
+ * 格式化日期时间为指定格式
+ * 如果为{@link Month},调用{@link Month#toString()}
*
* @param time {@link TemporalAccessor}
* @param formatter 日期格式化器,预定义的格式见:{@link DateTimeFormatter}
@@ -52,6 +54,10 @@ public class TemporalAccessorUtil extends TemporalUtil{
return null;
}
+ if(time instanceof Month){
+ return time.toString();
+ }
+
if(null == formatter){
formatter = DateTimeFormatter.ISO_LOCAL_DATE_TIME;
}
@@ -74,7 +80,8 @@ public class TemporalAccessorUtil extends TemporalUtil{
}
/**
- * 格式化日期时间为指定格式
+ * 格式化日期时间为指定格式
+ * 如果为{@link Month},调用{@link Month#toString()}
*
* @param time {@link TemporalAccessor}
* @param format 日期格式
@@ -86,6 +93,10 @@ public class TemporalAccessorUtil extends TemporalUtil{
return null;
}
+ if(time instanceof Month){
+ return time.toString();
+ }
+
// 检查自定义格式
if(GlobalCustomFormat.isCustomFormat(format)){
return GlobalCustomFormat.format(time, format);
@@ -98,13 +109,17 @@ public class TemporalAccessorUtil extends TemporalUtil{
}
/**
- * {@link TemporalAccessor}转换为 时间戳(从1970-01-01T00:00:00Z开始的毫秒数)
+ * {@link TemporalAccessor}转换为 时间戳(从1970-01-01T00:00:00Z开始的毫秒数)
+ * 如果为{@link Month},调用{@link Month#getValue()}
*
* @param temporalAccessor Date对象
* @return {@link Instant}对象
* @since 5.4.1
*/
public static long toEpochMilli(TemporalAccessor temporalAccessor) {
+ if(temporalAccessor instanceof Month){
+ return ((Month) temporalAccessor).getValue();
+ }
return toInstant(temporalAccessor).toEpochMilli();
}
diff --git a/hutool-json/src/main/java/cn/hutool/json/JSONObject.java b/hutool-json/src/main/java/cn/hutool/json/JSONObject.java
index 403070853..a7582edd4 100644
--- a/hutool-json/src/main/java/cn/hutool/json/JSONObject.java
+++ b/hutool-json/src/main/java/cn/hutool/json/JSONObject.java
@@ -671,7 +671,6 @@ public class JSONObject implements JSON, JSONGetter, Map
// 不支持对象类型转换为JSONObject
throw new JSONException("Unsupported type [{}] to JSONObject!", source.getClass());
}
-
}
/**
diff --git a/hutool-json/src/test/java/cn/hutool/json/Issue2090Test.java b/hutool-json/src/test/java/cn/hutool/json/Issue2090Test.java
new file mode 100755
index 000000000..f1f59b68e
--- /dev/null
+++ b/hutool-json/src/test/java/cn/hutool/json/Issue2090Test.java
@@ -0,0 +1,43 @@
+package cn.hutool.json;
+
+import lombok.Data;
+import org.junit.Assert;
+import org.junit.Test;
+
+import java.time.LocalDate;
+import java.time.Month;
+
+/**
+ * https://github.com/dromara/hutool/issues/2090
+ */
+public class Issue2090Test {
+
+ @Test
+ public void parseTest(){
+ final TestBean test = new TestBean();
+ test.setLocalDate(LocalDate.now());
+
+ final JSONObject json = JSONUtil.parseObj(test);
+ final TestBean test1 = json.toBean(TestBean.class);
+ Assert.assertEquals(test, test1);
+ }
+
+ @Test
+ public void parseLocalDateTest(){
+ LocalDate localDate = LocalDate.now();
+ final JSONObject jsonObject = JSONUtil.parseObj(localDate);
+ Assert.assertNotNull(jsonObject.toString());
+ }
+
+ @Test
+ public void monthTest(){
+ final JSONObject jsonObject = new JSONObject();
+ jsonObject.set("month", Month.JANUARY);
+ Assert.assertEquals("{\"month\":1}", jsonObject.toString());
+ }
+
+ @Data
+ public static class TestBean{
+ private LocalDate localDate;
+ }
+}
diff --git a/hutool-json/src/test/java/cn/hutool/json/JSONObjectTest.java b/hutool-json/src/test/java/cn/hutool/json/JSONObjectTest.java
index f3ae62388..3b18c8059 100644
--- a/hutool-json/src/test/java/cn/hutool/json/JSONObjectTest.java
+++ b/hutool-json/src/test/java/cn/hutool/json/JSONObjectTest.java
@@ -30,6 +30,7 @@ import org.junit.Test;
import java.math.BigDecimal;
import java.sql.Timestamp;
+import java.time.LocalDate;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
From 15a34bcc24a14ef0214d34d1b6f60cbb811ba092 Mon Sep 17 00:00:00 2001
From: Looly
Date: Sat, 15 Jan 2022 22:09:52 +0800
Subject: [PATCH 10/28] add method
---
CHANGELOG.md | 1 +
.../java/cn/hutool/http/HttpGlobalConfig.java | 25 +++++++++++++++++++
.../java/cn/hutool/http/HttpResponse.java | 3 ++-
3 files changed, 28 insertions(+), 1 deletion(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index de4449f8f..bb0310d47 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -13,6 +13,7 @@
* 【core 】 ObjectUtil 添加三个defaultIfXxxx方法,用于节省CPU及内存损耗(pr#2094@Github)
* 【db 】 增加单条数据原生upsert语义支持(pr#501@Gitee)
* 【core 】 在CollectorUtil提交Collectors.toMap的对null友好实现,避免NPE(pr#502@Gitee)
+* 【http 】 增加HttpGlobalConfig.setIgnoreEOFError(issue#2092@Github)
*
### 🐞Bug修复
* 【core 】 修复setter重载导致匹配错误(issue#2082@Github)
diff --git a/hutool-http/src/main/java/cn/hutool/http/HttpGlobalConfig.java b/hutool-http/src/main/java/cn/hutool/http/HttpGlobalConfig.java
index 918085592..99f28b1e1 100755
--- a/hutool-http/src/main/java/cn/hutool/http/HttpGlobalConfig.java
+++ b/hutool-http/src/main/java/cn/hutool/http/HttpGlobalConfig.java
@@ -32,6 +32,7 @@ public class HttpGlobalConfig implements Serializable {
private static boolean isAllowPatch = false;
private static String boundary = "--------------------Hutool_" + RandomUtil.randomString(16);
private static int maxRedirectCount = 0;
+ private static boolean ignoreEOFError = true;
/**
* 获取全局默认的超时时长
@@ -99,6 +100,30 @@ public class HttpGlobalConfig implements Serializable {
maxRedirectCount = customMaxRedirectCount;
}
+ /**
+ * 获取是否忽略响应读取时可能的EOF异常。
+ * 在Http协议中,对于Transfer-Encoding: Chunked在正常情况下末尾会写入一个Length为0的的chunk标识完整结束。
+ * 如果服务端未遵循这个规范或响应没有正常结束,会报EOF异常,此选项用于是否忽略这个异常。
+ *
+ * @return 是否忽略响应读取时可能的EOF异常
+ * @since 5.7.20
+ */
+ public static boolean isIgnoreEOFError() {
+ return ignoreEOFError;
+ }
+
+ /**
+ * 设置是否忽略响应读取时可能的EOF异常。
+ * 在Http协议中,对于Transfer-Encoding: Chunked在正常情况下末尾会写入一个Length为0的的chunk标识完整结束。
+ * 如果服务端未遵循这个规范或响应没有正常结束,会报EOF异常,此选项用于是否忽略这个异常。
+ *
+ * @param customIgnoreEOFError 是否忽略响应读取时可能的EOF异常。
+ * @since 5.7.20
+ */
+ synchronized public static void setIgnoreEOFError(boolean customIgnoreEOFError) {
+ ignoreEOFError = customIgnoreEOFError;
+ }
+
/**
* 获取Cookie管理器,用于自定义Cookie管理
*
diff --git a/hutool-http/src/main/java/cn/hutool/http/HttpResponse.java b/hutool-http/src/main/java/cn/hutool/http/HttpResponse.java
index 03ae911da..d43ae1e6c 100644
--- a/hutool-http/src/main/java/cn/hutool/http/HttpResponse.java
+++ b/hutool-http/src/main/java/cn/hutool/http/HttpResponse.java
@@ -588,7 +588,8 @@ public class HttpResponse extends HttpBase implements Closeable {
copyLength = IoUtil.copy(in, out, IoUtil.DEFAULT_BUFFER_SIZE, contentLength, streamProgress);
} catch (IORuntimeException e) {
//noinspection StatementWithEmptyBody
- if (e.getCause() instanceof EOFException || StrUtil.containsIgnoreCase(e.getMessage(), "Premature EOF")) {
+ if (HttpGlobalConfig.isIgnoreEOFError()
+ && (e.getCause() instanceof EOFException || StrUtil.containsIgnoreCase(e.getMessage(), "Premature EOF"))) {
// 忽略读取HTTP流中的EOF错误
} else {
throw e;
From cacf025b2fd27b67964f31fed1d23d743a8eb12a Mon Sep 17 00:00:00 2001
From: dream <52assert@gmail.com>
Date: Sun, 16 Jan 2022 00:09:44 +0800
Subject: [PATCH 11/28] =?UTF-8?q?fix:=20=E5=AF=B9RandomUtil.randomStringWi?=
=?UTF-8?q?thoutStr=E6=8E=92=E9=99=A4=E5=AD=97=E7=AC=A6=E4=B8=B2=E5=85=BC?=
=?UTF-8?q?=E5=AE=B9=E5=A4=A7=E5=86=99=E5=AD=97=E6=AF=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../src/main/java/cn/hutool/core/util/RandomUtil.java | 10 ++--------
.../test/java/cn/hutool/core/util/RandomUtilTest.java | 11 +++++++++++
2 files changed, 13 insertions(+), 8 deletions(-)
diff --git a/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java b/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java
index 8d77384e7..3e1db16a0 100644
--- a/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java
+++ b/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java
@@ -14,13 +14,7 @@ import java.math.BigDecimal;
import java.math.RoundingMode;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Date;
-import java.util.LinkedHashSet;
-import java.util.List;
-import java.util.Random;
-import java.util.Set;
+import java.util.*;
import java.util.concurrent.ThreadLocalRandom;
/**
@@ -524,7 +518,7 @@ public class RandomUtil {
*/
public static String randomStringWithoutStr(int length, String elemData) {
String baseStr = BASE_CHAR_NUMBER;
- baseStr = StrUtil.removeAll(baseStr, elemData.toCharArray());
+ baseStr = StrUtil.removeAll(baseStr, elemData.toLowerCase(Locale.ROOT).toCharArray());
return randomString(baseStr, length);
}
diff --git a/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java b/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java
index 978fcd2ed..1472dcd79 100644
--- a/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java
+++ b/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java
@@ -8,6 +8,7 @@ import org.junit.Test;
import java.math.RoundingMode;
import java.util.List;
+import java.util.Locale;
import java.util.Set;
public class RandomUtilTest {
@@ -59,4 +60,14 @@ public class RandomUtilTest {
char c = RandomUtil.randomChinese();
Assert.assertTrue(c > 0);
}
+ @Test
+ public void randomStringWithoutStrTest() {
+ for (int i = 0; i < 100; i++) {
+ final String s = RandomUtil.randomStringWithoutStr(8, "0IPOL");
+ System.out.println(s);
+ for (char c : "0IPOL".toCharArray()) {
+ Assert.assertFalse(s.contains((String.valueOf(c).toLowerCase(Locale.ROOT))));
+ }
+ }
+ }
}
From dd560ce5e34c38eab9d58ba1ce9df864f95c11fd Mon Sep 17 00:00:00 2001
From: Looly
Date: Sun, 16 Jan 2022 00:39:44 +0800
Subject: [PATCH 12/28] change code
---
CHANGELOG.md | 3 ++-
.../main/java/cn/hutool/core/util/RandomUtil.java | 14 ++++++++++----
.../java/cn/hutool/core/util/RandomUtilTest.java | 2 ++
3 files changed, 14 insertions(+), 5 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index bb0310d47..370e2162a 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -3,7 +3,7 @@
-------------------------------------------------------------------------------------------------------------
-# 5.7.20 (2022-01-15)
+# 5.7.20 (2022-01-16)
### 🐣新特性
* 【core 】 增加对null值友好的groupingBy操作的Collector实现,可指定map类型(pr#498@Gitee)
@@ -14,6 +14,7 @@
* 【db 】 增加单条数据原生upsert语义支持(pr#501@Gitee)
* 【core 】 在CollectorUtil提交Collectors.toMap的对null友好实现,避免NPE(pr#502@Gitee)
* 【http 】 增加HttpGlobalConfig.setIgnoreEOFError(issue#2092@Github)
+* 【core 】 RandomUtil.randomStringWithoutStr排除字符串兼容大写字母(pr#503@Gitee)
*
### 🐞Bug修复
* 【core 】 修复setter重载导致匹配错误(issue#2082@Github)
diff --git a/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java b/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java
index 3e1db16a0..2c415b386 100644
--- a/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java
+++ b/hutool-core/src/main/java/cn/hutool/core/util/RandomUtil.java
@@ -14,7 +14,13 @@ import java.math.BigDecimal;
import java.math.RoundingMode;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Date;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Random;
+import java.util.Set;
import java.util.concurrent.ThreadLocalRandom;
/**
@@ -510,15 +516,15 @@ public class RandomUtil {
}
/**
- * 获得一个随机的字符串(只包含数字和字符) 并排除指定字符串
+ * 获得一个随机的字符串(只包含数字和小写字母) 并排除指定字符串
*
* @param length 字符串的长度
- * @param elemData 要排除的字符串,如:去重容易混淆的字符串,oO0、lL1、q9Q、pP
+ * @param elemData 要排除的字符串,如:去重容易混淆的字符串,oO0、lL1、q9Q、pP,不区分大小写
* @return 随机字符串
*/
public static String randomStringWithoutStr(int length, String elemData) {
String baseStr = BASE_CHAR_NUMBER;
- baseStr = StrUtil.removeAll(baseStr, elemData.toLowerCase(Locale.ROOT).toCharArray());
+ baseStr = StrUtil.removeAll(baseStr, elemData.toLowerCase().toCharArray());
return randomString(baseStr, length);
}
diff --git a/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java b/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java
index 1472dcd79..e61e5bcbf 100644
--- a/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java
+++ b/hutool-core/src/test/java/cn/hutool/core/util/RandomUtilTest.java
@@ -60,7 +60,9 @@ public class RandomUtilTest {
char c = RandomUtil.randomChinese();
Assert.assertTrue(c > 0);
}
+
@Test
+ @Ignore
public void randomStringWithoutStrTest() {
for (int i = 0; i < 100; i++) {
final String s = RandomUtil.randomStringWithoutStr(8, "0IPOL");
From cba165983323fe3ffa5576125605c8cf5c586b19 Mon Sep 17 00:00:00 2001
From: VampireAchao
Date: Mon, 17 Jan 2022 14:40:16 +0800
Subject: [PATCH 13/28] =?UTF-8?q?=E4=BF=AE=E5=A4=8DofTry=E4=B8=AD=E5=B9=B6?=
=?UTF-8?q?=E5=8F=91=E7=8E=AF=E5=A2=83=E4=B8=8B=E7=BA=BF=E7=A8=8B=E5=AE=89?=
=?UTF-8?q?=E5=85=A8=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../src/main/java/cn/hutool/core/lang/Opt.java | 2 +-
.../test/java/cn/hutool/core/lang/OptTest.java | 15 +++++++++++++++
2 files changed, 16 insertions(+), 1 deletion(-)
diff --git a/hutool-core/src/main/java/cn/hutool/core/lang/Opt.java b/hutool-core/src/main/java/cn/hutool/core/lang/Opt.java
index e03ad64cd..dad1b5cd0 100644
--- a/hutool-core/src/main/java/cn/hutool/core/lang/Opt.java
+++ b/hutool-core/src/main/java/cn/hutool/core/lang/Opt.java
@@ -122,7 +122,7 @@ public class Opt {
try {
return Opt.ofNullable(supplier.call());
} catch (Exception e) {
- final Opt empty = Opt.empty();
+ final Opt empty = new Opt<>(null);
empty.exception = e;
return empty;
}
diff --git a/hutool-core/src/test/java/cn/hutool/core/lang/OptTest.java b/hutool-core/src/test/java/cn/hutool/core/lang/OptTest.java
index 0bdab907d..41d2d19c3 100644
--- a/hutool-core/src/test/java/cn/hutool/core/lang/OptTest.java
+++ b/hutool-core/src/test/java/cn/hutool/core/lang/OptTest.java
@@ -187,6 +187,21 @@ public class OptTest {
Assert.assertEquals(indexOut, indexOutSituation);
Assert.assertEquals("hutool", npe);
Assert.assertEquals("hutool", indexOut);
+
+ // 多线程下情况测试
+ Stream.iterate(0, i -> ++i).limit(20000).parallel().forEach(i -> {
+ Opt