ai.yue.library.data.jdbc.client

Class Db

java.lang.Object

ai.yue.library.data.jdbc.client.DbBase

ai.yue.library.data.jdbc.client.Db

All Implemented Interfaces:

Cloneable

public class Db
extends DbBase
implements Cloneable

SQL优化型数据库操作

Created by sunJinChuan on 2016/6/6

Since:

0.0.1

Field Summary

Fields inherited from class ai.yue.library.data.jdbc.client.DbBase

dialect

Constructor Summary

Constructors

Constructor and Description
Db(DataSource dataSource)
Db(Dialect dialect)

Method Summary

Modifier and Type	Method and Description
Db	clone() 克隆Db 适用于需要复制原有Db配置，并创建新的Db对象以进行修改配置等场景 如：需要对操作的某个DAO单独配置 DbBase.getJdbcProperties() JdbcProperties#setEnableDeleteQueryFilter(boolean) 属性
long	delete(String tableName, com.alibaba.fastjson.JSONObject paramJson) 删除
void	delete(String tableName, Long id) 删除
void	deleteBatch(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons) 删除-批量
int[]	deleteBatch2(String sql, com.alibaba.fastjson.JSONObject[] paramJsons) 删除-批量
void	deleteBatchLogic(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons) 删除-批量-逻辑的
void	deleteBatchLogicNotParamFormat(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons) 删除-批量-逻辑的（不调用 DbBase.paramFormat(JSONObject) 方法）
void	deleteBatchNotParamFormat(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons) 删除-批量
int[]	deleteBatchNotParamFormat2(String sql, com.alibaba.fastjson.JSONObject[] paramJsons) 删除-批量
void	deleteByBusinessUk(String tableName, String businessUkValue) 删除-通过表业务键
long	deleteLogic(String tableName, com.alibaba.fastjson.JSONObject paramJson) 删除-逻辑的
void	deleteLogic(String tableName, Long id) 删除-逻辑的
void	deleteLogicByBusinessUk(String tableName, String businessUkValue) 删除-逻辑的
void	deleteSafe(String tableName, Long id) Deprecated. 请使用：delete(String, Long)
com.alibaba.fastjson.JSONObject	get(String tableName, com.alibaba.fastjson.JSONObject paramJson) 单个-绝对条件查询
<T> T	get(String tableName, com.alibaba.fastjson.JSONObject paramJson, Class<T> mappedClass) 单个-绝对条件查询
com.alibaba.fastjson.JSONObject	getByBusinessUk(String tableName, String businessUkValue) 单个-By业务键
<T> T	getByBusinessUk(String tableName, String businessUkValue, Class<T> mappedClass) 单个-By业务键
com.alibaba.fastjson.JSONObject	getById(String tableName, long id) 单个-ById
<T> T	getById(String tableName, Long id, Class<T> mappedClass) 单个-ById
long	getCount(String tableName) 获得总数
org.springframework.jdbc.support.rowset.SqlRowSetMetaData	getMetaData(String tableName) 获得表的元数据
Long	insert(String tableName, com.alibaba.fastjson.JSONObject paramJson) 插入一条数据，主键必须为有序
void	insertBatch(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons) 批量插入数据，主键必须为有序
void	insertBatchNotParamFormat(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons) 批量插入数据，主键必须为有序 （不调用 DbBase.paramFormat(JSONObject) 方法）。
void	insertNotReturn(String tableName, com.alibaba.fastjson.JSONObject paramJson) 插入一条数据
Long	insertOrUpdate(String tableName, com.alibaba.fastjson.JSONObject paramJson, String[] conditions, DbUpdateEnum dBUpdateEnum) 插入或更新 表中必须存在数据唯一性约束
Long	insertWithSortIdxAutoIncrement(String tableName, com.alibaba.fastjson.JSONObject paramJson, String... uniqueKeys) 插入一条数据，并自动递增 sort_idx 使用条件：
boolean	isDataSize(String tableName, com.alibaba.fastjson.JSONObject paramJson) Deprecated. 请使用：isExistData(String, JSONObject)
boolean	isExistData(String tableName, com.alibaba.fastjson.JSONObject paramJson) 是否有数据
BigDecimal	jdbcQueryBigDecimal(String sql, Object... args)
Boolean	jdbcQueryBoolean(String sql, Object... args)
Date	jdbcQueryDate(String sql, Object... args)
Double	jdbcQueryDouble(String sql, Object... args)
com.alibaba.fastjson.JSONObject	jdbcQueryForJson(String sql, Object... args) 查询一行数据
<T> List<T>	jdbcQueryForList(String sql, Class<T> mappedClass, Object... args) 查询多行数据
List<com.alibaba.fastjson.JSONObject>	jdbcQueryForList(String sql, Object... args) 查询多行数据
<T> T	jdbcQueryForObj(String sql, Class<T> mappedClass, Object... args) 查询一行数据
Integer	jdbcQueryInt(String sql, Object... args)
LocalDate	jdbcQueryLocalDate(String sql, Object... args)
LocalDateTime	jdbcQueryLocalDateTime(String sql, Object... args)
Long	jdbcQueryLong(String sql, Object... args)
Number	jdbcQueryNumber(String sql, Object... args)
String	jdbcQueryStr(String sql, Object... args)
List<com.alibaba.fastjson.JSONObject>	list(String tableName, com.alibaba.fastjson.JSONObject paramJson) 列表-绝对条件查询
<T> List<T>	list(String tableName, com.alibaba.fastjson.JSONObject paramJson, Class<T> mappedClass) 列表-绝对条件查询
List<com.alibaba.fastjson.JSONObject>	list(String tableName, com.alibaba.fastjson.JSONObject paramJson, SortEnum sortEnum) 列表-绝对条件查询
<T> List<T>	list(String tableName, com.alibaba.fastjson.JSONObject paramJson, SortEnum sortEnum, Class<T> mappedClass) 列表-绝对条件查询
List<com.alibaba.fastjson.JSONObject>	listAll(String tableName) 列表-查询表中所有数据
<T> List<T>	listAll(String tableName, Class<T> mappedClass) 列表-查询表中所有数据
PageVO<com.alibaba.fastjson.JSONObject>	page(String tableName, PageIPO pageIPO) 单表分页查询
<T> PageVO<T>	page(String tableName, PageIPO pageIPO, Class<T> mappedClass) 单表分页查询
PageVO<com.alibaba.fastjson.JSONObject>	page(String tableName, PageIPO pageIPO, SortEnum sortEnum) 单表分页查询
<T> PageVO<T>	page(String tableName, PageIPO pageIPO, SortEnum sortEnum, Class<T> mappedClass) 单表分页查询
PageBeforeAndAfterVO	pageBeforeAndAfter(String querySql, PageIPO pageIPO, Long equalsId) 根据相同的列表条件，获得上一条与下一条数据
PageVO<com.alibaba.fastjson.JSONObject>	pageSql(String querySql, PageIPO pageIPO) 复杂SQL分页查询
<T> PageVO<T>	pageSql(String querySql, PageIPO pageIPO, Class<T> mappedClass) 复杂SQL分页查询
PageVO<com.alibaba.fastjson.JSONObject>	pageSql(String countSql, String querySql, PageIPO pageIPO) 复杂SQL分页查询
<T> PageVO<T>	pageSql(String countSql, String querySql, PageIPO pageIPO, Class<T> mappedClass) 复杂SQL分页查询
PageVO<com.alibaba.fastjson.JSONObject>	pageWhere(String tableName, String whereSql, PageIPO pageIPO) 单表分页查询
<T> PageVO<T>	pageWhere(String tableName, String whereSql, PageIPO pageIPO, Class<T> mappedClass) 单表分页查询
<T> T	queryObject(String sql, com.alibaba.fastjson.JSONObject paramJson, Class<T> mappedClass) Deprecated. 请使用：DbBase.queryForObject(String, JSONObject, Class)
long	update(String sql, com.alibaba.fastjson.JSONObject paramJson) 更新数据 同 NamedParameterJdbcTemplate.update(String, Map)
void	update(String sql, com.alibaba.fastjson.JSONObject paramJson, int expectedValue, DbExpectedEnum dBExpectedEnum) 更新数据 对 NamedParameterJdbcTemplate.update(String, Map) 方法的增强实现 将会对更新所影响的行数进行预期判断，若结果不符合预期值：expectedValue，那么此处便会抛出一个 DbException
Long	update(String tableName, com.alibaba.fastjson.JSONObject paramJson, String[] conditions) 绝对条件更新优化SQL 相对条件更新优化SQL可参照如下编写： UPDATE table SET paramNumber1 = paramNumber1 - 1, ... WHERE id = :id AND paramNumber1 > 0 AND ...
Long	update(String tableName, com.alibaba.fastjson.JSONObject paramJson, String[] conditions, DbUpdateEnum dBUpdateEnum) 绝对条件更新优化SQL
void	update(String tableName, com.alibaba.fastjson.JSONObject paramJson, String[] conditions, DbUpdateEnum dBUpdateEnum, int expectedValue, DbExpectedEnum dBExpectedEnum) 绝对条件更新优化SQL
Long	update(String sql, org.springframework.jdbc.core.namedparam.SqlParameterSource paramSource) 更新或插入数据，主键默认为id时使用。
org.springframework.jdbc.support.KeyHolder	update(String sql, org.springframework.jdbc.core.namedparam.SqlParameterSource paramSource, org.springframework.jdbc.support.KeyHolder generatedKeyHolder) 更新或插入数据 同 NamedParameterJdbcTemplate.update(String, SqlParameterSource, KeyHolder)
int[]	updateBatch(String sql, com.alibaba.fastjson.JSONObject[] paramJsons) 对多组参数进行批量更新处理 同 NamedParameterJdbcTemplate.batchUpdate(String, Map[])
void	updateBatch(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons, String[] conditions, DbUpdateEnum dBUpdateEnum) 更新-批量
int[]	updateBatchNotParamFormat(String sql, com.alibaba.fastjson.JSONObject[] paramJsons) 对多组参数进行批量更新处理 同 NamedParameterJdbcTemplate.batchUpdate(String, Map[])
void	updateBatchNotParamFormat(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons, String[] conditions, DbUpdateEnum dBUpdateEnum) 更新-批量（不调用 DbBase.paramFormat(JSONObject) 方法）
void	updateByBusinessUk(String tableName, com.alibaba.fastjson.JSONObject paramJson) 更新-By业务键
void	updateByBusinessUk(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons, DbUpdateEnum dBUpdateEnum) 批量更新-By业务键
void	updateByBusinessUk(String tableName, com.alibaba.fastjson.JSONObject paramJson, DbUpdateEnum dBUpdateEnum) 更新-By业务键
void	updateByBusinessUkNotParamFormat(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons, DbUpdateEnum dBUpdateEnum) 批量更新-By业务键（不调用 DbBase.paramFormat(JSONObject) 方法）
void	updateById(String tableName, com.alibaba.fastjson.JSONObject paramJson) 更新-ById
void	updateById(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons, DbUpdateEnum dBUpdateEnum) 批量更新-ById
void	updateById(String tableName, com.alibaba.fastjson.JSONObject paramJson, DbUpdateEnum dBUpdateEnum) 更新-ById
void	updateByIdNotParamFormat(String tableName, com.alibaba.fastjson.JSONObject[] paramJsons, DbUpdateEnum dBUpdateEnum) 批量更新-ById（不调用 DbBase.paramFormat(JSONObject) 方法）
void	updateSort(String tableName, Long id, Integer move, String... uniqueKeys) 更新-排序 使用限制：见 DbInsert.insertWithSortIdxAutoIncrement(String, JSONObject, String...)
protected String	updateSqlBuild(String tableName, com.alibaba.fastjson.JSONObject paramJson, String[] conditions, DbUpdateEnum dBUpdateEnum) 构建绝对条件更新优化SQL

