com.sh.javax

接口 DataCenter

所有已知实现类:

AutoCloseableExDataCenter, AutoCloseableJDBCDataCenter, AutoCloseableMainDataCenter, AutoCloseableReportDataCenter, DataCenterBase, DecorateDataCenter, ESDataCenter, ExDataCenter, JDBCDataCenter, MainDataCenter, MainSlaveDataCenter, MongoDataCenter, ReportDataCenter, SQueryDataCenter

public interface DataCenter

Description: 数据中心接口 Title:首亨软件 - CRM、TSS、ERP等信息化管理软件

版本:

2.0

作者:

江兴春

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	KEY_External_ExDataCenter
static java.lang.String	KEY_External_MainDataCenter
static java.lang.String	KEY_External_ReportDataCenter
static int	PROC_PARAM_TYPE_IN
static int	PROC_PARAM_TYPE_OUT
static int	PROC_PARAM_TYPE_OUT_CURSOR
static int	QUERY_TIMEOUT_FOREVER

方法概要

限定符和类型	方法和说明
java.lang.String[]	addBatch(java.lang.String key, java.lang.Object[] obj) 添加批量操作
java.lang.String[]	addObject(java.lang.Object obj, boolean commit) 添加表数据
java.lang.String[]	addObject(java.lang.Object obj, boolean commit, boolean showSql) 添加表数据
java.lang.String[]	beginBatchUpdateByParams(java.lang.String sql, java.lang.String[] colsType) 开始进行批量更新,必需与endBatchUpdateByParams一一配对使用
java.lang.String[]	beginBatchUpdateByParams(java.lang.String sql, java.lang.String[] colsType, int refreshCount) 开始进行批量更新,必需与endBatchUpdateByParams一一配对使用
boolean	checkValidAndReset() 检查连接，如果连接无效了，则自动重新连接
void	commit() 提交事务
java.sql.Connection	connect() 连接默认数据库
java.sql.Connection	connect(java.lang.String sector) 已过时。
java.lang.String[]	createColsTypeByValue(java.lang.Object[] value) 通过参数值自动生成参数类型
SqlBuilder	createQueryBuilder() 创建查询的SQL生成工具对象为
SqlUpdateBuilder	createUpdateBuilder() 创建添加、修改、删除的SQL生成工具对象为
void	disconnect() 断开默认的数据库连接
void	disconnect(java.sql.Connection con) 断开指定的连接
java.lang.String[]	endBatchUpdateByParams(java.lang.String key) 结束批量更新操作,执行后如果要重新执行批量更新，则需要再次调用beginBatchUpdateByParams函数
java.lang.String[]	endBatchUpdateByParams(java.lang.String key, boolean commit) 结束批量更新操作,执行后如果要重新执行批量更新，则需要再次调用beginBatchUpdateByParams函数
int	getAutoGeneratedKey() 获取自增长列 在执行查询前，需要做的操作有： setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) int key == getAutoGeneratedKey() ;
java.lang.String	getAutoGeneratedKeyStr() 获取自增长列并转化为String类型 在执行查询前，需要做的操作有： setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) String key == getAutoGeneratedKeyStr() ;
java.lang.String	getCacheDcType() 获取缓存使用的连接类型
java.sql.Connection	getConnection() 获取连接
java.lang.String	getDBType() 获取当前连接的数据类型
java.lang.String	getDriverName()
DSCacheRedis	getDsCacheRedis() 获取redis
long	getExecutionLen() 获取最后一次执行时长
long	getIdleTime() 获取空闲时间
java.lang.String	getJDBCPassword()
java.lang.String	getJDBCUrl()
java.lang.String	getJDBCUserId()
java.lang.Exception	getLastException()
java.lang.String	getLastExecuteSql() 获取最近一次执行的SQL语句
java.sql.Connection	getNewConnection() 获取新的连接，不从连接池中取,一般不允许使用
java.lang.String	getParam(java.lang.String key, java.lang.String defaultValue)
int	getQueryTimeout() 获取查询超时时长
boolean	getWriteEnable() 查询是否在记录DC日志
boolean	hasConnected() 是否已经建立连接
boolean	isClosed() 判断连接是否关闭，只在连接调用close方法后才会返回true
boolean	isExDataCenter() 是否主数据库连接
boolean	isExecute() 就否正在执行SQL
boolean	isMainDataCenter() 是否主数据库连接
boolean	isReportDataCenter() 是否主数据库连接
boolean	isTooLongIdle(long idleTimeout) 判断是否空闲太久
boolean	isValid() 判断连接是否有效
boolean	isValid(int timeout) 判断连接是否有效
java.lang.String	printLog()
java.lang.String	printLog(org.slf4j.Logger log)
java.lang.String	printLog(org.apache.logging.log4j.Logger log4j)
java.lang.String	printLog(org.apache.logging.log4j.Logger log4j, java.lang.String prefix)
java.lang.String[]	refreshBatchUpdate(java.lang.String key) 刷新批量更新,如果批量执行太多时，可以用这个函数来刷新队列，也可以在beginBatchUpdateByParams中设置refreshCount参数
java.lang.String[]	replaceObject(java.lang.Object obj, boolean commit)
java.lang.String[]	replaceObject(java.lang.Object obj, boolean commit, boolean showSql) 添加或修改表数据，只有mysql支持
Datastore	retrieve(java.sql.Connection con, java.lang.String sql) 从指定的数据中检索数据
Datastore	retrieve(java.sql.Connection con, java.lang.String sql, boolean cacheFlag) 从指定的数据库中检索数据
Datastore	retrieve(java.lang.String sql) 从默认的数据库中获取数据
Datastore	retrieve(java.lang.String sql, boolean cacheFlag) 从默认的数据库中获取数据
Datastore	retrieveByParams(java.lang.String sql, java.lang.Object[] obj) 带参数查询数据集
Datastore	retrieveByParams(java.lang.String sql, java.lang.Object[] obj, boolean cacheFlag) 带参数查询数据集
Datastore	retrieveByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj) 带参数查询数据集
Datastore	retrieveByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, boolean cacheFlag) 带参数查询数据集
Datastore	retrieveByParams2(java.lang.String sql, java.util.List<java.lang.Object> objList)
Datastore	retrieveByParams2(java.lang.String sql, java.util.List<java.lang.Object> objList, boolean cacheFlag)
Datastore	retrieveByParams2(java.lang.String sql, java.util.List<java.lang.String> colsTypeList, java.util.List<java.lang.Object> objList) 带参数查询数据集
Datastore	retrieveByParams2(java.lang.String sql, java.util.List<java.lang.String> colsTypeList, java.util.List<java.lang.Object> objList, boolean cacheFlag) 带参数查询数据集
Datastore	retrieveByStoreProc(java.lang.String procName) 通过存储过程的方式检索数据
Datastore	retrieveByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj) 通过存储过程的方式检索数据
java.util.List<Datastore>	retrieveListByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj, int[] paramType) 通过存储过程的方式检索数据,能返回多个游标
java.lang.Object	retrieveObj(java.lang.String sql, java.lang.Class queryObj) 通过对象查找
java.lang.Object	retrieveObj(java.lang.String sql, java.lang.Class queryObj, boolean cacheFlag) 通过对象查找
java.lang.Object	retrieveObjByParams(java.lang.String sql, java.lang.Object[] colsValue, java.lang.Class queryObj) 查询对象
java.lang.Object	retrieveObjByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] colsValue, java.lang.Class queryObj) 查询对象
java.lang.Object	retrieveObjByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] colsValue, java.lang.Class queryObj, boolean cacheFlag) 查询对象
java.lang.Object	retrieveObjByParams2(java.lang.String sql, java.util.List<java.lang.String> colsTypeList, java.util.List<java.lang.Object> colsValueList, java.lang.Class queryObj) 查询对象
java.util.List	retrieveObjList(java.lang.String sql, java.lang.Class queryObj) 不带参数的多数据集查询,不带缓存
java.util.List	retrieveObjList(java.lang.String sql, java.lang.Class queryObj, boolean cacheFlag) 不带参数的多数据集查询
java.util.List	retrieveObjList(java.lang.String sql, java.lang.Object[] colsValue, java.lang.Class queryObj) 查询多个对象的列表数据
java.util.List	retrieveObjList(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] colsValue, java.lang.Class queryObj) 查询多个对象的列表数据
java.util.List	retrieveObjList(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] colsValue, java.lang.Class queryObj, boolean cacheFlag) 查询多个对象的列表数据
void	rollback() 事务回滚
void	setAutoCommit(boolean commit) 设置DataCenter是否自动提交
void	setAutoGetGeneratedKey(boolean getGeneratedKeys) 设置自获取序列号
void	setCheckTimerSchedule(long delay, boolean forceDisconnect) 设置定时检查的间隔时间参数
void	setCheckTimerSchedule(long delay, java.lang.String flag) 设置定时检查的间隔时间参数
void	setCheckTimerSchedule(long delay, java.lang.String flag, boolean forceClose) 设置定时检查的间隔时间参数
void	setConfig(java.lang.String JDBCDriver, java.lang.String JDBCConnectionURL, java.lang.String userID, java.lang.String password) 设置数据连接属性
void	setConfig(java.lang.String JDBCDriver, java.lang.String JDBCConnectionURL, java.lang.String userID, java.lang.String password, int maxActive, int maxIdle, int maxWait) 设置数据连接属性
boolean	setConnection(java.sql.Connection conn) 对于外部传入Connection连接的情况，必须设置
void	setInitClassInfo(java.lang.String initClassInfo) 初始化该实例类的信息 该方法主要用在记录DC日志时对DataCenter实例进行跟踪
void	setParam(java.lang.String key, java.lang.String value)
void	setQueryTimeout(int queryTimeout) 设置查询超时时间，QUERY_TIMEOUT_FOREVER表示无限制
void	setUpdateSilence(boolean isUpdateSilence) 设置此连接是否为安静模式，即执行update时不会通知缓存等事件
void	setWriteEnable(boolean enable) 设置是否记录DC日志,为全局开关
java.lang.String[]	update(java.sql.Connection con, java.lang.String sql, boolean commit) 修改指定的数据库中的数据
java.lang.String[]	update(java.lang.String sql) 执行SQL并按默认方式处理事务
java.lang.String[]	update(java.lang.String sql, boolean commit) 修改默认的数据库中的数据
java.lang.String[]	updateByParams(java.lang.String sql, java.lang.Object[] obj) 用参数的方式更新数据库
java.lang.String[]	updateByParams(java.lang.String sql, java.lang.Object[] obj, boolean commit) 用参数的方式更新数据库
java.lang.String[]	updateByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj) 用参数的方式更新数据库
java.lang.String[]	updateByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[][] obj, boolean commit) 用参数的方式更新数据库
java.lang.String[]	updateByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, boolean commit) 用参数的方式更新数据库
java.lang.String[]	updateByParams(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, int start, int end, boolean commit) 用参数的方式更新数据库
java.lang.String[]	updateByParams2(java.lang.String sql, java.util.List<java.lang.String> colsTypeList, java.util.List<java.lang.Object> objList, boolean commit) 用参数的方式更新数据库
java.lang.String[]	updateByStoreProc(java.lang.String procName)
java.lang.String[]	updateByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj) 通过存储过程的方式修改数据
java.lang.String[]	updateByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[][] obj, boolean commit) 通过存储过程的方式修改数据
java.lang.String[]	updateByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[][] obj, int start, int end, boolean commit) 通过存储过程的方式修改数据
java.lang.String[]	updateByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj, boolean commit) 通过存储过程的方式修改数据
java.lang.String[]	updateByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj, int[] paramType) 通过存储过程的方式修改数据
java.lang.String[]	updateByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj, int start, int end, boolean commit) 通过存储过程的方式修改数据
java.lang.String[]	updateObject(java.lang.Object obj, boolean commit) 更新表数据
java.lang.String[]	updateObject(java.lang.Object obj, boolean commit, boolean showSql) 更新表数据

