程序包 com.sh.javax

类 ESDataCenter

java.lang.Object

com.sh.javax.DataCenterBase

com.sh.javax.ESDataCenter

所有已实现的接口:

DataCenter

public class ESDataCenter
extends DataCenterBase

Description: Elasticserach操作

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2018年7月19日

字段概要

从类继承的字段 com.sh.javax.DataCenterBase

_lastColType, _lastException, _lastObj, _lastRowCount, _lastSql, autoGeneratedKey, batchMap, checkTimer, checkTimerInstance, con, CONFIG_CONN, connectStartTime, eventRet, executeAutoGeneratedKeys, executeLen, External, External_CONN, isExcute, isUpdateSilence, lastExecuteTime, LOCAL_CONN, log4j, POOL_CONN, queryTimeout, SH_BASIC_POOL, SH_DRUID, SH_POOL, STRUTS_POOL, TOMCAT_POOL, UNDEFINE, WEBLOGIC_POOL, writeLogFlag

从接口继承的字段 com.sh.javax.DataCenter

KEY_External_ExDataCenter, KEY_External_MainDataCenter, KEY_External_ReportDataCenter, PROC_PARAM_TYPE_IN, PROC_PARAM_TYPE_OUT, PROC_PARAM_TYPE_OUT_CURSOR, QUERY_TIMEOUT_FOREVER

构造器概要

构造器

构造器	说明
ESDataCenter()

方法概要

