com.sh.wf.module.helper

类 SQLBatchBuilder

java.lang.Object

com.sh.wf.module.helper.SQLBatchBuilder

public class SQLBatchBuilder
extends java.lang.Object

Description: 批量插入更新工具类

Title:首亨软件 - 聚天平台

版本:

4.0 同一张表时，支持添加或更新操作 使用方式：SQLBatchBuilder batch = new SQLBatchBuilder(dc) ; batch.setTableName("table_xxxx"); while(flag){ batch.startBatchRow().asInsertOrUpdate() ; batch.addStringCol("colName","value") ; batch.endBatchRow(); } String[] updateMsg = batch.endBatch(true) ; 注意：当前版本如果添加或修改时列数不匹配，则无法添加，即支持添加或修改批量入库，但要求对应的列数相同 即：同一张表批量操作时，不管是insert还是update，条件列或更新列一定要一致 如：有添加有修改，则主键列一定要加入到whereCol中，否则就与insert时的列不一致了

作者:

江兴春

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	SQLBatchBuilder.SqlBatchBuilderCol

字段概要

字段

限定符和类型	字段和说明
static int	ERROR
static int	EXISTS
static int	INSERT
static int	INSERT_IGNORE
static int	INSERT_UPDATE
static int	NOT_EXISTS
static int	REPLACE
static int	UPDATE

构造器概要

构造器

构造器和说明
SQLBatchBuilder(DataCenter dc)

方法概要

限定符和类型	方法和说明
SQLBatchBuilder	addBigIntCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addCol(java.lang.String colName, java.lang.String colType, java.lang.Object obj)
SQLBatchBuilder	addCol(java.lang.String colName, java.lang.String colType, java.lang.Object obj, boolean isWhereCondition)
SQLBatchBuilder	addCol(java.lang.String colName, java.lang.String colType, java.lang.Object obj, boolean isWhereCondition, boolean isIn)
SQLBatchBuilder	addDoubleCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addIntegerCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addObjectCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addStringCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addSystemTime(java.lang.String colName)
SQLBatchBuilder	addTextCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addTimestampCol(java.lang.String colName, java.util.Date date)
SQLBatchBuilder	addTimestampCol(java.lang.String colName, java.time.LocalDateTime localDateTime)
SQLBatchBuilder	addTimestampCol(java.lang.String colName, java.lang.String time, java.lang.String format)
SQLBatchBuilder	addTimestampCol(java.lang.String colName, java.sql.Timestamp timestamp)
SQLBatchBuilder	addWhereBigIntCol_in(java.lang.String colName, java.lang.String obj)
SQLBatchBuilder	addWhereBigIntCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addWhereCol_in(java.lang.String colName, java.lang.String colType, java.lang.String obj)
SQLBatchBuilder	addWhereCol(java.lang.String colName, java.lang.String colType, java.lang.Object obj)
SQLBatchBuilder	addWhereDoubleCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addWhereIntegerCol_in(java.lang.String colName, java.lang.String obj)
SQLBatchBuilder	addWhereIntegerCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addWhereObjectCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addWhereStringCol_in(java.lang.String colName, java.lang.String obj)
SQLBatchBuilder	addWhereStringCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	addWhereTextCol(java.lang.String colName, java.lang.Object obj)
SQLBatchBuilder	asInsert()
SQLBatchBuilder	asInsertIgnore()
SQLBatchBuilder	asInsertOrUpdate()
SQLBatchBuilder	asUpdate()
java.lang.String[]	endBatch(boolean commit) 结束批量操作
java.lang.String[]	endBatchRow() 结束一行批量操作
int	getCurRow()
int	getCurRowHasAddCol()
int	getInsertRow()
SQLBatchBuilder.SqlBatchBuilderCol	getSqlBatchBuilderCol(java.lang.String colName, boolean isWhereCondition) 获取列信息
int	getTotalRow()
int	getUpdateRow()
boolean	isColExists(java.lang.String colName) 判断列是否存在，包括条件列或更新列
boolean	isDebug()
int	isRecordExists() 判断记录是否存在
boolean	isUpdateColExists(java.lang.String colName) 判断列是否存在
boolean	isWhereColExists(java.lang.String colName) 判断条件列是否存在
SQLBatchBuilder	onlyInsert()
SQLBatchBuilder	onlyUpdate()
SQLBatchBuilder	refreshEveryCount(int refreshCount) 设置批量操作每次自动刷新数据量
SQLBatchBuilder	reset() 重置
void	setDebug(boolean flag)
SQLBatchBuilder	setTableName(java.lang.String tableName) 表名
SQLBatchBuilder	startBatchRow()

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

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