字段详细资料

QUERY_TIMEOUT_FOREVER

static final int QUERY_TIMEOUT_FOREVER

另请参阅:

常量字段值

PROC_PARAM_TYPE_IN

static final int PROC_PARAM_TYPE_IN

另请参阅:

常量字段值

PROC_PARAM_TYPE_OUT

static final int PROC_PARAM_TYPE_OUT

另请参阅:

常量字段值

PROC_PARAM_TYPE_OUT_CURSOR

static final int PROC_PARAM_TYPE_OUT_CURSOR

另请参阅:

常量字段值

KEY_External_MainDataCenter

static final java.lang.String KEY_External_MainDataCenter

另请参阅:

常量字段值

KEY_External_ReportDataCenter

static final java.lang.String KEY_External_ReportDataCenter

另请参阅:

常量字段值

KEY_External_ExDataCenter

static final java.lang.String KEY_External_ExDataCenter

另请参阅:

常量字段值

方法详细资料

printLog

java.lang.String printLog()

printLog

java.lang.String printLog(org.slf4j.Logger log)

printLog

java.lang.String printLog(org.apache.logging.log4j.Logger log4j)

printLog

java.lang.String printLog(org.apache.logging.log4j.Logger log4j,
                          java.lang.String prefix)

getDriverName