修饰符和类型	方法	说明
String[]	addBatch(String key, Object[] obj)	添加批量操作
String[]	addObject(Object obj, boolean commit)	添加表数据
String[]	addObject(Object obj, boolean commit, boolean showSql)	添加表数据
String[]	beginBatchUpdateByParams(String sql, String[] colsType)	开始进行批量更新,必需与endBatchUpdateByParams一一配对使用
String[]	beginBatchUpdateByParams(String sql, String[] colsType, int refreshCount)	开始进行批量更新,必需与endBatchUpdateByParams一一配对使用
void	commit()	提交事务
Connection	connect()	连接默认数据库
Connection	connect(String sector)	连接配置文件中指定的段,这个只对connType=config有效
void	disconnect()	断开默认的数据库连接
void	disconnect(Connection con)	断开指定的连接
String	getCacheDcType()	获取缓存使用的连接类型
String	getDBType()	获取当前连接的数据类型
String	getDriverName()
String	getJDBCPassword()
String	getJDBCUrl()
String	getJDBCUserId()
Connection	getNewConnection()	获取新的连接，不从连接池中取,一般不允许使用
boolean	isExDataCenter()	是否主数据库连接
boolean	isMainDataCenter()	是否主数据库连接
boolean	isReportDataCenter()	是否主数据库连接
String[]	replaceObject(Object obj, boolean commit, boolean showSql)	添加或修改表数据，只有mysql支持
Datastore	retrieve(String sql)	从默认的数据库中获取数据
Datastore	retrieve(String sql, boolean cacheFlag)	从默认的数据库中获取数据
Datastore	retrieve(Connection con, String sql)	从指定的数据中检索数据
Datastore	retrieve(Connection con, String sql, boolean cacheFlag)	从指定的数据库中检索数据
Datastore	retrieveByParams(String sql, Object[] obj)	带参数查询数据集
Datastore	retrieveByParams(String sql, Object[] obj, boolean cacheFlag)	带参数查询数据集
Datastore	retrieveByParams(String sql, String[] colsType, Object[] obj)	带参数查询数据集
Datastore	retrieveByParams(String sql, String[] colsType, Object[] obj, boolean cacheFlag)	带参数查询数据集
Datastore	retrieveByStoreProc(String procName)	通过存储过程的方式检索数据
Datastore	retrieveByStoreProc(String procName, String[] colsType, Object[] obj)	通过存储过程的方式检索数据
List<Datastore>	retrieveListByStoreProc(String procName, String[] colsType, Object[] obj, int[] paramType)	通过存储过程的方式检索数据,能返回多个游标
Object	retrieveObj(String sql, Class queryObj)	通过对象查找
Object	retrieveObj(String sql, Class queryObj, boolean cacheFlag)	通过对象查找
Object	retrieveObjByParams(String sql, Object[] colsValue, Class queryObj)	查询对象
Object	retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj)	查询对象
Object	retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag)	查询对象
List	retrieveObjList(String sql, Class queryObj)	不带参数的多数据集查询,不带缓存
List	retrieveObjList(String sql, Class queryObj, boolean cacheFlag)	不带参数的多数据集查询
List	retrieveObjList(String sql, Object[] colsValue, Class queryObj)	查询多个对象的列表数据
List	retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj)	查询多个对象的列表数据
List	retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag)	查询多个对象的列表数据
void	rollback()	事务回滚
void	setAutoCommit(boolean commit)	设置DataCenter是否自动提交
void	setConfig(String JDBCDriver, String JDBCConnectionURL, String userID, String password)	设置数据连接属性
void	setConfig(String JDBCDriver, String JDBCConnectionURL, String userID, String password, int maxActive, int maxIdle, int maxWait)	设置数据连接属性
String[]	update(String sql)	执行SQL并按默认方式处理事务
String[]	update(String sql, boolean commit)	修改默认的数据库中的数据
String[]	update(Connection con, String sql, boolean commit)	修改指定的数据库中的数据
String[]	updateByParams(String sql, Object[] obj)	用参数的方式更新数据库
String[]	updateByParams(String sql, Object[] obj, boolean commit)	用参数的方式更新数据库
String[]	updateByParams(String sql, String[] colsType, Object[] obj)	用参数的方式更新数据库
String[]	updateByParams(String sql, String[] colsType, Object[][] obj, boolean commit)	用参数的方式更新数据库
String[]	updateByParams(String sql, String[] colsType, Object[] obj, boolean commit)	用参数的方式更新数据库
String[]	updateByParams(String sql, String[] colsType, Object[] obj, int start, int end, boolean commit)	用参数的方式更新数据库
String[]	updateByStoreProc(String procName)
String[]	updateByStoreProc(String procName, String[] colsType, Object[] obj)	通过存储过程的方式修改数据
String[]	updateByStoreProc(String procName, String[] colsType, Object[][] obj, boolean commit)	通过存储过程的方式修改数据
String[]	updateByStoreProc(String procName, String[] colsType, Object[][] obj, int start, int end, boolean commit)	通过存储过程的方式修改数据
String[]	updateByStoreProc(String procName, String[] colsType, Object[] obj, boolean commit)	通过存储过程的方式修改数据
String[]	updateByStoreProc(String procName, String[] colsType, Object[] obj, int[] paramType)	通过存储过程的方式修改数据
String[]	updateByStoreProc(String procName, String[] colsType, Object[] obj, int start, int end, boolean commit)	通过存储过程的方式修改数据
String[]	updateObject(Object obj, boolean commit)	更新表数据
String[]	updateObject(Object obj, boolean commit, boolean showSql)	更新表数据

从类继承的方法 com.sh.javax.DataCenterBase

_printLog, _printParamLog, beginBatchUpdateByParams, beginStatement, checkAndInitCache, checkErrorMsg, checkRetrieveWatcher, checkValidAndReset, close, closeCache, closeStatement, convertClobString, convertGetPropType, convertPwd, convertRsToDs, convertRsToDs, convertSetPropType, createColsTypeByValue, createQueryBuilder, createSelectBuilder, createSql, createUpdateBuilder, endBatchUpdateByParams, endBatchUpdateByParams, finishStatement, getAllField, getAutoGeneratedKey, getAutoGeneratedKey2, getAutoGeneratedKeyStr, getBatchUpdate, getCacheDs, getClassInfo, getConnection, getConnectStartTime, getDcType, getDsCacheRedis, getErrorMsg, getExecutionLen, getIdleTime, getLastException, getLastExecuteSql, getLastRowCount, getObjectByColumnType, getObjectValue, getParam, getQueryTimeout, getWriteEnable, hasConnected, initExternalDataSource, initExternalDataSource, isClosed, isContainCascade, isContainStr, isExecute, isSupportResultSetTypeScrollInsensitive, isTooLongIdle, isUpdateSilence, isValid, isValid, loadConfig, loadConfig, printGetConnectLog, printLog, printLog, printLog, printLog, processKey, putCacheDs, refreshBatchUpdate, replaceObject, retrieveByParams2, retrieveByParams2, retrieveByParams2, retrieveByParams2, retrieveObjByParams2, setAutoGetGeneratedKey, setCheckTimerSchedule, setCheckTimerSchedule, setCheckTimerSchedule, setConnection, setConnectState, setExtProperty, setGeneratedKeys, setInitClassInfo, setJDBCParam, setParam, setParams, setParams, setProcParams, setQueryTimeout, setUpdateSilence, setWriteEnable, toConnectBase, toDisconnectBase, updateByParams2, watcherRetrieveFinish, writeDetail, writeDetailByParam, writeExeDetail, writeExeDetail, writeExeDetail

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

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