Methods inherited from class ai.yue.library.data.jdbc.client.DbBase

aopAfter, aopAfter, aopAfter, aopBefore, aopBefore, audit, extractTables, getDataSource, getDeleteWhereSql, getJdbcProperties, getJdbcTemplate, getNamedParameterJdbcTemplate, getRowMapper, isDataSize, isUpdateAndExpectedEqual, isUpdateAndExpectedGreaterThanEqual, listResultToGetResult, paramFormat, paramToWhereSql, paramToWhereSql, paramValidate, paramValidate, paramValidate, paramValidate, paramValidate, paramValidate, paramValidate, paramValidate, queryForJson, queryForList, queryForList, queryForObject, queryForRowSet, resultToJson, resultToObject, setDataSource, updateAndExpectedEqual, updateAndExpectedGreaterThanEqual, updateBatchAndExpectedEqual

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Db

public Db(DataSource dataSource)

Db

public Db(Dialect dialect)

Method Detail

clone

public Db clone()

克隆Db

• 适用于需要复制原有Db配置，并创建新的Db对象以进行修改配置等场景
• 如：需要对操作的某个DAO单独配置 DbBase.getJdbcProperties() JdbcProperties#setEnableDeleteQueryFilter(boolean) 属性

Overrides:

clone in class Object

