程序包 com.sh.wf.module.helper

类 SQLBatchBuilder

java.lang.Object

com.sh.wf.module.helper.SQLBatchBuilder

public class SQLBatchBuilder
extends Object

Description: 批量插入更新工具类

Title:首亨软件 - 聚天平台

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	SQLBatchBuilder.SqlBatchBuilderCol

字段概要

字段

修饰符和类型	字段	说明
static final int	ERROR
static final int	EXISTS
static final int	EXISTS_IGNORE
static final int	INSERT
static final int	INSERT_IGNORE
static final int	INSERT_UPDATE
protected static org.apache.logging.log4j.Logger	log4j
static final int	NOT_EXISTS
static final int	REPLACE
static final int	UPDATE

构造器概要

构造器

构造器	说明
SQLBatchBuilder(DataCenter dc)

方法概要

修饰符和类型	方法	说明
SQLBatchBuilder	addBigIntCol(String colName, Object obj)
SQLBatchBuilder	addCol(String colName, String colType, Object obj)
SQLBatchBuilder	addCol(String colName, String colType, Object obj, boolean isWhereCondition)
SQLBatchBuilder	addCol(String colName, String colType, Object obj, boolean isWhereCondition, boolean isIn)
SQLBatchBuilder	addDoubleCol(String colName, Object obj)
SQLBatchBuilder	addIntegerCol(String colName, Object obj)
SQLBatchBuilder	addObjectCol(String colName, Object obj)
SQLBatchBuilder	addStringCol(String colName, Object obj)
SQLBatchBuilder	addSystemTime(String colName)
SQLBatchBuilder	addTextCol(String colName, Object obj)
SQLBatchBuilder	addTimestampCol(String colName, String time, String format)
SQLBatchBuilder	addTimestampCol(String colName, Timestamp timestamp)
SQLBatchBuilder	addTimestampCol(String colName, LocalDateTime localDateTime)
SQLBatchBuilder	addTimestampCol(String colName, Date date)
SQLBatchBuilder	addTimestampColZone(String colName, String time, String format)
SQLBatchBuilder	addWhereBigIntCol(String colName, Object obj)
SQLBatchBuilder	addWhereBigIntCol_in(String colName, String obj)
SQLBatchBuilder	addWhereCol(String colName, String colType, Object obj)
SQLBatchBuilder	addWhereCol_in(String colName, String colType, String obj)
SQLBatchBuilder	addWhereDoubleCol(String colName, Object obj)
SQLBatchBuilder	addWhereIntegerCol(String colName, Object obj)
SQLBatchBuilder	addWhereIntegerCol_in(String colName, String obj)
SQLBatchBuilder	addWhereObjectCol(String colName, Object obj)
SQLBatchBuilder	addWhereStringCol(String colName, Object obj)
SQLBatchBuilder	addWhereStringCol_in(String colName, String obj)
SQLBatchBuilder	addWhereTextCol(String colName, Object obj)
SQLBatchBuilder	asInsert()
SQLBatchBuilder	asInsertIgnore()
SQLBatchBuilder	asInsertOrUpdate()
SQLBatchBuilder	asUpdate()
void	checkAndRefreshBatch(Duration duration)	手动刷新数据
String[]	endBatch(boolean commit)	结束批量操作
String[]	endBatchRow()	结束一行批量操作
int	getCurRow()
int	getCurRowHasAddCol()
DataCenter	getDc()
int	getInsertRow()
SQLBatchBuilder.SqlBatchBuilderCol	getSqlBatchBuilderCol(String colName, boolean isWhereCondition)	获取列信息
int	getTotalNeedCommitRowCount()	获取已经addBatch,但还没有提交的数量
int	getTotalRow()
int	getUpdateRow()
SQLBatchBuilder	ifExistsQueryFromDBColValue(String... colName)	如果表里的数据已经存在，则从数据库更新非条件列
boolean	isColExists(String colName)	判断列是否存在，包括条件列或更新列
boolean	isDebug()
int	isRecordExists()	判断记录是否存在
boolean	isUpdateColExists(String colName)	判断列是否存在
boolean	isWhereColExists(String colName)	判断条件列是否存在
SQLBatchBuilder	onlyInsert()
SQLBatchBuilder	onlyUpdate()
SQLBatchBuilder	refreshEveryCount(int refreshCount)	设置批量操作每次自动刷新数据量
SQLBatchBuilder	reset()	重置
SQLBatchBuilder	setDebug(boolean flag)
SQLBatchBuilder	setNoChangeIgnore(boolean flag)	数据数据没有改变，则不进行更新，注意，只有asInsertOrUpdate()时有效
SQLBatchBuilder	setTableName(String tableName)	表名
SQLBatchBuilder	startBatchRow()

从类继承的方法 java.lang.Object

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

字段详细资料

log4j

protected static org.apache.logging.log4j.Logger log4j

INSERT

public static final int INSERT

另请参阅:

• 常量字段值

UPDATE

public static final int UPDATE

另请参阅:

• 常量字段值

REPLACE

public static final int REPLACE

另请参阅:

• 常量字段值

INSERT_UPDATE

public static final int INSERT_UPDATE

另请参阅:

• 常量字段值

INSERT_IGNORE

public static final int INSERT_IGNORE

另请参阅:

• 常量字段值

EXISTS

public static final int EXISTS

另请参阅:

• 常量字段值

ERROR

public static final int ERROR

另请参阅:

• 常量字段值

NOT_EXISTS

public static final int NOT_EXISTS

另请参阅:

• 常量字段值

EXISTS_IGNORE

public static final int EXISTS_IGNORE

另请参阅:

• 常量字段值

构造器详细资料

SQLBatchBuilder