构造器详细资料

ESDataCenter

public ESDataCenter()

方法详细资料

getDriverName

public String getDriverName()

getJDBCUrl

public String getJDBCUrl()

getJDBCUserId

public String getJDBCUserId()

getJDBCPassword

public String getJDBCPassword()

getDBType

public String getDBType()

从接口复制的说明: DataCenter

获取当前连接的数据类型

返回:

String

getCacheDcType

public String getCacheDcType()

从接口复制的说明: DataCenter

获取缓存使用的连接类型

返回:

String

isMainDataCenter

public boolean isMainDataCenter()

从接口复制的说明: DataCenter

是否主数据库连接

返回:

boolean

isReportDataCenter

public boolean isReportDataCenter()

从接口复制的说明: DataCenter

是否主数据库连接

返回:

boolean

isExDataCenter

public boolean isExDataCenter()

从接口复制的说明: DataCenter

是否主数据库连接

返回:

boolean

connect

public Connection connect()

从接口复制的说明: DataCenter

连接默认数据库

返回:

数据库连接

connect

public Connection connect(String sector)

从接口复制的说明: DataCenter

连接配置文件中指定的段,这个只对connType=config有效

参数:

sector - 段名称

返回:

数据库连接

getNewConnection

public Connection getNewConnection()

从接口复制的说明: DataCenter

获取新的连接，不从连接池中取,一般不允许使用

返回:

连接对象

setConfig

public void setConfig(String JDBCDriver,
 String JDBCConnectionURL,
 String userID,
 String password)

从接口复制的说明: DataCenter

设置数据连接属性

参数:

JDBCDriver - JDBC驱动

JDBCConnectionURL - 连接URL

userID - 用户名

password - 密码

setConfig

public void setConfig(String JDBCDriver,
 String JDBCConnectionURL,
 String userID,
 String password,
 int maxActive,
 int maxIdle,
 int maxWait)

从接口复制的说明: DataCenter

设置数据连接属性

参数:

JDBCDriver - JDBC驱动

JDBCConnectionURL - 连接URL

userID - 用户名

password - 密码

maxActive - 最大活动数

maxIdle - 最大空闲数

maxWait - 最大等待时长

disconnect

public void disconnect(Connection con)

从接口复制的说明: DataCenter

断开指定的连接

参数:

con - 数据库连接

disconnect

public void disconnect()

从接口复制的说明: DataCenter

断开默认的数据库连接

retrieve

public Datastore retrieve(Connection con,
 String sql)

从接口复制的说明: DataCenter

从指定的数据中检索数据

参数:

con - 数据库连接

sql - 查询语句

返回:

Datastore数据集

retrieve

public Datastore retrieve(Connection con,
 String sql,
 boolean cacheFlag)

从接口复制的说明: DataCenter

从指定的数据库中检索数据

参数:

con - 数据库连接

sql - 查询语句

cacheFlag - true使用缓存，false 不使用缓存

返回:

Datastore数据集

retrieve

public Datastore retrieve(String sql)

从接口复制的说明: DataCenter

从默认的数据库中获取数据

参数:

sql - 查询SQL

返回:

查询结果集

retrieve

public Datastore retrieve(String sql,
 boolean cacheFlag)

从接口复制的说明: DataCenter

从默认的数据库中获取数据

参数:

sql - 查询SQL

cacheFlag - 是否使用缓存 true|false

返回:

查询结果集

retrieveObj

public Object retrieveObj(String sql,
 Class queryObj)

从接口复制的说明: DataCenter