insert

@Transactional
public Long insert(String tableName,
                                  com.alibaba.fastjson.JSONObject paramJson)

插入一条数据，主键必须为有序

Parameters:

tableName - 表名

paramJson - 参数

Returns:

返回主键值

insertNotReturn

@Transactional
public void insertNotReturn(String tableName,
                                           com.alibaba.fastjson.JSONObject paramJson)

插入一条数据

Parameters:

tableName - 表名

paramJson - 参数

insertWithSortIdxAutoIncrement

@Transactional
public Long insertWithSortIdxAutoIncrement(String tableName,
                                                          com.alibaba.fastjson.JSONObject paramJson,
                                                          @Nullable
                                                          String... uniqueKeys)

插入一条数据，并自动递增 sort_idx

使用条件：

1. id 默认为主键

2. sort_idx 默认为排序字段，类型为 int unsigned 。DDL示例：`sort_idx` tinyint(2) UNSIGNED NOT NULL COMMENT '排序-索引'

Parameters:

tableName - 表名

paramJson - 插入数据

uniqueKeys - 同sort_idx字段组合的唯一约束keys（表中不建议建立sort_idx字段的唯一约束，但可以建立普通索引，以便于提高查询性能），可选参数

Returns:

返回主键值

insertBatch

public void insertBatch(String tableName,
                        com.alibaba.fastjson.JSONObject[] paramJsons)

批量插入数据，主键必须为有序

Parameters:

tableName - 表名

paramJsons - 参数

insertBatchNotParamFormat

@Transactional
public void insertBatchNotParamFormat(String tableName,
                                                     com.alibaba.fastjson.JSONObject[] paramJsons)

批量插入数据，主键必须为有序 （不调用 DbBase.paramFormat(JSONObject) 方法）。

Parameters:

tableName - 表名

paramJsons - 参数

insertOrUpdate

@Transactional
public Long insertOrUpdate(String tableName,
                                          com.alibaba.fastjson.JSONObject paramJson,
                                          String[] conditions,
                                          DbUpdateEnum dBUpdateEnum)

插入或更新
表中必须存在数据唯一性约束

更新触发条件：此数据若存在唯一性约束则更新，否则便执行插入数据

MySQL执行示例：
INSERT INTO table (param1, param2, ...)
VALUES
(:param1, :param2, ...)
ON DUPLICATE KEY UPDATE
condition = condition + :condition, ...

Parameters:

tableName - 表名

paramJson - 插入或更新所用到的参数

conditions - 更新条件（对应paramJson内的key值）

dBUpdateEnum - 更新类型 DbUpdateEnum

Returns:

受影响的行数

delete

@Transactional(rollbackFor={java.lang.RuntimeException.class,java.lang.Error.class})
public void delete(String tableName,
                                                                                                        Long id)

删除

数据删除前会先进行条数确认

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 deleteByBusinessUk(String, String)

Parameters:

tableName - 表名

id - 主键id

deleteSafe

@Deprecated
public void deleteSafe(String tableName,
                                   Long id)

Deprecated. 请使用：delete(String, Long)

删除-安全的

数据删除前会先进行条数确认

Parameters:

tableName - 表名

id - 主键id

deleteByBusinessUk

@Transactional(rollbackFor={java.lang.RuntimeException.class,java.lang.Error.class})
public void deleteByBusinessUk(String tableName,
                                                                                                                    String businessUkValue)

删除-通过表业务键

数据删除前会先进行条数确认

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

businessUkValue - 业务键的唯一值

delete

@Transactional(rollbackFor={java.lang.RuntimeException.class,java.lang.Error.class})
public long delete(String tableName,
                                                                                                        com.alibaba.fastjson.JSONObject paramJson)

删除

Parameters:

tableName - 表名

paramJson - 条件

Returns:

删除所影响的行数

deleteBatch