java.lang.String getDriverName()

getJDBCUrl

java.lang.String getJDBCUrl()

getJDBCUserId

java.lang.String getJDBCUserId()

getJDBCPassword

java.lang.String getJDBCPassword()

getLastException

java.lang.Exception getLastException()

getDBType

java.lang.String getDBType()

获取当前连接的数据类型

返回:

String

getCacheDcType

java.lang.String getCacheDcType()

获取缓存使用的连接类型

返回:

String

hasConnected

boolean hasConnected()

是否已经建立连接

返回:

boolean

isMainDataCenter

boolean isMainDataCenter()

是否主数据库连接

返回:

boolean

isReportDataCenter

boolean isReportDataCenter()

是否主数据库连接

返回:

boolean

isExDataCenter

boolean isExDataCenter()

是否主数据库连接

返回:

boolean

setQueryTimeout

void setQueryTimeout(int queryTimeout)

设置查询超时时间，QUERY_TIMEOUT_FOREVER表示无限制

参数:

queryTimeout - 超时时长 单位：秒

setConnection

boolean setConnection(java.sql.Connection conn)

对于外部传入Connection连接的情况，必须设置

参数:

conn - JDBC连接 注意：1)如果已经获取连接再次调用时，必须disconnect后再设置，否则无效 2)通过setConnection设置连接时，不需要调用connect方法