通过对象查找

参数:

sql - 查询SQL

queryObj - 查询对象

返回:

queryObj对应的实例

retrieveObj

public Object retrieveObj(String sql,
 Class queryObj,
 boolean cacheFlag)

从接口复制的说明: DataCenter

通过对象查找

参数:

sql - 查询SQL

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

queryObj对应的实例

retrieveObjByParams

public Object retrieveObjByParams(String sql,
 String[] colsType,
 Object[] colsValue,
 Class queryObj)

从接口复制的说明: DataCenter

查询对象

参数:

sql - SQL语句

colsType - 参数类型

colsValue - 参数值

queryObj - 带注释的PO对象

返回:

查询对象

retrieveObjByParams

public Object retrieveObjByParams(String sql,
 Object[] colsValue,
 Class queryObj)

查询对象

参数:

sql - SQL语句

colsValue - 参数值

queryObj - 带注释的PO对象

返回:

查询对象

抛出:

Exception - 查询异常

retrieveObjByParams

public Object retrieveObjByParams(String sql,
 String[] colsType,
 Object[] colsValue,
 Class queryObj,
 boolean cacheFlag)

从接口复制的说明: DataCenter

查询对象

参数:

sql - SQL语句

colsType - String数据，记录参数对应的类型

colsValue - String数据

queryObj - 带注释的PO对象

cacheFlag - 是否使用缓存

返回:

查询对象

retrieveObjList

public List retrieveObjList(String sql,
 Class queryObj)

从接口复制的说明: DataCenter

不带参数的多数据集查询,不带缓存

参数:

sql - 查询SQL

queryObj - 查询对象

返回:

queryObj对应的实例集

retrieveObjList

public List retrieveObjList(String sql,
 Class queryObj,
 boolean cacheFlag)

从接口复制的说明: DataCenter

不带参数的多数据集查询

参数:

sql - 查询SQL

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

queryObj对应的实例集

retrieveObjList

public List retrieveObjList(String sql,
 String[] colsType,
 Object[] colsValue,
 Class queryObj)

从接口复制的说明: DataCenter

查询多个对象的列表数据

参数:

sql - 查询SQL

colsType - 参数类型

colsValue - 参数值

queryObj - 查询对象

返回:

queryObj对应的实例集

retrieveObjList

public List retrieveObjList(String sql,
 Object[] colsValue,
 Class queryObj)

查询多个对象的列表数据

参数:

sql - 查询SQL

colsValue - 参数值

queryObj - 查询对象

返回:

queryObj对应的实例集

retrieveObjList

public List retrieveObjList(String sql,
 String[] colsType,
 Object[] colsValue,
 Class queryObj,
 boolean cacheFlag)

从接口复制的说明: DataCenter

查询多个对象的列表数据

参数:

sql - 查询SQL

colsType - 参数类型

colsValue - 参数值

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

queryObj对应的List集

retrieveByParams

public Datastore retrieveByParams(String sql,
 String[] colsType,
 Object[] obj,
 boolean cacheFlag)

从接口复制的说明: DataCenter

带参数查询数据集

参数:

sql - 查询SQL

colsType - 参数类型数组

obj - 参数值数组

cacheFlag - 是否使用缓存

返回:

查询数据集

retrieveByParams

public Datastore retrieveByParams(String sql,
 Object[] obj,
 boolean cacheFlag)

带参数查询数据集

参数:

sql - 查询SQL

obj - 参数值数组

cacheFlag - 是否使用缓存

返回:

查询数据集

retrieveByParams

public Datastore retrieveByParams(String sql,
 String[] colsType,
 Object[] obj)

从接口复制的说明: DataCenter

带参数查询数据集

参数:

sql - 查询SQL

colsType - 参数类型数组

obj - 参数值数组

返回:

查询数据集

retrieveByParams

public Datastore retrieveByParams(String sql,
 Object[] obj)

带参数查询数据集

参数:

sql - 查询SQL

obj - 参数值数组

返回:

查询数据集

retrieveByStoreProc

public Datastore retrieveByStoreProc(String procName)

从接口复制的说明: DataCenter

通过存储过程的方式检索数据

参数:

procName - 存储过程名称

返回:

数据集Datastore 注意：目前只支持ORACLE