@Transactional
public void deleteBatch(String tableName,
                                       com.alibaba.fastjson.JSONObject[] paramJsons)

删除-批量

一组条件对应一条数据，并且每组条件都采用相同的key

Parameters:

tableName - 表名

paramJsons - 条件数组

deleteBatchNotParamFormat

@Transactional
public void deleteBatchNotParamFormat(String tableName,
                                                     com.alibaba.fastjson.JSONObject[] paramJsons)

删除-批量

不调用 DbBase.paramFormat(JSONObject) 方法

一组条件对应一条数据，并且每组条件都采用相同的key

Parameters:

tableName - 表名

paramJsons - 条件数组

deleteBatch2

@Transactional
public int[] deleteBatch2(String sql,
                                         com.alibaba.fastjson.JSONObject[] paramJsons)

删除-批量

同 NamedParameterJdbcTemplate.batchUpdate(String, Map[])

示例：DELETE FROM table WHERE id = :id

Parameters:

sql - 要执行的删除SQL

paramJsons - 删除所用到的条件数组

Returns:

一个数组，其中包含受批处理中每个更新影响的行数

deleteBatchNotParamFormat2

@Transactional
public int[] deleteBatchNotParamFormat2(String sql,
                                                       com.alibaba.fastjson.JSONObject[] paramJsons)

删除-批量

不调用 DbBase.paramFormat(JSONObject) 方法

同 NamedParameterJdbcTemplate.batchUpdate(String, Map[])

示例：DELETE FROM table WHERE id = :id

Parameters:

sql - 要执行的删除SQL

paramJsons - 删除所用到的条件数组

Returns:

一个数组，其中包含受批处理中每个更新影响的行数

deleteLogic

@Transactional
public void deleteLogic(String tableName,
                                       Long id)

删除-逻辑的

数据非真实删除，而是更改 字段值为时间戳，代表数据已删除

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 deleteLogicByBusinessUk(String, String)

Parameters:

tableName - 表名

id - 主键id

deleteLogicByBusinessUk

@Transactional
public void deleteLogicByBusinessUk(String tableName,
                                                   String businessUkValue)

删除-逻辑的

数据非真实删除，而是更改 字段值为时间戳，代表数据已删除

Parameters:

tableName - 表名

businessUkValue - 业务键的唯一值

deleteLogic

@Transactional
public long deleteLogic(String tableName,
                                       com.alibaba.fastjson.JSONObject paramJson)

删除-逻辑的

数据非真实删除，而是更改 字段值为时间戳，代表数据已删除

Parameters:

tableName - 表名

paramJson - 条件

Returns:

删除所影响的行数

deleteBatchLogic

@Transactional
public void deleteBatchLogic(String tableName,
                                            com.alibaba.fastjson.JSONObject[] paramJsons)

删除-批量-逻辑的

数据非真实删除，而是更改 字段值为时间戳，代表数据已删除

一组条件对应一条数据，并且每组条件都采用相同的key

Parameters:

tableName - 表名

paramJsons - 条件数组

deleteBatchLogicNotParamFormat

@Transactional
public void deleteBatchLogicNotParamFormat(String tableName,
                                                          com.alibaba.fastjson.JSONObject[] paramJsons)

删除-批量-逻辑的（不调用 DbBase.paramFormat(JSONObject) 方法）

数据非真实删除，而是更改 字段值为时间戳，代表数据已删除

一组条件对应一条数据，并且每组条件都采用相同的key

Parameters:

tableName - 表名

paramJsons - 条件数组

update

@Transactional
public org.springframework.jdbc.support.KeyHolder update(String sql,
                                                                        org.springframework.jdbc.core.namedparam.SqlParameterSource paramSource,
                                                                        org.springframework.jdbc.support.KeyHolder generatedKeyHolder)

更新或插入数据
同 NamedParameterJdbcTemplate.update(String, SqlParameterSource, KeyHolder)

Parameters:

sql - 要执行的更新SQL

paramSource - 更新所用到的参数：MapSqlParameterSource，BeanPropertySqlParameterSource

Returns:

自动生成的键(可能由JDBC insert语句返回)或更新的主键id值。

update

@Transactional
public Long update(String sql,
                                  org.springframework.jdbc.core.namedparam.SqlParameterSource paramSource)

更新或插入数据，主键默认为id时使用。

Parameters:

sql - 更新或插入SQL

paramSource - 更新所用到的参数：MapSqlParameterSource，BeanPropertySqlParameterSource

Returns:

自动生成的键(可能由JDBC insert语句返回)或更新的主键id值。

update

@Transactional
public long update(String sql,
                                  com.alibaba.fastjson.JSONObject paramJson)

更新数据
同 NamedParameterJdbcTemplate.update(String, Map)

Parameters:

sql - 要执行的更新SQL

paramJson - 更新所用到的参数

Returns:

受影响的行数

update

@Transactional
public void update(String sql,
                                  com.alibaba.fastjson.JSONObject paramJson,
                                  int expectedValue,
                                  DbExpectedEnum dBExpectedEnum)

更新数据

• 对 NamedParameterJdbcTemplate.update(String, Map) 方法的增强实现
• 将会对更新所影响的行数进行预期判断，若结果不符合预期值：expectedValue，那么此处便会抛出一个 DbException

Parameters:

sql - 要执行的更新SQL

paramJson - 更新所用到的参数

expectedValue - 更新所影响的行数预期值

dBExpectedEnum - 预期值确认方式

updateBatch

@Transactional
public int[] updateBatch(String sql,
                                        com.alibaba.fastjson.JSONObject[] paramJsons)

对多组参数进行批量更新处理
同 NamedParameterJdbcTemplate.batchUpdate(String, Map[])

Parameters:

sql - 要执行的更新SQL

paramJsons - 更新所用到的参数数组