返回:

boolean

getQueryTimeout

int getQueryTimeout()

获取查询超时时长

返回:

超时时长，0表示无限制 单位：秒

setWriteEnable

void setWriteEnable(boolean enable)

设置是否记录DC日志,为全局开关

参数:

enable - true|false

getWriteEnable

boolean getWriteEnable()

查询是否在记录DC日志

返回:

boolean

setInitClassInfo

void setInitClassInfo(java.lang.String initClassInfo)

初始化该实例类的信息 该方法主要用在记录DC日志时对DataCenter实例进行跟踪

参数:

initClassInfo - 实例类信息，如：com.sh.javax.DataCenter.setInitClassInfo

connect

java.sql.Connection connect()
                     throws java.lang.Exception

连接默认数据库

返回:

数据库连接

抛出:

java.lang.Exception - Exception

isClosed

boolean isClosed()
          throws java.lang.Exception

判断连接是否关闭，只在连接调用close方法后才会返回true

返回:

true 已关闭 false 未关闭

抛出:

java.lang.Exception - Exception

isValid

boolean isValid(int timeout)
         throws java.lang.Exception

判断连接是否有效

参数:

timeout - 指定等待验证连接的秒数

返回:

true 有效 false 无效

抛出:

java.lang.Exception - Exception

isValid

boolean isValid()
         throws java.lang.Exception

判断连接是否有效

返回:

true 有效 false 无效

抛出:

java.lang.Exception - Exception

checkValidAndReset

boolean checkValidAndReset()

检查连接，如果连接无效了，则自动重新连接

返回:

boolean

connect

@Deprecated
java.sql.Connection connect(java.lang.String sector)
                                  throws java.lang.Exception

已过时。

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

参数:

sector - 段名称

返回:

数据库连接

抛出:

java.lang.Exception - Exception

getNewConnection

java.sql.Connection getNewConnection()
                              throws java.lang.Exception

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

返回:

连接对象

抛出:

java.lang.Exception - 连接异常

setConfig

void setConfig(java.lang.String JDBCDriver,
               java.lang.String JDBCConnectionURL,
               java.lang.String userID,
               java.lang.String password)

设置数据连接属性

参数:

JDBCDriver - JDBC驱动

JDBCConnectionURL - 连接URL

userID - 用户名

password - 密码

setConfig

void setConfig(java.lang.String JDBCDriver,
               java.lang.String JDBCConnectionURL,
               java.lang.String userID,
               java.lang.String password,
               int maxActive,
               int maxIdle,
               int maxWait)

设置数据连接属性

参数:

JDBCDriver - JDBC驱动

JDBCConnectionURL - 连接URL

userID - 用户名

password - 密码

maxActive - 最大活动数

maxIdle - 最大空闲数

maxWait - 最大等待时长

disconnect

void disconnect(java.sql.Connection con)

断开指定的连接

参数:

con - 数据库连接

disconnect

void disconnect()

断开默认的数据库连接

retrieve

Datastore retrieve(java.sql.Connection con,
                   java.lang.String sql)
            throws java.lang.Exception

从指定的数据中检索数据

参数:

