程序包 com.sh.javax
接口 DataCenter
- 所有已知实现类:
AutoCloseableExDataCenter,AutoCloseableJDBCDataCenter,AutoCloseableMainDataCenter,AutoCloseableReportDataCenter,DataCenterBase,DecorateDataCenter,ESDataCenter,ExDataCenter,JDBCDataCenter,MainDataCenter,ReportDataCenter,SDBDataCenter,SQueryDataCenter
public interface DataCenter
Description: 数据中心接口
Title:首亨软件 - CRM、TSS、ERP等信息化管理软件
-
字段概要
字段 -
方法概要
修饰符和类型方法说明String[]添加批量操作String[]添加表数据String[]添加表数据String[]beginBatchUpdateByParams(String sql, String[] colsType) 开始进行批量更新,必需与endBatchUpdateByParams一一配对使用String[]beginBatchUpdateByParams(String sql, String[] colsType, int refreshCount) 开始进行批量更新,必需与endBatchUpdateByParams一一配对使用boolean检查连接,如果连接无效了,则自动重新连接voidcommit()提交事务connect()连接默认数据库已过时。String[]createColsTypeByValue(Object[] value) 通过参数值自动生成参数类型创建查询的SQL生成工具对象为创建添加、修改、删除的SQL生成工具对象为void断开默认的数据库连接voiddisconnect(Connection con) 断开指定的连接String[]结束批量更新操作,执行后如果要重新执行批量更新,则需要再次调用beginBatchUpdateByParams函数String[]endBatchUpdateByParams(String key, boolean commit) 结束批量更新操作,执行后如果要重新执行批量更新,则需要再次调用beginBatchUpdateByParams函数int获取自增长列 在执行查询前,需要做的操作有: setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) int key == getAutoGeneratedKey() ;long获取自增长列并转化为String类型 在执行查询前,需要做的操作有: setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) String key == getAutoGeneratedKeyStr() ;getBatchUpdate(String key) 获取缓存使用的连接类型获取连接获取当前连接的数据类型获取redislong获取最后一次执行时长long获取空闲时间获取最近一次执行的SQL语句int获取最后一次影响行数获取新的连接,不从连接池中取,一般不允许使用int获取查询超时时长boolean查询是否在记录DC日志boolean是否已经建立连接booleanisClosed()判断连接是否关闭,只在连接调用close方法后才会返回trueboolean是否主数据库连接boolean就否正在执行SQLboolean是否主数据库连接boolean是否主数据库连接booleanisTooLongIdle(long idleTimeout) 判断是否空闲太久booleanisValid()判断连接是否有效booleanisValid(int timeout) 判断连接是否有效printLog()printLog(org.apache.logging.log4j.Logger log4j) printLog(org.slf4j.Logger log) String[]refreshBatchUpdate(String key) 刷新批量更新,如果批量执行太多时,可以用这个函数来刷新队列,也可以在beginBatchUpdateByParams中设置refreshCount参数String[]replaceObject(Object obj, boolean commit) String[]replaceObject(Object obj, boolean commit, boolean showSql) 添加或修改表数据,只有mysql支持从默认的数据库中获取数据从默认的数据库中获取数据retrieve(Connection con, String sql) 从指定的数据中检索数据retrieve(Connection con, String sql, boolean cacheFlag) 从指定的数据库中检索数据retrieveByParams(String sql, Object[] obj) 带参数查询数据集retrieveByParams(String sql, Object[] obj, boolean cacheFlag) 带参数查询数据集retrieveByParams(String sql, String[] colsType, Object[] obj) 带参数查询数据集retrieveByParams(String sql, String[] colsType, Object[] obj, boolean cacheFlag) 带参数查询数据集retrieveByParams2(String sql, List<Object> objList) retrieveByParams2(String sql, List<Object> objList, boolean cacheFlag) 带参数查询数据集带参数查询数据集retrieveByStoreProc(String procName) 通过存储过程的方式检索数据retrieveByStoreProc(String procName, String[] colsType, Object[] obj) 通过存储过程的方式检索数据retrieveListByStoreProc(String procName, String[] colsType, Object[] obj, int[] paramType) 通过存储过程的方式检索数据,能返回多个游标retrieveObj(String sql, Class queryObj) 通过对象查找retrieveObj(String sql, Class queryObj, boolean cacheFlag) 通过对象查找retrieveObjByParams(String sql, Object[] colsValue, Class queryObj) 查询对象retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj) 查询对象retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag) 查询对象retrieveObjByParams2(String sql, List<String> colsTypeList, List<Object> colsValueList, Class queryObj) 查询对象retrieveObjList(String sql, Class queryObj) 不带参数的多数据集查询,不带缓存retrieveObjList(String sql, Class queryObj, boolean cacheFlag) 不带参数的多数据集查询retrieveObjList(String sql, Object[] colsValue, Class queryObj) 查询多个对象的列表数据retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj) 查询多个对象的列表数据retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag) 查询多个对象的列表数据voidrollback()事务回滚voidsetAutoCommit(boolean commit) 设置DataCenter是否自动提交voidsetAutoGetGeneratedKey(boolean getGeneratedKeys) 设置自获取序列号voidsetCheckTimerSchedule(long delay, boolean forceDisconnect) 设置定时检查的间隔时间参数voidsetCheckTimerSchedule(long delay, String flag) 设置定时检查的间隔时间参数voidsetCheckTimerSchedule(long delay, String flag, boolean forceClose) 设置定时检查的间隔时间参数void设置数据连接属性voidsetConfig(String JDBCDriver, String JDBCConnectionURL, String userID, String password, int maxActive, int maxIdle, int maxWait) 设置数据连接属性booleansetConnection(Connection conn) 对于外部传入Connection连接的情况,必须设置voidsetInitClassInfo(String initClassInfo) 初始化该实例类的信息 该方法主要用在记录DC日志时对DataCenter实例进行跟踪voidvoidsetQueryTimeout(int queryTimeout) 设置查询超时时间,QUERY_TIMEOUT_FOREVER表示无限制voidsetUpdateSilence(boolean isUpdateSilence) 设置此连接是否为安静模式,即执行update时不会通知缓存等事件voidsetWriteEnable(boolean enable) 设置是否记录DC日志,为全局开关String[]执行SQL并按默认方式处理事务String[]修改默认的数据库中的数据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[]用参数的方式更新数据库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) 更新表数据
-
字段详细资料
-
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
- 另请参阅:
-
KEY_External_ReportDataCenter
- 另请参阅:
-
KEY_External_ExDataCenter
- 另请参阅:
-
-
方法详细资料
-
printLog
String printLog() -
printLog
-
printLog
-
printLog
-
getErrorMsg
String getErrorMsg() -
getDriverName
String getDriverName() -
getJDBCUrl
String getJDBCUrl() -
getJDBCUserId
String getJDBCUserId() -
getJDBCPassword
String getJDBCPassword() -
getLastException
Exception getLastException() -
getDBType
String getDBType()获取当前连接的数据类型- 返回:
- String
-
getCacheDcType
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
对于外部传入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
初始化该实例类的信息 该方法主要用在记录DC日志时对DataCenter实例进行跟踪- 参数:
initClassInfo- 实例类信息,如:com.sh.javax.DataCenter.setInitClassInfo
-
connect
Connection connect()连接默认数据库- 返回:
- 数据库连接
-
isClosed
boolean isClosed()判断连接是否关闭,只在连接调用close方法后才会返回true- 返回:
- true 已关闭 false 未关闭
-
isValid
boolean isValid(int timeout) 判断连接是否有效- 参数:
timeout- 指定等待验证连接的秒数- 返回:
- true 有效 false 无效
-
isValid
boolean isValid()判断连接是否有效- 返回:
- true 有效 false 无效
-
checkValidAndReset
boolean checkValidAndReset()检查连接,如果连接无效了,则自动重新连接- 返回:
- boolean
-
connect
已过时。连接配置文件中指定的段,这个只对connType=config有效- 参数:
sector- 段名称- 返回:
- 数据库连接
-
getNewConnection
Connection getNewConnection()获取新的连接,不从连接池中取,一般不允许使用- 返回:
- 连接对象
-
setConfig
设置数据连接属性- 参数:
JDBCDriver- JDBC驱动JDBCConnectionURL- 连接URLuserID- 用户名password- 密码
-
setConfig
void setConfig(String JDBCDriver, String JDBCConnectionURL, String userID, String password, int maxActive, int maxIdle, int maxWait) 设置数据连接属性- 参数:
JDBCDriver- JDBC驱动JDBCConnectionURL- 连接URLuserID- 用户名password- 密码maxActive- 最大活动数maxIdle- 最大空闲数maxWait- 最大等待时长
-
disconnect
断开指定的连接- 参数:
con- 数据库连接
-
disconnect
void disconnect()断开默认的数据库连接 -
retrieve
从指定的数据中检索数据- 参数:
con- 数据库连接sql- 查询语句- 返回:
- Datastore数据集
-
retrieve
从指定的数据库中检索数据- 参数:
con- 数据库连接sql- 查询语句cacheFlag- true使用缓存,false 不使用缓存- 返回:
- Datastore数据集
-
retrieve
从默认的数据库中获取数据- 参数:
sql- 查询SQL- 返回:
- 查询结果集
-
retrieve
从默认的数据库中获取数据- 参数:
sql- 查询SQLcacheFlag- 是否使用缓存 true|false- 返回:
- 查询结果集
-
retrieveObj
通过对象查找- 参数:
sql- 查询SQLqueryObj- 查询对象- 返回:
- queryObj对应的实例
-
retrieveObj
通过对象查找- 参数:
sql- 查询SQLqueryObj- 查询对象cacheFlag- 是否使用缓存- 返回:
- queryObj对应的实例
-
retrieveObjByParams2
Object retrieveObjByParams2(String sql, List<String> colsTypeList, List<Object> colsValueList, Class queryObj) 查询对象- 参数:
sql- SQL语句colsTypeList- 参数类型colsValueList- 参数值queryObj- 带注释的PO对象- 返回:
- 查询对象
-
retrieveObjByParams
查询对象- 参数:
sql- SQL语句colsType- 参数类型colsValue- 参数值queryObj- 带注释的PO对象- 返回:
- 查询对象
-
retrieveObjByParams
查询对象- 参数:
sql- SQL语句colsValue- 参数值queryObj- 带注释的PO对象- 返回:
- 查询对象
-
retrieveObjByParams
Object retrieveObjByParams(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag) 查询对象- 参数:
sql- SQL语句queryObj- 带注释的PO对象colsType- String数据,记录参数对应的类型colsValue- String数据queryObj- Object数据,记录参数值cacheFlag- 是否使用缓存- 返回:
- 查询对象
-
retrieveObjList
不带参数的多数据集查询,不带缓存- 参数:
sql- 查询SQLqueryObj- 查询对象- 返回:
- queryObj对应的实例集
-
retrieveObjList
不带参数的多数据集查询- 参数:
sql- 查询SQLqueryObj- 查询对象cacheFlag- 是否使用缓存- 返回:
- queryObj对应的实例集
-
retrieveObjList
查询多个对象的列表数据- 参数:
sql- 查询SQLcolsType- 参数类型colsValue- 参数值queryObj- 查询对象- 返回:
- queryObj对应的实例集
-
retrieveObjList
查询多个对象的列表数据- 参数:
sql- 查询SQLcolsValue- 参数值queryObj- 查询对象- 返回:
- queryObj对应的实例集
-
retrieveObjList
List retrieveObjList(String sql, String[] colsType, Object[] colsValue, Class queryObj, boolean cacheFlag) 查询多个对象的列表数据- 参数:
sql- 查询SQLcolsType- 参数类型colsValue- 参数值queryObj- 查询对象cacheFlag- 是否使用缓存- 返回:
- queryObj对应的List集
-
retrieveByParams
带参数查询数据集- 参数:
sql- 查询SQLcolsType- 参数类型数组obj- 参数值数组cacheFlag- 是否使用缓存- 返回:
- 查询数据集
-
retrieveByParams
带参数查询数据集- 参数:
sql- 查询SQLobj- 参数值数组cacheFlag- 是否使用缓存- 返回:
- 查询数据集
-
retrieveByParams
带参数查询数据集- 参数:
sql- 查询SQLcolsType- 参数类型数组obj- 参数值数组- 返回:
- 查询数据集
-
retrieveByParams
带参数查询数据集- 参数:
sql- 查询SQLobj- 参数值数组- 返回:
- 查询数据集
-
retrieveByParams2
带参数查询数据集- 参数:
sql- 查询SQLcolsTypeList- 参数类型数组objList- 参数值数组- 返回:
- 查询数据集
-
retrieveByParams2
-
retrieveByParams2
-
retrieveByParams2
Datastore retrieveByParams2(String sql, List<String> colsTypeList, List<Object> objList, boolean cacheFlag) 带参数查询数据集- 参数:
sql- 查询SQLcolsTypeList- 参数类型数组objList- 参数值数组cacheFlag- 是否使用缓存- 返回:
- 查询数据集
-
retrieveByStoreProc
通过存储过程的方式检索数据- 参数:
procName- 存储过程名称- 返回:
- 数据集Datastore 注意:目前只支持ORACLE
-
retrieveByStoreProc
通过存储过程的方式检索数据- 参数:
procName- 存储过程名称colsType- 参数类型数组obj- 参数值数组,多行数据- 返回:
- 数据集Datastore 注意:目前只支持ORACLE
-
retrieveListByStoreProc
List<Datastore> retrieveListByStoreProc(String procName, String[] colsType, Object[] obj, int[] paramType) 通过存储过程的方式检索数据,能返回多个游标- 参数:
procName- 存储过程名称,存储过程需要可以任意定义返回游标colsType- 参数类型数组obj- 参数值数组,多行数据paramType- 输入、输出参数类型、DataCenter.PROC_PARAM_TYPE_IN,DataCenter.PROC_PARAM_TYPE_OUT- 返回:
- 多数据集Datastore 注意:目前只支持ORACLE
-
update
修改指定的数据库中的数据- 参数:
con- 数据库连接sql- 更新语句commit- 是否提交,true提交,false不提交,可手动调用dc.commit()提交或dc.rollback()回滚- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
update
执行SQL并按默认方式处理事务- 参数:
sql- 修改数据库的语句- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateObject
更新表数据- 参数:
obj- 实例对象commit- 是否自动提交事务showSql- 是否打印出sql 默认为false- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateObject
更新表数据- 参数:
obj- 实例对象commit- 是否自动提交事务- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
addObject
添加表数据- 参数:
obj- 实例对象commit- 是否自动提交事务showSql- 是否打印出sql 默认为false- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
replaceObject
添加或修改表数据,只有mysql支持- 参数:
obj- 实例对象commit- 是否自动提交事务showSql- 是否打印出sql 默认为false- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
replaceObject
-
addObject
添加表数据- 参数:
obj- 实例对象commit- 是否自动提交事务- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
update
修改默认的数据库中的数据- 参数:
sql- 更新语句commit- 是否提交,true提交,false取消数据更新- 返回:
- string[0] "true"成功;"false"失败 string[1] 出错信息
-
updateByParams
用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句colsType- 参数类型obj- 参数值数组- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByParams
用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句obj- 参数值数组- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByParams
用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句colsType- 参数类型obj- 参数值数组commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByParams
用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句obj- 参数值数组commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByParams2
String[] updateByParams2(String sql, List<String> colsTypeList, List<Object> objList, boolean commit) 用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句colsTypeList- 参数类型objList- 参数值数组commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByParams
String[] updateByParams(String sql, String[] colsType, Object[] obj, int start, int end, boolean commit) 用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句colsType- 参数类型obj- 参数值数组start- 参数起始位置end- 参数结束位置commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByParams
用参数的方式更新数据库- 参数:
sql- 更改数据库数据的语句colsType- 参数类型obj- 参数值数组,同时更改多条数据commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByStoreProc
-
updateByStoreProc
String[] updateByStoreProc(String procName, String[] colsType, Object[][] obj, int start, int end, boolean commit) 通过存储过程的方式修改数据- 参数:
procName- 存储过程名称colsType- 参数类型数组obj- 参数值数组,多行数据start- 参数起始序号end- 参数结束序号commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByStoreProc
通过存储过程的方式修改数据- 参数:
procName- 存储过程名称colsType- 参数类型数组obj- 参数值数组,一行数据- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByStoreProc
通过存储过程的方式修改数据- 参数:
procName- 存储过程名称colsType- 参数类型数组obj- 参数值数组,一行数据commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByStoreProc
通过存储过程的方式修改数据- 参数:
procName- 存储过程名称,需要带上参数colsType- 参数类型数组obj- 参数值数组,一行数据,如果为OUT型参数,可以为空或nullparamType- 参数类型,DataCenter.PROC_PARAM_TYPE_OUT或DataCenter.PROC_PARAM_TYPE_IN- 返回:
- {true,ret1,ret2....}为果[0]为true时,后台参数依次返回指定参数类型的OUT的值 Note:要求colsType/obj/paramType三个数组长度一致
-
updateByStoreProc
String[] updateByStoreProc(String procName, String[] colsType, Object[] obj, int start, int end, boolean commit) 通过存储过程的方式修改数据- 参数:
procName- 存储过程名称colsType- 参数类型数组obj- 参数值数组,一行数据start- 参数起始序号end- 参数结束序号commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
updateByStoreProc
通过存储过程的方式修改数据- 参数:
procName- 存储过程名称colsType- 参数类型数组obj- 参数值数组,多行数据commit- 是否提交- 返回:
- string[0] "true"成功;"false"失败 string[1] 影响行数|出错信息
-
beginBatchUpdateByParams
开始进行批量更新,必需与endBatchUpdateByParams一一配对使用- 参数:
sql- 执行SQLcolsType- SQL参数类型refreshCount- 批量队列到达该值时自动刷新,0表示取消自动刷新,设置此值后在自动刷新时操作成功会提交事务,即执行commit()方法- 返回:
- {true|false,操作关键字(后续操作会用到)|错误信息}
-
beginBatchUpdateByParams
开始进行批量更新,必需与endBatchUpdateByParams一一配对使用- 参数:
sql- 执行SQLcolsType- SQL参数类型- 返回:
- {true|false,操作关键字(后续操作会用到)|错误信息}
-
addBatch
添加批量操作- 参数:
key- 操作序列号,通过beginBatchUpdateByParams获取obj- 参数值- 返回:
- {true|false,操作序列号|错误信息}
-
getBatchUpdate
-
refreshBatchUpdate
刷新批量更新,如果批量执行太多时,可以用这个函数来刷新队列,也可以在beginBatchUpdateByParams中设置refreshCount参数- 参数:
key- 操作序列号,通过beginBatchUpdateByParams获取- 返回:
- {true|false,当前操作号|错误信息}
-
endBatchUpdateByParams
结束批量更新操作,执行后如果要重新执行批量更新,则需要再次调用beginBatchUpdateByParams函数- 参数:
key- 操作序列号,通过beginBatchUpdateByParams获取- 返回:
- {true|false,更新记录条数|错误信息}
-
endBatchUpdateByParams
结束批量更新操作,执行后如果要重新执行批量更新,则需要再次调用beginBatchUpdateByParams函数- 参数:
key- 操作序列号,通过beginBatchUpdateByParams获取commit- 自动提交事务,true|false,默认:false- 返回:
- {true|false,更新记录条数|错误信息}
-
setAutoCommit
void setAutoCommit(boolean commit) 设置DataCenter是否自动提交- 参数:
commit- true自动提交,false手工提交
-
getConnection
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() ;- 返回:
- 自增长值
-
getAutoGeneratedKey2
long getAutoGeneratedKey2() -
getAutoGeneratedKeyStr
String getAutoGeneratedKeyStr()获取自增长列并转化为String类型 在执行查询前,需要做的操作有: setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) String key == getAutoGeneratedKeyStr() ;- 返回:
- 自增长键值
-
setUpdateSilence
void setUpdateSilence(boolean isUpdateSilence) 设置此连接是否为安静模式,即执行update时不会通知缓存等事件- 参数:
isUpdateSilence- 开头
-
getLastExecuteSql
String getLastExecuteSql()获取最近一次执行的SQL语句- 返回:
- String
-
getDsCacheRedis
DSCacheRedis getDsCacheRedis()获取redis- 返回:
- DSCacheRedis
-
isExecute
boolean isExecute()就否正在执行SQL- 返回:
- true|false
-
setCheckTimerSchedule
设置定时检查的间隔时间参数- 参数:
delay- 间隔时间,单独产:毫秒flag- 状态标识,用于业务判断
-
setCheckTimerSchedule
void setCheckTimerSchedule(long delay, boolean forceDisconnect) 设置定时检查的间隔时间参数- 参数:
delay- 间隔时间,单独产:毫秒forceClose- 到达时间后是否强制关闭
-
setCheckTimerSchedule
设置定时检查的间隔时间参数- 参数:
delay- 间隔时间,单独产:毫秒flag- 状态标识,用于业务判断forceClose- 到达时间后是否强制关闭,默认:false
-
isTooLongIdle
boolean isTooLongIdle(long idleTimeout) 判断是否空闲太久- 参数:
idleTimeout- 空闲超时时长- 返回:
- boolean true|false
-
getIdleTime
long getIdleTime()获取空闲时间- 返回:
- 空闲时长,单位:毫秒
-
createUpdateBuilder
SqlUpdateBuilder createUpdateBuilder()创建添加、修改、删除的SQL生成工具对象为- 返回:
-
createQueryBuilder
SqlBuilder createQueryBuilder()创建查询的SQL生成工具对象为- 返回:
-
createSelectBuilder
SqlSelectBuilder createSelectBuilder() -
setParam
-
getParam
-
createColsTypeByValue
通过参数值自动生成参数类型- 参数:
value-- 返回:
-
getLastRowCount
int getLastRowCount()获取最后一次影响行数- 返回:
-