Returns:

一个数组，其中包含受批处理中每个更新影响的行数

updateBatchNotParamFormat

@Transactional
public int[] updateBatchNotParamFormat(String sql,
                                                      com.alibaba.fastjson.JSONObject[] paramJsons)

对多组参数进行批量更新处理
同 NamedParameterJdbcTemplate.batchUpdate(String, Map[])

Parameters:

sql - 要执行的更新SQL

paramJsons - 更新所用到的参数数组（不调用 DbBase.paramFormat(JSONObject) 方法）

Returns:

一个数组，其中包含受批处理中每个更新影响的行数

updateSqlBuild

protected String updateSqlBuild(String tableName,
                                com.alibaba.fastjson.JSONObject paramJson,
                                String[] conditions,
                                DbUpdateEnum dBUpdateEnum)

构建绝对条件更新优化SQL

Parameters:

tableName - 表名

paramJson - 更新所用到的参数

conditions - 作为更新条件的参数名，对应paramJson内的key（注意：作为条件的参数，将不会用于字段值的更新）

dBUpdateEnum - 更新类型 DbUpdateEnum

Returns:

绝对条件更新优化SQL

update

@Transactional
public Long update(String tableName,
                                  com.alibaba.fastjson.JSONObject paramJson,
                                  String[] conditions)

绝对条件更新优化SQL

相对条件更新优化SQL可参照如下编写：
UPDATE table
SET paramNumber1 = paramNumber1 - 1, ...
WHERE
id = :id
AND
paramNumber1 > 0
AND ...

Parameters:

tableName - 表名

paramJson - 更新所用到的参数（where条件参数不会用于set值的更新）

conditions - 作为更新条件的参数名，对应paramJson内的key（注意：作为条件的参数，将不会用于字段值的更新）

Returns:

受影响的行数

update

@Transactional
public Long update(String tableName,
                                  com.alibaba.fastjson.JSONObject paramJson,
                                  String[] conditions,
                                  DbUpdateEnum dBUpdateEnum)

绝对条件更新优化SQL

Parameters:

tableName - 表名

paramJson - 更新所用到的参数

conditions - 作为更新条件的参数名，对应paramJson内的key（注意：作为条件的参数，将不会用于字段值的更新）

dBUpdateEnum - 更新类型 DbUpdateEnum

Returns:

受影响的行数

update

@Transactional
public void update(String tableName,
                                  com.alibaba.fastjson.JSONObject paramJson,
                                  String[] conditions,
                                  DbUpdateEnum dBUpdateEnum,
                                  int expectedValue,
                                  DbExpectedEnum dBExpectedEnum)

绝对条件更新优化SQL

Parameters:

tableName - 表名

paramJson - 更新所用到的参数

conditions - 作为更新条件的参数名，对应paramJson内的key（注意：作为条件的参数，将不会用于字段值的更新）

dBUpdateEnum - 更新类型 DbUpdateEnum

expectedValue - 更新所影响的行数预期值

dBExpectedEnum - 预期值确认方式

updateById

@Transactional
public void updateById(String tableName,
                                      com.alibaba.fastjson.JSONObject paramJson)

更新-ById

根据表中主键ID进行更新

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 updateByBusinessUk(String, JSONObject)

Parameters:

tableName - 表名

paramJson - 更新所用到的参数（包含主键ID字段）

updateById

@Transactional
public void updateById(String tableName,
                                      com.alibaba.fastjson.JSONObject paramJson,
                                      DbUpdateEnum dBUpdateEnum)

更新-ById

根据表中主键ID进行更新

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 updateByBusinessUk(String, JSONObject, DbUpdateEnum)

Parameters:

tableName - 表名

paramJson - 更新所用到的参数（包含主键ID字段）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateById

@Transactional
public void updateById(String tableName,
                                      com.alibaba.fastjson.JSONObject[] paramJsons,
                                      DbUpdateEnum dBUpdateEnum)

批量更新-ById

根据表中主键ID进行批量更新

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 updateByBusinessUk(String, JSONObject[], DbUpdateEnum)

Parameters:

tableName - 表名

paramJsons - 更新所用到的参数数组（包含主键ID字段）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateByIdNotParamFormat

@Transactional
public void updateByIdNotParamFormat(String tableName,
                                                    com.alibaba.fastjson.JSONObject[] paramJsons,
                                                    DbUpdateEnum dBUpdateEnum)

批量更新-ById（不调用 DbBase.paramFormat(JSONObject) 方法）

根据表中主键ID进行批量更新

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 updateByBusinessUkNotParamFormat(String, JSONObject[], DbUpdateEnum)

Parameters:

tableName - 表名

paramJsons - 更新所用到的参数数组（包含主键ID字段）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateByBusinessUk

@Transactional
public void updateByBusinessUk(String tableName,
                                              com.alibaba.fastjson.JSONObject paramJson)

更新-By业务键

根据表中业务键进行更新

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

paramJson - 更新所用到的参数（包含业务键字段）

updateByBusinessUk

@Transactional
public void updateByBusinessUk(String tableName,
                                              com.alibaba.fastjson.JSONObject paramJson,
                                              DbUpdateEnum dBUpdateEnum)

更新-By业务键

根据表中业务键进行更新

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

paramJson - 更新所用到的参数（包含业务键字段）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateByBusinessUk

@Transactional
public void updateByBusinessUk(String tableName,
                                              com.alibaba.fastjson.JSONObject[] paramJsons,
                                              DbUpdateEnum dBUpdateEnum)

批量更新-By业务键

根据表中业务键进行批量更新

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

paramJsons - 更新所用到的参数数组（包含业务键字段）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateByBusinessUkNotParamFormat

@Transactional
public void updateByBusinessUkNotParamFormat(String tableName,
                                                            com.alibaba.fastjson.JSONObject[] paramJsons,
                                                            DbUpdateEnum dBUpdateEnum)

批量更新-By业务键（不调用 DbBase.paramFormat(JSONObject) 方法）

根据表中业务键进行批量更新

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

paramJsons - 更新所用到的参数数组（包含业务键字段）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateSort

@Transactional
public void updateSort(String tableName,
                                      Long id,
                                      Integer move,
                                      @Nullable
                                      String... uniqueKeys)

更新-排序
使用限制：见 DbInsert.insertWithSortIdxAutoIncrement(String, JSONObject, String...)

Parameters:

tableName - 表名

id - 主键ID

move - sort_idx移动位数（值不可等于零，正整数表示：向后移动几位，负整数表示：向前移动几位）

uniqueKeys - 同sort_idx字段组合的唯一约束keys（表中不建议建立sort_idx字段的唯一约束，但可以建立普通索引，以便于提高查询性能），可选参数

updateBatch

public void updateBatch(String tableName,
                        com.alibaba.fastjson.JSONObject[] paramJsons,
                        String[] conditions,
                        DbUpdateEnum dBUpdateEnum)

更新-批量

一组条件对应一条数据，并且每组条件都采用相同的key

Parameters:

tableName - 表名

paramJsons - 更新所用到的参数数组

conditions - 作为更新条件的参数名，对应paramJson内的key（注意：作为条件的参数，将不会用于字段值的更新）

dBUpdateEnum - 更新类型 DbUpdateEnum

updateBatchNotParamFormat

@Transactional(rollbackFor={java.lang.RuntimeException.class,java.lang.Error.class})
public void updateBatchNotParamFormat(String tableName,
                                                                                                                           com.alibaba.fastjson.JSONObject[] paramJsons,
                                                                                                                           String[] conditions,
                                                                                                                           DbUpdateEnum dBUpdateEnum)

更新-批量（不调用 DbBase.paramFormat(JSONObject) 方法）

一组条件对应一条数据，并且每组条件都采用相同的key

Parameters:

tableName - 表名

paramJsons - 更新所用到的参数数组

conditions - 作为更新条件的参数名，对应paramJson内的key（注意：作为条件的参数，将不会用于字段值的更新）

dBUpdateEnum - 更新类型 DbUpdateEnum

queryObject

@Deprecated
public <T> T queryObject(String sql,
                                     com.alibaba.fastjson.JSONObject paramJson,
                                     Class<T> mappedClass)

Deprecated. 请使用：DbBase.queryForObject(String, JSONObject, Class)

同 NamedParameterJdbcTemplate.queryForObject(String, Map, Class)

指定SQL语句以创建预编译执行SQL和绑定查询参数，结果映射应该是一个单行查询否则结果为null。

Parameters:

sql - 要执行的SQL查询

paramJson - 要绑定到查询的参数映射

mappedClass - 结果对象期望匹配的普通类型

Returns:

所需普通类型的结果对象（如：Long, String, Boolean）或null

isDataSize

@Deprecated
public boolean isDataSize(String tableName,
                                      com.alibaba.fastjson.JSONObject paramJson)

Deprecated. 请使用：isExistData(String, JSONObject)

是否有数据

Parameters:

tableName - 表名

paramJson - 查询参数

Returns:

是否有数据

isExistData

public boolean isExistData(String tableName,
                           com.alibaba.fastjson.JSONObject paramJson)

是否有数据

Parameters:

tableName - 表名

paramJson - 查询参数

Returns:

是否有数据

getMetaData

public org.springframework.jdbc.support.rowset.SqlRowSetMetaData getMetaData(String tableName)

获得表的元数据

检索元数据，即此行集合的列的数字、类型和属性。

Parameters:

tableName - 表名

Returns:

Spring的SqlRowSet的元数据接口

getCount

public long getCount(String tableName)

获得总数

Parameters:

tableName - 表名

Returns:

总数

getById

public com.alibaba.fastjson.JSONObject getById(String tableName,
                                               long id)

单个-ById

字段名=id，一般为表自增ID-主键

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 getByBusinessUk(String, String)

Parameters:

tableName - 表名

id - 主键ID

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

getById

public <T> T getById(String tableName,
                     Long id,
                     Class<T> mappedClass)

单个-ById

字段名=id，一般为表自增ID-主键

依赖于接口传入 参数时慎用此方法，避免有序主键被遍历风险，造成数据越权行为。推荐使用 getByBusinessUk(String, String, Class)

Parameters:

tableName - 表名

id - 主键ID

mappedClass - 查询结果映射类型，支持JavaBean与简单类型（如：Long, String, Boolean）

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

getByBusinessUk

public com.alibaba.fastjson.JSONObject getByBusinessUk(String tableName,
                                                       String businessUkValue)

单个-By业务键

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

businessUkValue - 业务键的唯一值

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

getByBusinessUk

public <T> T getByBusinessUk(String tableName,
                             String businessUkValue,
                             Class<T> mappedClass)

单个-By业务键

默认业务键为key

业务键值推荐使用UUID5

Parameters:

tableName - 表名

businessUkValue - 业务键的唯一值

mappedClass - 查询结果映射类型，支持JavaBean与简单类型（如：Long, String, Boolean）

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

get

public com.alibaba.fastjson.JSONObject get(String tableName,
                                           com.alibaba.fastjson.JSONObject paramJson)

单个-绝对条件查询

Parameters:

tableName - 表名

paramJson - 查询参数

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

get

public <T> T get(String tableName,
                 com.alibaba.fastjson.JSONObject paramJson,
                 Class<T> mappedClass)

单个-绝对条件查询

Parameters:

tableName - 表名

