com.fr.write.config

类 DMLConfig

java.lang.Object

com.fr.write.config.DMLConfig

所有已实现的接口:

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

直接已知子类:

BatchDMLConfig

public abstract class DMLConfig
extends java.lang.Object
implements XMLable, ColumnRowRelated

数据库操作配置信息

另请参阅:

序列化表格

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	DMLConfig.DMLColumnValues
class	DMLConfig.SimpleDataModel

字段概要

字段

限定符和类型	字段和说明
protected java.util.List<ColumnConfig>	columnConfigList
protected Condition	condition
protected Dialect	dialect
protected Table	evaledTable
static CalculatorKey	KEY
static CalculatorKey	P_TAG
protected java.util.List<NameSubmitJob>	submitJobList
protected Table	table
static java.lang.String	XML_TAG 读写XML的标签

构造器概要

构造器

构造器和说明
DMLConfig() 默认的构造函数

方法概要

方法

限定符和类型	方法和说明
void	addColumnConfig(ColumnConfig columnConfig) 添加一个指定的列操作信息
void	addSubmitJob(NameSubmitJob nameSubmitJob) 添加一个指定的提交事务
void	clearColumnConfigs() 清楚所有的列操作信息
void	clearSubmitJobs() 清除所有的提交事务
java.lang.Object	clone()
protected void	closeStatement(java.sql.Connection conn) 关闭对应conn中的statment
protected java.lang.Exception	dealWithException(java.lang.Exception e) 对异常的一些特殊处理
protected void	dealWithIllegal(java.sql.Connection conn, Calculator ca) 有非法记录的处理逻辑
protected abstract int	dmlSubmit(java.sql.Connection conn, Calculator ca, java.lang.Object[] columnValues, java.util.Map kvMap) 数据和数据库的交互操作
protected abstract int	dmlSubmitBatch(int index, java.sql.Connection conn, Calculator ca, java.lang.Object[] columnValues, java.util.Map kvMap) 批量提交
void	execute(java.sql.Connection conn, Calculator ca) 提交入库,但不需要返回数据库记录的更新
DBFeedback	executeAndFeedback(java.sql.Connection conn, Calculator ca) 计算并返回受影响的数据记录 暂时只处理Insert
DMLConfig.DMLColumnValues[]	extractByValues2Column(java.lang.Object[] values2Column) 从value转化成column值
protected Where	generateWhere(java.sql.Connection conn, java.lang.Object[] columnValues)
ColumnConfig	getColumnConfig(int index) 获取指定索引上的列操作信息
int	getColumnConfigCount() 获取列操作信息的数目
protected java.lang.Object	getColumnDefValue(int columnIndexInSQL)
protected java.lang.String	getColumnName(int columnIndexInSQL)
protected int	getColumnType(java.lang.String columnName, java.sql.Connection conn)
Condition	getCondition() 获取提交事务所提交条件
Dialect	getDialect(java.sql.Connection conn) 获取数据操作对应的数据库方言
Table	getOriTable() 获取需要操作的数据库表，不处理其表名以及表模式中的公式
ColumnRow[]	getRelatedColumnRows() 获取和当前操作相关的所有格子信息组成的数组
ColumnRow[]	getRelatedColumnRows(int idx) 获取和当前操作相关的所有格子信息组成的数组
NameSubmitJob	getSubmitJob(int index) 获取指定索引上的提交事务
int	getSubmitJobCount() 获取提交事务的数目
Table	getTable() 获取需要操作的数据库表，处理其表名以及表模式中的公式
Table	getTable(Calculator ca) 获取经过了公式运算后的表信息
int	getTotalTimes()
protected abstract boolean	isIgnoreUpdate(Calculator ca)
boolean	isUpdateSelected() 值不改变不更新
void	readXML(XMLableReader reader) 读取子节点，应该会被XMLableReader.readXMLObject()调用多次
void	setCondition(Condition c) 设置提交事务田间
void	setDialect(Dialect dialect) 设置提交配置对应的数据库方言
void	setTable(Table table) 设置需要操作的数据库表
void	setTotalTimes(int totalTimes)
void	setUpdateSelected(boolean updateSelected)
java.lang.String	toString() 转化成字符串
void	writeXML(XMLPrintWriter writer) Write XML.

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

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

字段详细资料

KEY

public static final CalculatorKey KEY

P_TAG

public static final CalculatorKey P_TAG

XML_TAG

public static final java.lang.String XML_TAG

读写XML的标签

另请参阅:

常量字段值

table

protected Table table

evaledTable

protected transient Table evaledTable

dialect

protected Dialect dialect

columnConfigList

protected java.util.List<ColumnConfig> columnConfigList

submitJobList

protected java.util.List<NameSubmitJob> submitJobList

condition

protected Condition condition

构造器详细资料

DMLConfig

public DMLConfig()

默认的构造函数

方法详细资料

getTotalTimes

public int getTotalTimes()

setTotalTimes

public void setTotalTimes(int totalTimes)

getDialect

public Dialect getDialect(java.sql.Connection conn)

获取数据操作对应的数据库方言

参数:

conn - 数据库连接

返回:

返回不同数据库的方言

setDialect

public void setDialect(Dialect dialect)

设置提交配置对应的数据库方言

参数:

dialect - 数据库方言

getTable

public Table getTable()

获取需要操作的数据库表，处理其表名以及表模式中的公式

返回:

表

setTable

public void setTable(Table table)

设置需要操作的数据库表

参数:

table - 数据库表

getOriTable

public Table getOriTable()

获取需要操作的数据库表，不处理其表名以及表模式中的公式

返回:

表

getTable

public Table getTable(Calculator ca)