con - 数据库连接

sql - 查询语句

返回:

Datastore数据集

抛出:

java.lang.Exception - Exception

retrieve

Datastore retrieve(java.sql.Connection con,
                   java.lang.String sql,
                   boolean cacheFlag)
            throws java.lang.Exception

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

参数:

con - 数据库连接

sql - 查询语句

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

返回:

Datastore数据集

抛出:

java.lang.Exception - Exception

retrieve

Datastore retrieve(java.lang.String sql)
            throws java.lang.Exception

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

参数:

sql - 查询SQL

返回:

查询结果集

抛出:

java.lang.Exception - Exception

retrieve

Datastore retrieve(java.lang.String sql,
                   boolean cacheFlag)
            throws java.lang.Exception

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

参数:

sql - 查询SQL

cacheFlag - 是否使用缓存 true|false

返回:

查询结果集

抛出:

java.lang.Exception - Exception

retrieveObj

java.lang.Object retrieveObj(java.lang.String sql,
                             java.lang.Class queryObj)
                      throws java.lang.Exception

通过对象查找

参数:

sql - 查询SQL

queryObj - 查询对象

返回:

queryObj对应的实例

抛出:

java.lang.Exception - 查询异常

retrieveObj

java.lang.Object retrieveObj(java.lang.String sql,
                             java.lang.Class queryObj,
                             boolean cacheFlag)
                      throws java.lang.Exception

通过对象查找

参数:

sql - 查询SQL

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

queryObj对应的实例

抛出:

java.lang.Exception - Exception

retrieveObjByParams2

java.lang.Object retrieveObjByParams2(java.lang.String sql,
                                      java.util.List<java.lang.String> colsTypeList,
                                      java.util.List<java.lang.Object> colsValueList,
                                      java.lang.Class queryObj)
                               throws java.lang.Exception

查询对象

参数:

sql - SQL语句

colsTypeList - 参数类型

colsValueList - 参数值

queryObj - 带注释的PO对象

返回:

查询对象

抛出:

java.lang.Exception - 查询异常

retrieveObjByParams

java.lang.Object retrieveObjByParams(java.lang.String sql,
                                     java.lang.String[] colsType,
                                     java.lang.Object[] colsValue,
                                     java.lang.Class queryObj)
                              throws java.lang.Exception

查询对象

参数:

sql - SQL语句

colsType - 参数类型

colsValue - 参数值

queryObj - 带注释的PO对象

返回:

查询对象

抛出:

java.lang.Exception - 查询异常

retrieveObjByParams

java.lang.Object retrieveObjByParams(java.lang.String sql,
                                     java.lang.Object[] colsValue,
                                     java.lang.Class queryObj)
                              throws java.lang.Exception

查询对象

参数:

sql - SQL语句

colsValue - 参数值

queryObj - 带注释的PO对象

返回:

查询对象

抛出:

java.lang.Exception - 查询异常

retrieveObjByParams

java.lang.Object retrieveObjByParams(java.lang.String sql,
                                     java.lang.String[] colsType,
                                     java.lang.Object[] colsValue,
                                     java.lang.Class queryObj,
                                     boolean cacheFlag)
                              throws java.lang.Exception

查询对象

参数:

sql - SQL语句

queryObj - 带注释的PO对象

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

colsValue - String数据

queryObj - Object数据，记录参数值

cacheFlag - 是否使用缓存

返回:

查询对象

抛出:

java.lang.Exception - 查询异常

retrieveObjList

java.util.List retrieveObjList(java.lang.String sql,
                               java.lang.Class queryObj)
                        throws java.lang.Exception

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

参数:

sql - 查询SQL

queryObj - 查询对象

返回:

queryObj对应的实例集

抛出:

java.lang.Exception - 查询异常

retrieveObjList

java.util.List retrieveObjList(java.lang.String sql,
                               java.lang.Class queryObj,
                               boolean cacheFlag)
                        throws java.lang.Exception

不带参数的多数据集查询

参数:

sql - 查询SQL

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

queryObj对应的实例集

抛出:

java.lang.Exception - 查询异常

retrieveObjList

java.util.List retrieveObjList(java.lang.String sql,
                               java.lang.String[] colsType,
                               java.lang.Object[] colsValue,
                               java.lang.Class queryObj)
                        throws java.lang.Exception

查询多个对象的列表数据

参数:

sql - 查询SQL

colsType - 参数类型

colsValue - 参数值

queryObj - 查询对象

返回:

queryObj对应的实例集