retrieveByStoreProc

public Datastore retrieveByStoreProc(String procName,
 String[] colsType,
 Object[] obj)

从接口复制的说明: DataCenter

通过存储过程的方式检索数据

参数:

procName - 存储过程名称

colsType - 参数类型数组

obj - 参数值数组，多行数据

返回:

数据集Datastore 注意：目前只支持ORACLE

retrieveListByStoreProc

public List<Datastore> retrieveListByStoreProc(String procName,
 String[] colsType,
 Object[] obj,
 int[] paramType)

从接口复制的说明: DataCenter

通过存储过程的方式检索数据,能返回多个游标

参数:

procName - 存储过程名称,存储过程需要可以任意定义返回游标

colsType - 参数类型数组

obj - 参数值数组，多行数据

paramType - 输入、输出参数类型、DataCenter.PROC_PARAM_TYPE_IN,DataCenter.PROC_PARAM_TYPE_OUT

返回:

多数据集Datastore 注意：目前只支持ORACLE

update

public String[] update(Connection con,
 String sql,
 boolean commit)

从接口复制的说明: DataCenter

修改指定的数据库中的数据

参数:

con - 数据库连接

sql - 更新语句

commit - 是否提交,true提交，false不提交，可手动调用dc.commit()提交或dc.rollback()回滚

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

update

public String[] update(String sql)

从接口复制的说明: DataCenter

执行SQL并按默认方式处理事务

参数:

sql - 修改数据库的语句

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateObject

public String[] updateObject(Object obj,
 boolean commit,
 boolean showSql)

从接口复制的说明: DataCenter

更新表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

showSql - 是否打印出sql 默认为false

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateObject

public String[] updateObject(Object obj,
 boolean commit)

从接口复制的说明: DataCenter

更新表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

addObject

public String[] addObject(Object obj,
 boolean commit,
 boolean showSql)

从接口复制的说明: DataCenter

添加表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

showSql - 是否打印出sql 默认为false

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

replaceObject

public String[] replaceObject(Object obj,
 boolean commit,
 boolean showSql)

从接口复制的说明: DataCenter

添加或修改表数据，只有mysql支持

参数:

obj - 实例对象

commit - 是否自动提交事务

showSql - 是否打印出sql 默认为false

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

addObject

public String[] addObject(Object obj,
 boolean commit)

从接口复制的说明: DataCenter

添加表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

update

public String[] update(String sql,
 boolean commit)

从接口复制的说明: DataCenter

修改默认的数据库中的数据

参数:

sql - 更新语句

commit - 是否提交,true提交，false取消数据更新

返回:

string[0] "true"成功；"false"失败 string[1] 出错信息

updateByParams

public String[] updateByParams(String sql,
 String[] colsType,
 Object[] obj)

从接口复制的说明: DataCenter

用参数的方式更新数据库

参数:

sql - 更改数据库数据的语句

colsType - 参数类型

obj - 参数值数组

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByParams

public String[] updateByParams(String sql,
 Object[] obj)

用参数的方式更新数据库

参数:

sql - 更改数据库数据的语句

obj - 参数值数组

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByParams

public String[] updateByParams(String sql,
 String[] colsType,
 Object[] obj,
 boolean commit)

从接口复制的说明: DataCenter

用参数的方式更新数据库

参数:

sql - 更改数据库数据的语句

colsType - 参数类型

obj - 参数值数组

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByParams

public String[] updateByParams(String sql,
 Object[] obj,
 boolean commit)

用参数的方式更新数据库

参数:

sql - 更改数据库数据的语句

obj - 参数值数组

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByParams

public String[] updateByParams(String sql,
 String[] colsType,
 Object[] obj,
 int start,
 int end,
 boolean commit)

从接口复制的说明: DataCenter

用参数的方式更新数据库

参数:

sql - 更改数据库数据的语句

colsType - 参数类型

obj - 参数值数组

start - 参数起始位置

end - 参数结束位置

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByParams

public String[] updateByParams(String sql,
 String[] colsType,
 Object[][] obj,
 boolean commit)

从接口复制的说明: DataCenter

用参数的方式更新数据库

参数:

sql - 更改数据库数据的语句

colsType - 参数类型