获取经过了公式运算后的表信息

参数:

ca - 算子

返回:

讲表中的模式和名字经过公式计算后的表

addColumnConfig

public void addColumnConfig(ColumnConfig columnConfig)

添加一个指定的列操作信息

参数:

columnConfig - 列操作信息

getColumnConfigCount

public int getColumnConfigCount()

获取列操作信息的数目

getColumnConfig

public ColumnConfig getColumnConfig(int index)

获取指定索引上的列操作信息

参数:

index - 指定的索引

返回:

列操作信息

clearColumnConfigs

public void clearColumnConfigs()

清楚所有的列操作信息

addSubmitJob

public void addSubmitJob(NameSubmitJob nameSubmitJob)

添加一个指定的提交事务

参数:

nameSubmitJob - 带名字的提交事务

getSubmitJobCount

public int getSubmitJobCount()

获取提交事务的数目

getSubmitJob

public NameSubmitJob getSubmitJob(int index)

获取指定索引上的提交事务

参数:

index - 指定的索引

返回:

提交事务

clearSubmitJobs

public void clearSubmitJobs()

清除所有的提交事务

getCondition

public Condition getCondition()

获取提交事务所提交条件

返回:

提交条件

setCondition

public void setCondition(Condition c)

设置提交事务田间

参数:

c - 提交条件

isUpdateSelected

public boolean isUpdateSelected()

值不改变不更新

返回:

值不改变不更新

setUpdateSelected

public void setUpdateSelected(boolean updateSelected)

getRelatedColumnRows

public ColumnRow[] getRelatedColumnRows()

获取和当前操作相关的所有格子信息组成的数组

指定者:

getRelatedColumnRows 在接口中 ColumnRowRelated

返回:

相关数组

getRelatedColumnRows

public ColumnRow[] getRelatedColumnRows(int idx)

获取和当前操作相关的所有格子信息组成的数组

参数:

idx - 单元格组时候取第几组值

返回:

相关数组

execute

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

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

参数:

conn - 数据库连接对象

ca - 算子

抛出:

java.lang.Exception - 异常

executeAndFeedback

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

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

参数:

conn - 数据库连接对象

ca - 算子

返回:

受影响的数据记录

抛出:

java.lang.Exception - 异常

extractByValues2Column

public DMLConfig.DMLColumnValues[] extractByValues2Column(java.lang.Object[] values2Column)
                                                   throws java.lang.CloneNotSupportedException

从value转化成column值

参数:

values2Column - 待转化的value值

返回:

column值

抛出:

java.lang.CloneNotSupportedException

dmlSubmit

protected abstract int dmlSubmit(java.sql.Connection conn,
            Calculator ca,
            java.lang.Object[] columnValues,
            java.util.Map kvMap)
                          throws java.sql.SQLException

数据和数据库的交互操作

参数:

conn - 数据库连接

ca - 算子

columnValues - 要入库的列的值

kvMap - 插入时是否需要以这个Map里的值填充

返回:

返回操作过的数据的条数

抛出:

java.sql.SQLException - 操作过程中出现错误则抛出此异常

dmlSubmitBatch

protected abstract int dmlSubmitBatch(int index,
                 java.sql.Connection conn,
                 Calculator ca,
                 java.lang.Object[] columnValues,
                 java.util.Map kvMap)
                               throws java.sql.SQLException

批量提交

参数:

index - 数据索引

conn - 数据连接

ca - 算子

columnValues - 要入库的列的值

kvMap - 插入时是否需要以这个Map里的值填充

返回:

返回操作过的数据的条数

抛出:

java.sql.SQLException - 操作过程中出现错误则抛出此异常

isIgnoreUpdate

protected abstract boolean isIgnoreUpdate(Calculator ca)

readXML

public void readXML(XMLableReader reader)

从接口复制的说明: XMLReadable

读取子节点，应该会被XMLableReader.readXMLObject()调用多次

指定者:

readXML 在接口中 XMLReadable

参数:

reader - XML读取对象

另请参阅:

XMLableReader

writeXML

public void writeXML(XMLPrintWriter writer)

从接口复制的说明: XMLWriter

Write XML.
The method will be invoked when save data to XML file.
May override the method to save your own data. 从性能上面考虑，大家用writer.print(), 而不是writer.println()

指定者:

writeXML 在接口中 XMLWriter

参数:

writer - XML写入对象

generateWhere

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

getColumnType

protected int getColumnType(java.lang.String columnName,
                java.sql.Connection conn)

closeStatement

protected void closeStatement(java.sql.Connection conn)
                       throws java.sql.SQLException

关闭对应conn中的statment

参数:

conn -

抛出:

java.sql.SQLException

toString

public java.lang.String toString()

转化成字符串

覆盖:

toString 在类中 java.lang.Object

返回:

字符串

clone

public java.lang.Object clone()
                       throws java.lang.CloneNotSupportedException

指定者:

clone 在接口中 FCloneable

覆盖:

clone 在类中 java.lang.Object

返回:

克隆后的对象

抛出:

java.lang.CloneNotSupportedException - 如果克隆失败则抛出此异常

getColumnName

protected java.lang.String getColumnName(int columnIndexInSQL)

getColumnDefValue

protected java.lang.Object getColumnDefValue(int columnIndexInSQL)

dealWithException

protected java.lang.Exception dealWithException(java.lang.Exception e)

对异常的一些特殊处理

参数:

e -

返回:

dealWithIllegal

protected void dealWithIllegal(java.sql.Connection conn,
                   Calculator ca)
                        throws java.sql.SQLException

有非法记录的处理逻辑

抛出:

java.sql.SQLException