抛出:

java.lang.Exception - 查询异常

retrieveObjList

java.util.List retrieveObjList(java.lang.String sql,
                               java.lang.Object[] colsValue,
                               java.lang.Class queryObj)
                        throws java.lang.Exception

查询多个对象的列表数据

参数:

sql - 查询SQL

colsValue - 参数值

queryObj - 查询对象

返回:

queryObj对应的实例集

抛出:

java.lang.Exception - 查询异常

retrieveObjList

java.util.List retrieveObjList(java.lang.String sql,
                               java.lang.String[] colsType,
                               java.lang.Object[] colsValue,
                               java.lang.Class queryObj,
                               boolean cacheFlag)
                        throws java.lang.Exception

查询多个对象的列表数据

参数:

sql - 查询SQL

colsType - 参数类型

colsValue - 参数值

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

queryObj对应的List集

抛出:

java.lang.Exception - 查询异常

retrieveByParams

Datastore retrieveByParams(java.lang.String sql,
                           java.lang.String[] colsType,
                           java.lang.Object[] obj,
                           boolean cacheFlag)

带参数查询数据集

参数:

sql - 查询SQL

colsType - 参数类型数组

obj - 参数值数组

cacheFlag - 是否使用缓存

返回:

查询数据集

retrieveByParams

Datastore retrieveByParams(java.lang.String sql,
                           java.lang.Object[] obj,
                           boolean cacheFlag)

带参数查询数据集

参数:

sql - 查询SQL

obj - 参数值数组

cacheFlag - 是否使用缓存

返回:

查询数据集

retrieveByParams

Datastore retrieveByParams(java.lang.String sql,
                           java.lang.String[] colsType,
                           java.lang.Object[] obj)

带参数查询数据集

参数:

sql - 查询SQL

colsType - 参数类型数组

obj - 参数值数组

返回:

查询数据集

retrieveByParams

Datastore retrieveByParams(java.lang.String sql,
                           java.lang.Object[] obj)

带参数查询数据集

参数:

sql - 查询SQL

obj - 参数值数组

返回:

查询数据集

retrieveByParams2

Datastore retrieveByParams2(java.lang.String sql,
                            java.util.List<java.lang.String> colsTypeList,
                            java.util.List<java.lang.Object> objList)

带参数查询数据集

参数:

sql - 查询SQL

colsTypeList - 参数类型数组

objList - 参数值数组

返回:

查询数据集

抛出:

java.lang.Exception - Exception

retrieveByParams2

Datastore retrieveByParams2(java.lang.String sql,
                            java.util.List<java.lang.Object> objList)

retrieveByParams2

Datastore retrieveByParams2(java.lang.String sql,
                            java.util.List<java.lang.Object> objList,
                            boolean cacheFlag)

retrieveByParams2

Datastore retrieveByParams2(java.lang.String sql,
                            java.util.List<java.lang.String> colsTypeList,
                            java.util.List<java.lang.Object> objList,
                            boolean cacheFlag)

带参数查询数据集

参数:

sql - 查询SQL

colsTypeList - 参数类型数组

objList - 参数值数组

cacheFlag - 是否使用缓存

返回:

查询数据集

抛出:

java.lang.Exception - Exception

retrieveByStoreProc

Datastore retrieveByStoreProc(java.lang.String procName)

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

参数:

procName - 存储过程名称

返回:

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

retrieveByStoreProc

Datastore retrieveByStoreProc(java.lang.String procName,
                              java.lang.String[] colsType,
                              java.lang.Object[] obj)

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

返回:

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

retrieveListByStoreProc

java.util.List<Datastore> retrieveListByStoreProc(java.lang.String procName,
                                                  java.lang.String[] colsType,
                                                  java.lang.Object[] obj,
                                                  int[] paramType)

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

参数:

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

colsType - 参数类型数组

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

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

返回:

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

update

java.lang.String[] update(java.sql.Connection con,
                          java.lang.String sql,
                          boolean commit)

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

参数:

con - 数据库连接

sql - 更新语句

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

返回:

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

update

java.lang.String[] update(java.lang.String sql)

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

参数:

sql - 修改数据库的语句

返回:

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

updateObject

java.lang.String[] updateObject(java.lang.Object obj,
                                boolean commit,
                                boolean showSql)
                         throws java.lang.Exception

更新表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

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

返回:

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

抛出:

java.lang.Exception - 异常

updateObject

java.lang.String[] updateObject(java.lang.Object obj,
                                boolean commit)
                         throws java.lang.Exception