obj - 参数值数组，同时更改多条数据

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByStoreProc

public String[] updateByStoreProc(String procName)

updateByStoreProc

public String[] updateByStoreProc(String procName,
 String[] colsType,
 Object[][] obj,
 int start,
 int end,
 boolean commit)

从接口复制的说明: DataCenter

通过存储过程的方式修改数据

参数:

procName - 存储过程名称

colsType - 参数类型数组

obj - 参数值数组，多行数据

start - 参数起始序号

end - 参数结束序号

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByStoreProc

public String[] updateByStoreProc(String procName,
 String[] colsType,
 Object[] obj)

从接口复制的说明: DataCenter

通过存储过程的方式修改数据

参数:

procName - 存储过程名称

colsType - 参数类型数组

obj - 参数值数组，一行数据

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByStoreProc

public String[] updateByStoreProc(String procName,
 String[] colsType,
 Object[] obj,
 boolean commit)

从接口复制的说明: DataCenter

通过存储过程的方式修改数据

参数:

procName - 存储过程名称

colsType - 参数类型数组

obj - 参数值数组，一行数据

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByStoreProc

public String[] updateByStoreProc(String procName,
 String[] colsType,
 Object[] obj,
 int[] paramType)

从接口复制的说明: DataCenter

通过存储过程的方式修改数据

参数:

procName - 存储过程名称,需要带上参数

colsType - 参数类型数组

obj - 参数值数组，一行数据,如果为OUT型参数，可以为空或null

paramType - 参数类型，DataCenter.PROC_PARAM_TYPE_OUT或DataCenter.PROC_PARAM_TYPE_IN

返回:

{true,ret1,ret2....}为果[0]为true时，后台参数依次返回指定参数类型的OUT的值 Note:要求colsType/obj/paramType三个数组长度一致

updateByStoreProc

public String[] updateByStoreProc(String procName,
 String[] colsType,
 Object[] obj,
 int start,
 int end,
 boolean commit)

从接口复制的说明: DataCenter

通过存储过程的方式修改数据

参数:

procName - 存储过程名称

colsType - 参数类型数组

obj - 参数值数组，一行数据

start - 参数起始序号

end - 参数结束序号

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

updateByStoreProc

public String[] updateByStoreProc(String procName,
 String[] colsType,
 Object[][] obj,
 boolean commit)

从接口复制的说明: DataCenter

通过存储过程的方式修改数据

参数:

procName - 存储过程名称

colsType - 参数类型数组

obj - 参数值数组，多行数据

commit - 是否提交

返回:

string[0] "true"成功；"false"失败 string[1] 影响行数|出错信息

beginBatchUpdateByParams

public String[] beginBatchUpdateByParams(String sql,
 String[] colsType,
 int refreshCount)

从接口复制的说明: DataCenter

开始进行批量更新,必需与endBatchUpdateByParams一一配对使用

参数:

sql - 执行SQL

colsType - SQL参数类型

refreshCount - 批量队列到达该值时自动刷新，0表示取消自动刷新,设置此值后在自动刷新时操作成功会提交事务，即执行commit()方法

返回:

{true|false,操作关键字(后续操作会用到)|错误信息}

beginBatchUpdateByParams

public String[] beginBatchUpdateByParams(String sql,
 String[] colsType)

从接口复制的说明: DataCenter

开始进行批量更新,必需与endBatchUpdateByParams一一配对使用

参数:

sql - 执行SQL

colsType - SQL参数类型

返回:

{true|false,操作关键字(后续操作会用到)|错误信息}

addBatch

public String[] addBatch(String key,
 Object[] obj)

添加批量操作

指定者:

addBatch 在接口中 DataCenter

覆盖:

addBatch 在类中 DataCenterBase

参数:

key - 操作序列号,通过beginBatchUpdateByParams获取

obj - 参数值

返回:

{true|false,|错误信息}

setAutoCommit

public void setAutoCommit(boolean commit)

从接口复制的说明: DataCenter

设置DataCenter是否自动提交

参数:

commit - true自动提交，false手工提交

commit

public void commit()

从接口复制的说明: DataCenter

提交事务

rollback

public void rollback()

从接口复制的说明: DataCenter

事务回滚