diff --git a/jero-boot/jero-boot-base/jero-boot-base-core/src/main/java/com/jero/common/util/dynamic/db/DynamicDBUtil.java b/jero-boot/jero-boot-base/jero-boot-base-core/src/main/java/com/jero/common/util/dynamic/db/DynamicDBUtil.java index 25281d8d..0db47ab7 100644 --- a/jero-boot/jero-boot-base/jero-boot-base-core/src/main/java/com/jero/common/util/dynamic/db/DynamicDBUtil.java +++ b/jero-boot/jero-boot-base/jero-boot-base-core/src/main/java/com/jero/common/util/dynamic/db/DynamicDBUtil.java @@ -11,9 +11,9 @@ import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; import java.sql.SQLException; -import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Objects; /** * Spring JDBC 实时数据库访问 @@ -138,12 +138,12 @@ public class DynamicDBUtil { * @param data sql语法中需要判断的数据及sql拼接注入中需要的数据 * @return */ - public static int updateByHash(final String dbKey, String sql, HashMap data) { + public static int updateByHash(final String dbKey, String sql, Map data) { int effectCount; JdbcTemplate jdbcTemplate = getJdbcTemplate(dbKey); //根据模板获取sql sql = FreemarkerParseFactory.parseTemplateContent(sql, data); - NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate.getDataSource()); + NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(Objects.requireNonNull(jdbcTemplate.getDataSource())); effectCount = namedParameterJdbcTemplate.update(sql, data); return effectCount; } @@ -169,7 +169,7 @@ public class DynamicDBUtil { * @param data sql语法中需要判断的数据及sql拼接注入中需要的数据 * @return */ - public static Object findOneByHash(final String dbKey, String sql, HashMap data) { + public static Object findOneByHash(final String dbKey, String sql, Map data) { List> list; list = findListByHash(dbKey, sql, data); if (oConvertUtils.listIsEmpty(list)) { @@ -206,7 +206,7 @@ public class DynamicDBUtil { * @return */ @SuppressWarnings("unchecked") - public static Object findOneByHash(final String dbKey, String sql, Class clazz, HashMap data) { + public static Object findOneByHash(final String dbKey, String sql, Class clazz, Map data) { Map map = (Map) findOneByHash(dbKey, sql, data); return ReflectHelper.setAll(clazz, map); } @@ -231,12 +231,12 @@ public class DynamicDBUtil { * @param data sql语法中需要判断的数据及sql拼接注入中需要的数据 * @return */ - public static List> findListByHash(final String dbKey, String sql, HashMap data) { + public static List> findListByHash(final String dbKey, String sql, Map data) { List> list; JdbcTemplate jdbcTemplate = getJdbcTemplate(dbKey); //根据模板获取sql sql = FreemarkerParseFactory.parseTemplateContent(sql, data); - NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate.getDataSource()); + NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(Objects.requireNonNull(jdbcTemplate.getDataSource())); list = namedParameterJdbcTemplate.queryForList(sql, data); return list; } @@ -263,12 +263,12 @@ public class DynamicDBUtil { * @param data sql语法中需要判断的数据及sql拼接注入中需要的数据 * @return */ - public static List findListByHash(final String dbKey, String sql, Class clazz, HashMap data) { + public static List findListByHash(final String dbKey, String sql, Class clazz, Map data) { List list; JdbcTemplate jdbcTemplate = getJdbcTemplate(dbKey); //根据模板获取sql sql = FreemarkerParseFactory.parseTemplateContent(sql, data); - NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate.getDataSource()); + NamedParameterJdbcTemplate namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(Objects.requireNonNull(jdbcTemplate.getDataSource())); list = namedParameterJdbcTemplate.queryForList(sql, data, clazz); return list; } @@ -296,7 +296,7 @@ public class DynamicDBUtil { * @param data sql语法中需要判断的数据及sql拼接注入中需要的数据 * @return */ - public static List findListEntitiesByHash(final String dbKey, String sql, Class clazz, HashMap data) { + public static List findListEntitiesByHash(final String dbKey, String sql, Class clazz, Map data) { List> queryList = findListByHash(dbKey, sql, data); return ReflectHelper.transList2Entrys(queryList, clazz); }