更新表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

返回:

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

抛出:

java.lang.Exception - Exception

addObject

java.lang.String[] addObject(java.lang.Object obj,
                             boolean commit,
                             boolean showSql)

添加表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

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

返回:

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

replaceObject

java.lang.String[] replaceObject(java.lang.Object obj,
                                 boolean commit,
                                 boolean showSql)

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

参数:

obj - 实例对象

commit - 是否自动提交事务

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

返回:

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

replaceObject

java.lang.String[] replaceObject(java.lang.Object obj,
                                 boolean commit)

addObject

java.lang.String[] addObject(java.lang.Object obj,
                             boolean commit)
                      throws java.lang.Exception

添加表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

返回:

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

抛出:

java.lang.Exception - Exception

update

java.lang.String[] update(java.lang.String sql,
                          boolean commit)

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

参数:

sql - 更新语句

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

返回:

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

updateByParams

java.lang.String[] updateByParams(java.lang.String sql,
                                  java.lang.String[] colsType,
                                  java.lang.Object[] obj)

用参数的方式更新数据库

参数:

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

colsType - 参数类型

obj - 参数值数组

返回:

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

updateByParams

java.lang.String[] updateByParams(java.lang.String sql,
                                  java.lang.Object[] obj)

用参数的方式更新数据库

参数:

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

obj - 参数值数组

返回:

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

updateByParams

java.lang.String[] updateByParams(java.lang.String sql,
                                  java.lang.String[] colsType,
                                  java.lang.Object[] obj,
                                  boolean commit)

用参数的方式更新数据库

参数:

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

colsType - 参数类型

obj - 参数值数组

commit - 是否提交

返回:

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

updateByParams

java.lang.String[] updateByParams(java.lang.String sql,
                                  java.lang.Object[] obj,
                                  boolean commit)

用参数的方式更新数据库

参数:

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

obj - 参数值数组

commit - 是否提交

返回:

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

updateByParams2

java.lang.String[] updateByParams2(java.lang.String sql,
                                   java.util.List<java.lang.String> colsTypeList,
                                   java.util.List<java.lang.Object> objList,
                                   boolean commit)

用参数的方式更新数据库

参数:

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

colsTypeList - 参数类型

objList - 参数值数组

commit - 是否提交

返回:

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

updateByParams

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

用参数的方式更新数据库

参数:

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

colsType - 参数类型

obj - 参数值数组

start - 参数起始位置

end - 参数结束位置

commit - 是否提交

返回:

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

updateByParams

java.lang.String[] updateByParams(java.lang.String sql,
                                  java.lang.String[] colsType,
                                  java.lang.Object[][] obj,
                                  boolean commit)

用参数的方式更新数据库

参数:

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

colsType - 参数类型

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

commit - 是否提交

返回:

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

updateByStoreProc

java.lang.String[] updateByStoreProc(java.lang.String procName)

updateByStoreProc

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

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

start - 参数起始序号

end - 参数结束序号

commit - 是否提交

返回:

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

updateByStoreProc

java.lang.String[] updateByStoreProc(java.lang.String procName,
                                     java.lang.String[] colsType,
                                     java.lang.Object[] obj)

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

返回:

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

updateByStoreProc

java.lang.String[] updateByStoreProc(java.lang.String procName,
                                     java.lang.String[] colsType,
                                     java.lang.Object[] obj,
                                     boolean commit)

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

commit - 是否提交

返回:

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

updateByStoreProc

java.lang.String[] updateByStoreProc(java.lang.String procName,
                                     java.lang.String[] colsType,
                                     java.lang.Object[] obj,
                                     int[] paramType)

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

参数:

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

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

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

start - 参数起始序号

end - 参数结束序号

commit - 是否提交

返回:

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

updateByStoreProc

java.lang.String[] updateByStoreProc(java.lang.String procName,
                                     java.lang.String[] colsType,
                                     java.lang.Object[][] obj,
                                     boolean commit)

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

commit - 是否提交

返回:

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

beginBatchUpdateByParams

java.lang.String[] beginBatchUpdateByParams(java.lang.String sql,
                                            java.lang.String[] colsType,
                                            int refreshCount)

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

参数:

sql - 执行SQL

colsType - SQL参数类型

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

返回:

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

beginBatchUpdateByParams

java.lang.String[] beginBatchUpdateByParams(java.lang.String sql,
                                            java.lang.String[] colsType)

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

参数:

sql - 执行SQL

colsType - SQL参数类型

返回:

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