字段详细资料

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

另请参阅:

常量字段值

构造器详细资料

SQLBatchBuilder

public SQLBatchBuilder(DataCenter dc)

方法详细资料

setDebug

public void setDebug(boolean flag)

setTableName

public SQLBatchBuilder setTableName(java.lang.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()

reset

public SQLBatchBuilder reset()

重置

返回:

startBatchRow

public SQLBatchBuilder startBatchRow()

addWhereCol

public SQLBatchBuilder addWhereCol(java.lang.String colName,
                                   java.lang.String colType,
                                   java.lang.Object obj)

addWhereCol_in

public SQLBatchBuilder addWhereCol_in(java.lang.String colName,
                                      java.lang.String colType,
                                      java.lang.String obj)

addWhereStringCol

public SQLBatchBuilder addWhereStringCol(java.lang.String colName,
                                         java.lang.Object obj)

addWhereStringCol_in

public SQLBatchBuilder addWhereStringCol_in(java.lang.String colName,
                                            java.lang.String obj)

addWhereTextCol

public SQLBatchBuilder addWhereTextCol(java.lang.String colName,
                                       java.lang.Object obj)

addWhereIntegerCol

public SQLBatchBuilder addWhereIntegerCol(java.lang.String colName,
                                          java.lang.Object obj)

addWhereIntegerCol_in

public SQLBatchBuilder addWhereIntegerCol_in(java.lang.String colName,
                                             java.lang.String obj)

addWhereBigIntCol

public SQLBatchBuilder addWhereBigIntCol(java.lang.String colName,
                                         java.lang.Object obj)

addWhereBigIntCol_in

public SQLBatchBuilder addWhereBigIntCol_in(java.lang.String colName,
                                            java.lang.String obj)

addWhereDoubleCol

public SQLBatchBuilder addWhereDoubleCol(java.lang.String colName,
                                         java.lang.Object obj)

addWhereObjectCol

public SQLBatchBuilder addWhereObjectCol(java.lang.String colName,
                                         java.lang.Object obj)

addCol

public SQLBatchBuilder addCol(java.lang.String colName,
                              java.lang.String colType,
                              java.lang.Object obj)

addStringCol

public SQLBatchBuilder addStringCol(java.lang.String colName,
                                    java.lang.Object obj)

addTextCol

public SQLBatchBuilder addTextCol(java.lang.String colName,
                                  java.lang.Object obj)

addIntegerCol

public SQLBatchBuilder addIntegerCol(java.lang.String colName,
                                     java.lang.Object obj)

addBigIntCol

public SQLBatchBuilder addBigIntCol(java.lang.String colName,
                                    java.lang.Object obj)

addDoubleCol

public SQLBatchBuilder addDoubleCol(java.lang.String colName,
                                    java.lang.Object obj)

addTimestampCol

public SQLBatchBuilder addTimestampCol(java.lang.String colName,
                                       java.lang.String time,
                                       java.lang.String format)

addTimestampCol

public SQLBatchBuilder addTimestampCol(java.lang.String colName,
                                       java.sql.Timestamp timestamp)

addTimestampCol

public SQLBatchBuilder addTimestampCol(java.lang.String colName,
                                       java.util.Date date)

addTimestampCol

public SQLBatchBuilder addTimestampCol(java.lang.String colName,
                                       java.time.LocalDateTime localDateTime)

addObjectCol

public SQLBatchBuilder addObjectCol(java.lang.String colName,
                                    java.lang.Object obj)

addCol

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

addSystemTime

public SQLBatchBuilder addSystemTime(java.lang.String colName)

isColExists

public boolean isColExists(java.lang.String colName)

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

参数:

colName - boolean

返回:

boolean

isWhereColExists

public boolean isWhereColExists(java.lang.String colName)

判断条件列是否存在

参数:

colName - boolean

返回:

boolean

isUpdateColExists

public boolean isUpdateColExists(java.lang.String colName)

判断列是否存在

参数:

colName - String

返回:

boolean

addCol

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

getSqlBatchBuilderCol

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

获取列信息

参数:

colName - String

isWhereCondition - boolean

返回:

SqlBatchBuilderCol

endBatchRow

public java.lang.String[] endBatchRow()

结束一行批量操作

返回:

String[]

isRecordExists

public int isRecordExists()

判断记录是否存在

返回:

int

endBatch

public java.lang.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()