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

类 SQLBatchOperatorTask

java.lang.Object

com.sh.wf.module.helper.SQLBatchOperatorTask

所有已实现的接口:

Runnable

@Service
public class SQLBatchOperatorTask
extends Object
implements Runnable

通用定时批量SQL数据入库任务

嵌套类概要

嵌套类

修饰符和类型	类	说明
static class	SQLBatchOperatorTask.SQLBatchOperatorInfo

字段概要

字段

修饰符和类型	字段	说明
protected static ConcurrentHashMap<String,SQLBatchOperatorTask.SQLBatchOperatorInfo>	dataMap
protected Duration	durationTimeout
protected static SQLBatchOperatorTask	instance
static DelayUtil.DelayNotify	notify

构造器概要

构造器

构造器	说明
SQLBatchOperatorTask()

方法概要

修饰符和类型	方法	说明
static void	addRowData(String tableName, SQLBatchOperatorData data)	添加到队列，使用方法如下： SQLBatchOperatorTask.addRowData("tableName", SQLBatchOperatorData.create().asInsert() .addWhereIntegerCol("id", "") .addStringCol("name", "") ); 如果需要在所有添加完成后立即入库，则调用：SQLBatchOperatorTask.finishData(tableName)
static void	finishData(String tableName)	结束数据
SQLBatchOperatorTask.SQLBatchOperatorInfo	getBatchOperatorInfo(String tableName)
Duration	getDurationTimeout()
void	run()
SQLBatchOperatorTask	setDurationTimeout(Duration durationTimeout)

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

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

字段详细资料

dataMap

protected static ConcurrentHashMap<String,SQLBatchOperatorTask.SQLBatchOperatorInfo> dataMap

notify

public static DelayUtil.DelayNotify notify

durationTimeout

protected Duration durationTimeout

instance

protected static SQLBatchOperatorTask instance

构造器详细资料

SQLBatchOperatorTask

public SQLBatchOperatorTask()

方法详细资料

addRowData

public static void addRowData(String tableName,
 SQLBatchOperatorData data)

添加到队列，使用方法如下： SQLBatchOperatorTask.addRowData("tableName", SQLBatchOperatorData.create().asInsert() .addWhereIntegerCol("id", "") .addStringCol("name", "") ); 如果需要在所有添加完成后立即入库，则调用：SQLBatchOperatorTask.finishData(tableName)

finishData

public static void finishData(String tableName)

结束数据

参数:

tableName - 表名

getBatchOperatorInfo

public SQLBatchOperatorTask.SQLBatchOperatorInfo getBatchOperatorInfo(String tableName)

run

public void run()

指定者:

run 在接口中 Runnable

getDurationTimeout

public Duration getDurationTimeout()

setDurationTimeout

public SQLBatchOperatorTask setDurationTimeout(Duration durationTimeout)