public SQLBatchBuilder(DataCenter dc)

方法详细资料

setDebug

public SQLBatchBuilder setDebug(boolean flag)

setTableName

public SQLBatchBuilder setTableName(String tableName)

表名

参数:

tableName -

返回:

refreshEveryCount

public SQLBatchBuilder refreshEveryCount(int refreshCount)

设置批量操作每次自动刷新数据量

参数:

refreshCount -

返回:

asInsert

public SQLBatchBuilder asInsert()

asInsertIgnore

public SQLBatchBuilder asInsertIgnore()

asUpdate

public SQLBatchBuilder asUpdate()

asInsertOrUpdate

public SQLBatchBuilder asInsertOrUpdate()

onlyInsert

public SQLBatchBuilder onlyInsert()

onlyUpdate

public SQLBatchBuilder onlyUpdate()

ifExistsQueryFromDBColValue

public SQLBatchBuilder ifExistsQueryFromDBColValue(String... colName)

如果表里的数据已经存在，则从数据库更新非条件列

参数:

colName -

返回:

setNoChangeIgnore

public SQLBatchBuilder setNoChangeIgnore(boolean flag)

数据数据没有改变，则不进行更新，注意，只有asInsertOrUpdate()时有效

参数:

flag -

返回:

reset

public SQLBatchBuilder reset()

重置

返回:

startBatchRow

public SQLBatchBuilder startBatchRow()

addWhereCol

public SQLBatchBuilder addWhereCol(String colName,
 String colType,
 Object obj)

addWhereCol_in

public SQLBatchBuilder addWhereCol_in(String colName,
 String colType,
 String obj)

addWhereStringCol

public SQLBatchBuilder addWhereStringCol(String colName,
 Object obj)

addWhereStringCol_in

public SQLBatchBuilder addWhereStringCol_in(String colName,
 String obj)

addWhereTextCol

public SQLBatchBuilder addWhereTextCol(String colName,
 Object obj)

addWhereIntegerCol

public SQLBatchBuilder addWhereIntegerCol(String colName,
 Object obj)

addWhereIntegerCol_in

public SQLBatchBuilder addWhereIntegerCol_in(String colName,
 String obj)

addWhereBigIntCol

public SQLBatchBuilder addWhereBigIntCol(String colName,
 Object obj)

addWhereBigIntCol_in

public SQLBatchBuilder addWhereBigIntCol_in(String colName,
 String obj)

addWhereDoubleCol

public SQLBatchBuilder addWhereDoubleCol(String colName,
 Object obj)

addWhereObjectCol

public SQLBatchBuilder addWhereObjectCol(String colName,
 Object obj)

addCol

public SQLBatchBuilder addCol(String colName,
 String colType,
 Object obj)

addStringCol

public SQLBatchBuilder addStringCol(String colName,
 Object obj)

addTextCol

public SQLBatchBuilder addTextCol(String colName,
 Object obj)

addIntegerCol

public SQLBatchBuilder addIntegerCol(String colName,
 Object obj)

addBigIntCol

public SQLBatchBuilder addBigIntCol(String colName,
 Object obj)

addDoubleCol

public SQLBatchBuilder addDoubleCol(String colName,
 Object obj)

addTimestampCol

public SQLBatchBuilder addTimestampCol(String colName,
 String time,
 String format)

addTimestampColZone

public SQLBatchBuilder addTimestampColZone(String colName,
 String time,
 String format)

addTimestampCol

public SQLBatchBuilder addTimestampCol(String colName,
 Timestamp timestamp)

addTimestampCol

public SQLBatchBuilder addTimestampCol(String colName,
 Date date)

addTimestampCol

public SQLBatchBuilder addTimestampCol(String colName,
 LocalDateTime localDateTime)

addObjectCol

public SQLBatchBuilder addObjectCol(String colName,
 Object obj)

addCol

public SQLBatchBuilder addCol(String colName,
 String colType,
 Object obj,
 boolean isWhereCondition)

addSystemTime

public SQLBatchBuilder addSystemTime(String colName)

isColExists

public boolean isColExists(String colName)

判断列是否存在，包括条件列或更新列

参数:

colName - boolean

返回:

boolean

isWhereColExists

public boolean isWhereColExists(String colName)

判断条件列是否存在

参数:

colName - boolean

返回:

boolean

isUpdateColExists

public boolean isUpdateColExists(String colName)

判断列是否存在

参数:

colName - String

返回:

boolean

addCol

public SQLBatchBuilder addCol(String colName,
 String colType,
 Object obj,
 boolean isWhereCondition,
 boolean isIn)

getSqlBatchBuilderCol

public SQLBatchBuilder.SqlBatchBuilderCol getSqlBatchBuilderCol(String colName,
 boolean isWhereCondition)

获取列信息

参数:

colName - String

isWhereCondition - boolean

返回:

SqlBatchBuilderCol

endBatchRow

public String[] endBatchRow()

结束一行批量操作

返回:

String[]

isRecordExists

public int isRecordExists()

判断记录是否存在

返回:

int

checkAndRefreshBatch

public void checkAndRefreshBatch(Duration duration)

手动刷新数据

参数:

duration - 时间

getTotalNeedCommitRowCount

public int getTotalNeedCommitRowCount()

获取已经addBatch,但还没有提交的数量

返回:

endBatch

public String[] endBatch(boolean commit)

结束批量操作

参数:

commit -

返回:

getInsertRow

public int getInsertRow()

getUpdateRow

public int getUpdateRow()

getTotalRow

public int getTotalRow()

getCurRowHasAddCol

public int getCurRowHasAddCol()

isDebug

public boolean isDebug()

getCurRow

public int getCurRow()

getDc

public DataCenter getDc()