paramJson - 查询参数

mappedClass - 查询结果映射类型，支持JavaBean与简单类型（如：Long, String, Boolean）

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

list

public List<com.alibaba.fastjson.JSONObject> list(String tableName,
                                                  com.alibaba.fastjson.JSONObject paramJson)

列表-绝对条件查询

Parameters:

tableName - 表名

paramJson - 查询参数

Returns:

列表数据

list

public <T> List<T> list(String tableName,
                        com.alibaba.fastjson.JSONObject paramJson,
                        Class<T> mappedClass)

列表-绝对条件查询

Type Parameters:

T - 泛型

Parameters:

tableName - 表名

paramJson - 查询参数

mappedClass - 映射类

Returns:

列表数据

list

public List<com.alibaba.fastjson.JSONObject> list(String tableName,
                                                  com.alibaba.fastjson.JSONObject paramJson,
                                                  SortEnum sortEnum)

列表-绝对条件查询

Parameters:

tableName - 表名

paramJson - 查询参数

sortEnum - 排序方式

Returns:

列表数据

list

public <T> List<T> list(String tableName,
                        com.alibaba.fastjson.JSONObject paramJson,
                        SortEnum sortEnum,
                        Class<T> mappedClass)

列表-绝对条件查询

Type Parameters:

T - 泛型

Parameters:

tableName - 表名

paramJson - 查询参数

sortEnum - 排序方式

mappedClass - 映射类

Returns:

列表数据

listAll

public List<com.alibaba.fastjson.JSONObject> listAll(String tableName)

列表-查询表中所有数据

Parameters:

tableName - 表名

Returns:

列表数据

listAll

public <T> List<T> listAll(String tableName,
                           Class<T> mappedClass)

列表-查询表中所有数据

Type Parameters:

T - 泛型

Parameters:

tableName - 表名

mappedClass - 映射类

Returns:

列表数据

page

public PageVO<com.alibaba.fastjson.JSONObject> page(String tableName,
                                                    PageIPO pageIPO)

单表分页查询

阿里最优SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT 100000,20 ) b where a.id=b.id

Parameters:

tableName - 表名

pageIPO - 分页查询参数 PageIPO，所有的条件参数，都将以等于的形式进行SQL拼接

Returns:

count（总数），data（分页列表数据）

page

public <T> PageVO<T> page(String tableName,
                          PageIPO pageIPO,
                          Class<T> mappedClass)

单表分页查询

阿里最优SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT 100000,20 ) b where a.id=b.id

Type Parameters:

T - 泛型

Parameters:

tableName - 表名

pageIPO - 分页查询参数 PageIPO，所有的条件参数，都将以等于的形式进行SQL拼接

mappedClass - 映射类

Returns:

count（总数），data（分页列表数据）

page

public PageVO<com.alibaba.fastjson.JSONObject> page(String tableName,
                                                    PageIPO pageIPO,
                                                    SortEnum sortEnum)

单表分页查询

阿里最优SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 ORDER BY id LIMIT 100000,20 ) b where a.id=b.id

Parameters:

tableName - 表名

pageIPO - 分页查询参数 PageIPO，所有的条件参数，都将以等于的形式进行SQL拼接

sortEnum - 排序方式 SortEnum

Returns:

count（总数），data（分页列表数据）

page

public <T> PageVO<T> page(String tableName,
                          PageIPO pageIPO,
                          SortEnum sortEnum,
                          Class<T> mappedClass)

单表分页查询

阿里最优SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 ORDER BY id LIMIT 100000,20 ) b where a.id=b.id

Type Parameters:

T - 泛型

Parameters:

tableName - 表名

pageIPO - 分页查询参数 PageIPO，所有的条件参数，都将以等于的形式进行SQL拼接

sortEnum - 排序方式 SortEnum

mappedClass - 映射类

Returns:

count（总数），data（分页列表数据）

pageWhere

public PageVO<com.alibaba.fastjson.JSONObject> pageWhere(String tableName,
                                                         String whereSql,
                                                         PageIPO pageIPO)

单表分页查询

阿里最优SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT 100000,20 ) b where a.id=b.id

Parameters:

tableName - 表名

whereSql - 自定义WHERE语句，若此参数为空，那么所有的条件参数，都将以等于的形式进行SQL拼接。
SQL示例： WHERE 条件

pageIPO - 分页查询参数 PageIPO

Returns:

count（总数），data（分页列表数据）

pageWhere

public <T> PageVO<T> pageWhere(String tableName,
                               String whereSql,
                               PageIPO pageIPO,
                               Class<T> mappedClass)

单表分页查询

阿里最优SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT 100000,20 ) b where a.id=b.id

Type Parameters:

T - 泛型

Parameters:

tableName - 表名

whereSql - 自定义WHERE语句，若此参数为空，那么所有的条件参数，都将以等于的形式进行SQL拼接。
SQL示例： WHERE 条件

pageIPO - 分页查询参数 PageIPO

mappedClass - 映射类

Returns:

count（总数），data（分页列表数据）

pageSql

public PageVO<com.alibaba.fastjson.JSONObject> pageSql(String querySql,
                                                       PageIPO pageIPO)

复杂SQL分页查询

阿里最优查询SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT :page, :limit) b where a.id=b.id

Parameters:

querySql - 用于查询数据的sql语句

pageIPO - 分页查询参数 PageIPO

Returns:

count（总数），data（分页列表数据）

pageSql

public <T> PageVO<T> pageSql(String querySql,
                             PageIPO pageIPO,
                             Class<T> mappedClass)

复杂SQL分页查询

阿里最优查询SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT :page, :limit) b where a.id=b.id

Type Parameters:

T - 泛型

Parameters:

querySql - 用于查询数据的sql语句

pageIPO - 分页查询参数 PageIPO

mappedClass - 映射类

Returns:

count（总数），data（分页列表数据）

pageSql

public PageVO<com.alibaba.fastjson.JSONObject> pageSql(@Nullable
                                                       String countSql,
                                                       String querySql,
                                                       PageIPO pageIPO)

复杂SQL分页查询

统计SQL示例：

SELECT count(*) count FROM 表1 a, (select id from 表1 where 条件) b where a.id=b.id

阿里最优查询SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT :page, :limit) b where a.id=b.id

Parameters:

countSql - 用于统计总数的sql语句 （注意：count(*)必须拥有count别名） 同时countSql可以为null表示不统计 可选参数

querySql - 用于查询数据的sql语句

pageIPO - 分页查询参数 PageIPO

Returns:

count（总数），data（分页列表数据）

pageSql

public <T> PageVO<T> pageSql(@Nullable
                             String countSql,
                             String querySql,
                             PageIPO pageIPO,
                             Class<T> mappedClass)

复杂SQL分页查询

统计SQL示例：

SELECT count(*) count FROM 表1 a, (select id from 表1 where 条件) b where a.id=b.id

阿里最优查询SQL示例：

SELECT a.* FROM 表1 a, (select id from 表1 where 条件 LIMIT :page, :limit) b where a.id=b.id

Type Parameters:

T - 泛型

Parameters:

countSql - 用于统计总数的sql语句 （注意：count(*)必须拥有count别名） 同时countSql可以为null表示不统计 可选参数

querySql - 用于查询数据的sql语句

pageIPO - 分页查询参数 PageIPO

mappedClass - 映射类

Returns:

count（总数），data（分页列表数据）

pageBeforeAndAfter

public PageBeforeAndAfterVO pageBeforeAndAfter(String querySql,
                                               PageIPO pageIPO,
                                               Long equalsId)

根据相同的列表条件，获得上一条与下一条数据

Parameters:

querySql - 用于查询数据的sql语句

pageIPO - 分页查询参数 PageIPO

equalsId - 做比较的条件ID（将与查询结果的主键ID做比较）

Returns:

PageBeforeAndAfterVO

jdbcQueryForList

public List<com.alibaba.fastjson.JSONObject> jdbcQueryForList(String sql,
                                                              @Nullable
                                                              Object... args)

查询多行数据

同 JdbcTemplate.queryForList(String, Object...)

执行以 '?' 作为参数占位符的SQL语句进行列表查询

Parameters:

sql - SQL语句中可以包含一个或多个 '?' 参数占位符

args - 查询参数，有序的对应SQL语句中的 '?' 参数占位符

Returns:

多行查询结果

jdbcQueryForList

public <T> List<T> jdbcQueryForList(String sql,
                                    Class<T> mappedClass,
                                    @Nullable
                                    Object... args)

查询多行数据

对 JdbcTemplate.queryForList(String, Class, Object...) 方法的优化实现

执行以 '?' 作为参数占位符的SQL语句进行列表查询

Parameters:

sql - SQL语句中可以包含一个或多个 '?' 参数占位符

mappedClass - 查询结果映射类型，支持JavaBean与简单类型（如：Long, String, Boolean）

args - 查询参数，有序的对应SQL语句中的 '?' 参数占位符

Returns:

多行查询结果

jdbcQueryForJson

public com.alibaba.fastjson.JSONObject jdbcQueryForJson(String sql,
                                                        @Nullable
                                                        Object... args)

查询一行数据

对 JdbcTemplate.queryForMap(String, Object...) 方法的优化实现

执行以 '?' 作为参数占位符的SQL语句进行单行查询

Parameters:

sql - SQL语句中可以包含一个或多个 '?' 参数占位符

args - 查询参数，有序的对应SQL语句中的 '?' 参数占位符

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

jdbcQueryForObj

public <T> T jdbcQueryForObj(String sql,
                             Class<T> mappedClass,
                             @Nullable
                             Object... args)

查询一行数据

对 JdbcTemplate.queryForObject(String, Class, Object...) 方法的优化实现

执行以 '?' 作为参数占位符的SQL语句进行单行查询

Parameters:

sql - SQL语句中可以包含一个或多个 '?' 参数占位符

mappedClass - 查询结果映射类型，支持JavaBean与简单类型（如：Long, String, Boolean）

args - 查询参数，有序的对应SQL语句中的 '?' 参数占位符

Returns:

可以是一个正确的单行查询结果、或null、或查询结果是多条数据而引发的预期错误异常

jdbcQueryStr

public String jdbcQueryStr(String sql,
                           @Nullable
                           Object... args)

jdbcQueryInt

public Integer jdbcQueryInt(String sql,
                            @Nullable
                            Object... args)

jdbcQueryLong

public Long jdbcQueryLong(String sql,
                          @Nullable
                          Object... args)

jdbcQueryDouble

public Double jdbcQueryDouble(String sql,
                              @Nullable
                              Object... args)

jdbcQueryBigDecimal

public BigDecimal jdbcQueryBigDecimal(String sql,
                                      @Nullable
                                      Object... args)

jdbcQueryNumber

public Number jdbcQueryNumber(String sql,
                              @Nullable
                              Object... args)

jdbcQueryBoolean

public Boolean jdbcQueryBoolean(String sql,
                                @Nullable
                                Object... args)

jdbcQueryDate

public Date jdbcQueryDate(String sql,
                          @Nullable
                          Object... args)

jdbcQueryLocalDate

public LocalDate jdbcQueryLocalDate(String sql,
                                    @Nullable
                                    Object... args)

jdbcQueryLocalDateTime

public LocalDateTime jdbcQueryLocalDateTime(String sql,
                                            @Nullable
                                            Object... args)