com.fr.write.config

类 BatchDMLConfig

java.lang.Object

com.fr.write.config.DMLConfig

com.fr.write.config.BatchDMLConfig

所有已实现的接口:

ColumnRowRelated, FCloneable, XMLable, XMLReadable, XMLWriter, java.io.Serializable, java.lang.Cloneable

直接已知子类:

DeleteConfig, InsertConfig, IntelliDMLConfig, UpdateConfig

public abstract class BatchDMLConfig
extends DMLConfig

Created by loy on 16/8/12.

另请参阅:

序列化表格

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	BatchDMLConfig.BatchDMLColumnValues

从类继承的嵌套类/接口 com.fr.write.config.DMLConfig

DMLConfig.DMLColumnValues, DMLConfig.SimpleDataModel

字段概要

字段

限定符和类型	字段和说明
static int	BATCH_SIZE
static java.lang.String	XML_TAG

从类继承的字段 com.fr.write.config.DMLConfig

columnConfigList, condition, dialect, evaledTable, KEY, P_TAG, submitJobList, table

构造器概要

构造器

构造器和说明
BatchDMLConfig()

方法概要

方法

限定符和类型	方法和说明
protected int	calSuccessCount(int[] result) 计算result数组中大于等于0的个数
protected abstract int	dmlSubmitBatchNew(java.sql.Connection conn, Calculator ca, java.util.List<ColumnValuesEntry> columnValuesList)
void	execute(java.sql.Connection conn, Calculator ca) 提交入库,但不需要返回数据库记录的更新
DBFeedback	executeAndFeedback(java.sql.Connection conn, Calculator ca) 计算并返回受影响的数据记录 暂时只处理Insert
BatchDMLConfig.BatchDMLColumnValues[]	extractByValues2ColumnBatch(java.lang.Object[] values2Column)
protected java.util.Map<java.lang.String,ListMap<java.lang.Integer,ColumnValuesEntry>>	generateColumnValuesEntryMapByWhere(java.sql.Connection conn, java.util.List<ColumnValuesEntry> columnValuesList)
protected Where	generateWhereNew(java.sql.Connection conn, java.lang.Object[] columnValues)
int	getTotalTimes()
void	setColumnConfigList(java.util.List<ColumnConfig> columnConfigList)
void	setSubmitJobList(java.util.List<NameSubmitJob> submitJobList)
void	setTotalTimes(int totalTimes)

从类继承的方法 com.fr.write.config.DMLConfig

addColumnConfig, addSubmitJob, clearColumnConfigs, clearSubmitJobs, clone, closeStatement, dealWithException, dealWithIllegal, dmlSubmit, dmlSubmitBatch, extractByValues2Column, generateWhere, getColumnConfig, getColumnConfigCount, getColumnDefValue, getColumnName, getColumnType, getCondition, getDialect, getOriTable, getRelatedColumnRows, getRelatedColumnRows, getSubmitJob, getSubmitJobCount, getTable, getTable, isIgnoreUpdate, isUpdateSelected, readXML, setCondition, setDialect, setTable, setUpdateSelected, toString, writeXML

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

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

字段详细资料

XML_TAG

public static final java.lang.String XML_TAG

另请参阅:

常量字段值

BATCH_SIZE

public static final int BATCH_SIZE

另请参阅:

常量字段值

构造器详细资料

BatchDMLConfig

public BatchDMLConfig()

方法详细资料

getTotalTimes

public int getTotalTimes()

覆盖:

getTotalTimes 在类中 DMLConfig

setTotalTimes

public void setTotalTimes(int totalTimes)

覆盖:

setTotalTimes 在类中 DMLConfig

setColumnConfigList

public void setColumnConfigList(java.util.List<ColumnConfig> columnConfigList)

setSubmitJobList

public void setSubmitJobList(java.util.List<NameSubmitJob> submitJobList)

dmlSubmitBatchNew

protected abstract int dmlSubmitBatchNew(java.sql.Connection conn,
                    Calculator ca,
                    java.util.List<ColumnValuesEntry> columnValuesList)
                                  throws java.sql.SQLException

抛出:

java.sql.SQLException

execute

public void execute(java.sql.Connection conn,
           Calculator ca)
             throws java.lang.Exception

从类复制的说明: DMLConfig

提交入库,但不需要返回数据库记录的更新

覆盖:

execute 在类中 DMLConfig

参数:

conn - 数据库连接对象

ca - 算子

抛出:

java.lang.Exception - 异常

executeAndFeedback

public DBFeedback executeAndFeedback(java.sql.Connection conn,
                            Calculator ca)
                              throws java.lang.Exception

从类复制的说明: DMLConfig

计算并返回受影响的数据记录 暂时只处理Insert

覆盖:

executeAndFeedback 在类中 DMLConfig

参数:

conn - 数据库连接对象

ca - 算子

返回:

受影响的数据记录

抛出:

java.lang.Exception - 异常

extractByValues2ColumnBatch

public BatchDMLConfig.BatchDMLColumnValues[] extractByValues2ColumnBatch(java.lang.Object[] values2Column)
                                                                  throws java.lang.CloneNotSupportedException

抛出:

java.lang.CloneNotSupportedException

calSuccessCount

protected int calSuccessCount(int[] result)

计算result数组中大于等于0的个数

generateWhereNew

protected Where generateWhereNew(java.sql.Connection conn,
                     java.lang.Object[] columnValues)

generateColumnValuesEntryMapByWhere

protected java.util.Map<java.lang.String,ListMap<java.lang.Integer,ColumnValuesEntry>> generateColumnValuesEntryMapByWhere(java.sql.Connection conn,
                                                                                                               java.util.List<ColumnValuesEntry> columnValuesList)