addBatch

java.lang.String[] addBatch(java.lang.String key,
                            java.lang.Object[] obj)

添加批量操作

参数:

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

obj - 参数值

返回:

{true|false,操作序列号|错误信息}

refreshBatchUpdate

java.lang.String[] refreshBatchUpdate(java.lang.String key)

刷新批量更新,如果批量执行太多时，可以用这个函数来刷新队列，也可以在beginBatchUpdateByParams中设置refreshCount参数

参数:

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

返回:

{true|false,当前操作号|错误信息}

endBatchUpdateByParams

java.lang.String[] endBatchUpdateByParams(java.lang.String key)

结束批量更新操作,执行后如果要重新执行批量更新，则需要再次调用beginBatchUpdateByParams函数

参数:

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

返回:

{true|false,更新记录条数|错误信息}

endBatchUpdateByParams

java.lang.String[] endBatchUpdateByParams(java.lang.String key,
                                          boolean commit)

结束批量更新操作,执行后如果要重新执行批量更新，则需要再次调用beginBatchUpdateByParams函数

参数:

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

commit - 自动提交事务，true|false,默认：false

返回:

{true|false,更新记录条数|错误信息}

setAutoCommit

void setAutoCommit(boolean commit)
            throws java.sql.SQLException

设置DataCenter是否自动提交

参数:

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

抛出:

java.sql.SQLException - SQLException

getConnection

java.sql.Connection getConnection()

获取连接

返回:

Connection 连接对象

getExecutionLen

long getExecutionLen()

获取最后一次执行时长

返回:

执行时长，单位：ms

commit

void commit()

提交事务

rollback

void rollback()

事务回滚

setAutoGetGeneratedKey

void setAutoGetGeneratedKey(boolean getGeneratedKeys)

设置自获取序列号

参数:

getGeneratedKeys - boolean

getAutoGeneratedKey

int getAutoGeneratedKey()

获取自增长列 在执行查询前，需要做的操作有： setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) int key == getAutoGeneratedKey() ;

返回:

自增长值

getAutoGeneratedKeyStr

java.lang.String getAutoGeneratedKeyStr()

获取自增长列并转化为String类型 在执行查询前，需要做的操作有： setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) String key == getAutoGeneratedKeyStr() ;

返回:

自增长键值

setUpdateSilence

void setUpdateSilence(boolean isUpdateSilence)

设置此连接是否为安静模式，即执行update时不会通知缓存等事件

参数:

isUpdateSilence - 开头

getLastExecuteSql

java.lang.String getLastExecuteSql()

获取最近一次执行的SQL语句

返回:

String

getDsCacheRedis

DSCacheRedis getDsCacheRedis()

获取redis

返回:

DSCacheRedis

isExecute

boolean isExecute()

就否正在执行SQL

返回:

true|false

setCheckTimerSchedule

void setCheckTimerSchedule(long delay,
                           java.lang.String flag)

设置定时检查的间隔时间参数

参数:

delay - 间隔时间，单独产：毫秒

flag - 状态标识，用于业务判断

setCheckTimerSchedule

void setCheckTimerSchedule(long delay,
                           boolean forceDisconnect)

设置定时检查的间隔时间参数

参数:

delay - 间隔时间，单独产：毫秒

forceClose - 到达时间后是否强制关闭

setCheckTimerSchedule

void setCheckTimerSchedule(long delay,
                           java.lang.String flag,
                           boolean forceClose)

设置定时检查的间隔时间参数

参数:

delay - 间隔时间，单独产：毫秒

flag - 状态标识，用于业务判断

forceClose - 到达时间后是否强制关闭，默认：false

isTooLongIdle

boolean isTooLongIdle(long idleTimeout)

判断是否空闲太久

参数:

idleTimeout - 空闲超时时长

返回:

boolean true|false

getIdleTime

long getIdleTime()

获取空闲时间

返回:

空闲时长，单位：毫秒

createUpdateBuilder

SqlUpdateBuilder createUpdateBuilder()

创建添加、修改、删除的SQL生成工具对象为

返回:

createQueryBuilder

SqlBuilder createQueryBuilder()

创建查询的SQL生成工具对象为

返回:

setParam

void setParam(java.lang.String key,
              java.lang.String value)

getParam

java.lang.String getParam(java.lang.String key,
                          java.lang.String defaultValue)

createColsTypeByValue

java.lang.String[] createColsTypeByValue(java.lang.Object[] value)

通过参数值自动生成参数类型

参数:

value -

返回: