com.sh.javax

类 DataCenterBase

java.lang.Object

com.sh.javax.DataCenterBase

所有已实现的接口:

DataCenter

直接已知子类:

ESDataCenter, ExDataCenter, JDBCDataCenter, MainDataCenter, MainSlaveDataCenter, MongoDataCenter, ReportDataCenter, SQueryDataCenter

public abstract class DataCenterBase
extends java.lang.Object
implements DataCenter

Description: 数据库连接基类，处理一些公共的方法

Title:首亨软件 - CRM、TSS、ERP等信息化管理软件

版本:

1.0

作者:

江兴春

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	CONFIG_CONN
static int	External
static java.lang.String	External_CONN
static java.lang.String	LOCAL_CONN
static java.lang.String	POOL_CONN
static int	SH_BASIC_POOL
static int	SH_DRUID
static int	SH_POOL
static int	STRUTS_POOL
static int	TOMCAT_POOL
static int	UNDEFINE
static int	WEBLOGIC_POOL
static boolean	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

构造器概要

构造器

构造器和说明
DataCenterBase()

方法概要

限定符和类型	方法和说明
java.lang.String[]	addBatch(java.lang.String key, java.lang.Object[] obj) 添加批量操作
void	beginStatement(java.sql.Statement statement)
void	checkAndInitCache()
DCWatcher	checkRetrieveWatcher(java.lang.String key) 查看是否观察者
boolean	checkValidAndReset() 检查连接，如果连接无效了，则自动重新连接
void	close()
void	closeCache()
void	closeStatement(java.sql.Statement statement)
Datastore	convertRsToDs(java.sql.ResultSet rs, int start, int end) 将JDBC数据集转化称Datastore
Datastore	convertRsToDs(java.sql.ResultSet rs, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, long startTime) 将整个数据集都转化称Datastore
java.lang.String[]	createColsTypeByValue(java.lang.Object[] value) 通过参数值自动生成参数类型
SqlBuilder	createQueryBuilder() 创建查询的SQL生成工具对象为
SqlUpdateBuilder	createUpdateBuilder() 创建添加、修改、删除的SQL生成工具对象为
java.lang.String[]	endBatchUpdateByParams(java.lang.String key) 结束批量更新操作
java.lang.String[]	endBatchUpdateByParams(java.lang.String key, boolean commit) 结束批量更新操作
void	finishStatement(java.sql.Statement statement)
int	getAutoGeneratedKey() 获取自增长列 在执行查询前，需要做的操作有： setAutoGetGeneratedKey(true) //执行update setAutoGetGeneratedKey(false) int key == getAutoGeneratedKey() ;
java.lang.String	getAutoGeneratedKeyStr() 获取自增长列并转化为String类型 在执行查询前，需要做的操作有： setAutoGetGeneratedKey(true) //执行带insert的且有自增长列的操作 setAutoGetGeneratedKey(false) String key == getAutoGeneratedKeyStr() ;
Datastore	getCacheDs(java.lang.String key)
java.lang.String	getClassInfo() 获取初始化实例类信息
java.sql.Connection	getConnection() 获取连接
long	getConnectStartTime()
java.lang.String	getDcType() DC类型
DSCacheRedis	getDsCacheRedis() 获取redis
long	getExecutionLen() 最后一次执行时长
long	getIdleTime() 获取空闲时间
java.lang.Exception	getLastException()
java.lang.String	getLastExecuteSql() 获取最近一次执行的SQL语句
java.lang.String	getParam(java.lang.String key, java.lang.String defaultValue)
int	getQueryTimeout() 获取查询超时时长
boolean	getWriteEnable() 是否记录DC日志标志
boolean	hasConnected() 是否已经建立连接
static void	initExternalDataSource(javax.sql.DataSource datasource, java.lang.Class<?> clazz) 初始化外部连接
boolean	isClosed() 判断连接是否关闭，只在连接调用close方法后才会返回true
boolean	isExecute() 是否正在执行
boolean	isTooLongIdle(long idleTimeout) 判断是否空闲太久
boolean	isUpdateSilence()
boolean	isValid() 判断连接是否有效,默认等待验证连接秒数：5s
boolean	isValid(int timeout) 判断连接是否有效
java.lang.String	printLog()
java.lang.String	printLog(org.apache.logging.log4j.Logger log4j)
java.lang.String	printLog(org.slf4j.Logger log)
java.lang.String	printLog(org.apache.logging.log4j.Logger log4j, java.lang.String prefix)
java.lang.String	processKey(java.lang.String sql, java.lang.String key, java.lang.String[] colsType, java.lang.Object[] obj)
void	putCacheDs(java.lang.String key, Datastore ds)
java.lang.String[]	refreshBatchUpdate(java.lang.String key) 刷新批量更新
java.lang.String[]	replaceObject(java.lang.Object obj, boolean commit)
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 isCache)
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) 带参数查询数据集
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) 查询对象
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 forceDisconnect) 设置定时检查的间隔时间参数
boolean	setConnection(java.sql.Connection conn) 对于外部传入Connection连接的情况，必须设置
void	setConnectState(boolean isConnected) 设置连接是否已经建立
void	setInitClassInfo(java.lang.String initClassInfo) 设置初始化实例类 主要用于日志输出
void	setJDBCParam(java.lang.String driver, java.lang.String url, java.lang.String user, java.lang.String password) 设置配置的连接信息
void	setParam(java.lang.String key, java.lang.String value)
void	setQueryTimeout(int queryTimeout) 设置查询超时时间，0表示无限制
void	setUpdateSilence(boolean isUpdateSilence) 设置此连接是否为安静模式，即执行update时不会通知缓存等事件
void	setWriteEnable(boolean enable) 设置DC日志
java.lang.String[]	updateByParams2(java.lang.String sql, java.util.List<java.lang.String> colsTypeList, java.util.List<java.lang.Object> objList, boolean commit) 用参数的方式更新数据库
void	watcherRetrieveFinish(DCWatcher watcher, java.lang.String key, Datastore ds) 查询结束通知观察者

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

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

从接口继承的方法 com.sh.javax.DataCenter

addObject, addObject, beginBatchUpdateByParams, beginBatchUpdateByParams, commit, connect, connect, disconnect, disconnect, getCacheDcType, getDBType, getDriverName, getJDBCPassword, getJDBCUrl, getJDBCUserId, getNewConnection, isExDataCenter, isMainDataCenter, isReportDataCenter, replaceObject, retrieve, retrieve, retrieve, retrieve, retrieveByParams, retrieveByParams, retrieveByParams, retrieveByParams, retrieveByStoreProc, retrieveByStoreProc, retrieveListByStoreProc, retrieveObj, retrieveObj, retrieveObjByParams, retrieveObjByParams, retrieveObjByParams, retrieveObjList, retrieveObjList, retrieveObjList, retrieveObjList, retrieveObjList, rollback, setAutoCommit, setConfig, setConfig, update, update, update, updateByParams, updateByParams, updateByParams, updateByParams, updateByParams, updateByParams, updateByStoreProc, updateByStoreProc, updateByStoreProc, updateByStoreProc, updateByStoreProc, updateByStoreProc, updateByStoreProc, updateObject, updateObject

字段详细资料

POOL_CONN

public static final java.lang.String POOL_CONN

另请参阅:

常量字段值

CONFIG_CONN

public static final java.lang.String CONFIG_CONN

另请参阅:

常量字段值

LOCAL_CONN

public static final java.lang.String LOCAL_CONN

另请参阅:

常量字段值

External_CONN

public static final java.lang.String External_CONN

另请参阅:

常量字段值

UNDEFINE

public static final int UNDEFINE

另请参阅:

常量字段值

SH_POOL

public static final int SH_POOL

另请参阅:

常量字段值

STRUTS_POOL

public static final int STRUTS_POOL

另请参阅:

常量字段值

TOMCAT_POOL

public static final int TOMCAT_POOL

另请参阅:

常量字段值

WEBLOGIC_POOL

public static final int WEBLOGIC_POOL

另请参阅:

常量字段值

SH_BASIC_POOL

public static final int SH_BASIC_POOL

另请参阅:

常量字段值

SH_DRUID

public static final int SH_DRUID

另请参阅:

常量字段值

External

public static final int External

另请参阅:

常量字段值

writeLogFlag

public static boolean writeLogFlag

构造器详细资料

DataCenterBase

public DataCenterBase()

方法详细资料

setParam

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

指定者:

setParam 在接口中 DataCenter

getParam

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

指定者:

getParam 在接口中 DataCenter

isExecute

public boolean isExecute()

是否正在执行

指定者:

isExecute 在接口中 DataCenter

返回:

true|false

isTooLongIdle

public boolean isTooLongIdle(long idleTimeout)

判断是否空闲太久

指定者:

isTooLongIdle 在接口中 DataCenter

参数:

idleTimeout - 空闲超时时长

返回:

boolean true|false

getIdleTime

public long getIdleTime()

获取空闲时间

指定者:

getIdleTime 在接口中 DataCenter

返回:

空闲时长，单位：毫秒

getLastExecuteSql

public java.lang.String getLastExecuteSql()

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

指定者:

getLastExecuteSql 在接口中 DataCenter

返回:

String

checkRetrieveWatcher

public DCWatcher checkRetrieveWatcher(java.lang.String key)

查看是否观察者

参数:

key - String

返回:

DCWatcher

watcherRetrieveFinish

public void watcherRetrieveFinish(DCWatcher watcher,
                                  java.lang.String key,
                                  Datastore ds)

查询结束通知观察者

参数:

watcher - DCWatcher

key - String

ds - Datastore

beginStatement

public void beginStatement(java.sql.Statement statement)

finishStatement

public void finishStatement(java.sql.Statement statement)

closeStatement

public void closeStatement(java.sql.Statement statement)

setCheckTimerSchedule

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

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

指定者:

setCheckTimerSchedule 在接口中 DataCenter

参数:

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

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

setCheckTimerSchedule

public void setCheckTimerSchedule(long delay,
                                  boolean forceDisconnect)

从接口复制的说明: DataCenter

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

指定者:

setCheckTimerSchedule 在接口中 DataCenter

参数:

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

setCheckTimerSchedule

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

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

指定者:

setCheckTimerSchedule 在接口中 DataCenter

参数:

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

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

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

getLastException

public java.lang.Exception getLastException()

指定者:

getLastException 在接口中 DataCenter

setConnection

public boolean setConnection(java.sql.Connection conn)

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

指定者:

setConnection 在接口中 DataCenter

参数:

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

返回:

boolean

getConnection

public java.sql.Connection getConnection()

获取连接

指定者:

getConnection 在接口中 DataCenter

返回:

Connection 连接对象

setAutoGetGeneratedKey

public void setAutoGetGeneratedKey(boolean getGeneratedKeys)

设置自获取序列号

指定者:

setAutoGetGeneratedKey 在接口中 DataCenter

参数:

getGeneratedKeys - boolean

getAutoGeneratedKey

public int getAutoGeneratedKey()

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

指定者:

getAutoGeneratedKey 在接口中 DataCenter

返回:

自增长值

getAutoGeneratedKeyStr

public java.lang.String getAutoGeneratedKeyStr()

从接口复制的说明: DataCenter

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

指定者:

getAutoGeneratedKeyStr 在接口中 DataCenter

返回:

自增长键值

hasConnected

public boolean hasConnected()

是否已经建立连接

指定者:

hasConnected 在接口中 DataCenter

返回:

boolean

setConnectState

public void setConnectState(boolean isConnected)

设置连接是否已经建立

参数:

isConnected - boolean

isValid

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

判断连接是否有效

指定者:

isValid 在接口中 DataCenter

参数:

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

返回:

true 有效 false 无效

抛出:

java.lang.Exception - Exception

isValid

public boolean isValid()

判断连接是否有效,默认等待验证连接秒数：5s

指定者:

isValid 在接口中 DataCenter

返回:

true 有效 false 无效

checkValidAndReset

public boolean checkValidAndReset()

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

指定者:

checkValidAndReset 在接口中 DataCenter

返回:

boolean

isClosed

public boolean isClosed()
                 throws java.lang.Exception

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

指定者:

isClosed 在接口中 DataCenter

返回:

true 已关闭 false 未关闭

抛出:

java.lang.Exception - Exception

setQueryTimeout

public void setQueryTimeout(int queryTimeout)

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

指定者:

setQueryTimeout 在接口中 DataCenter

参数:

queryTimeout - 超时时长 单位：秒

getQueryTimeout

public int getQueryTimeout()

获取查询超时时长

指定者:

getQueryTimeout 在接口中 DataCenter

返回:

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

setWriteEnable

public void setWriteEnable(boolean enable)

设置DC日志

指定者:

setWriteEnable 在接口中 DataCenter

参数:

enable - true|false

getWriteEnable

public boolean getWriteEnable()

是否记录DC日志标志

指定者:

getWriteEnable 在接口中 DataCenter

返回:

boolean

setInitClassInfo

public void setInitClassInfo(java.lang.String initClassInfo)

设置初始化实例类 主要用于日志输出

指定者:

setInitClassInfo 在接口中 DataCenter

参数:

initClassInfo - 实例化类信息描述

getClassInfo

public java.lang.String getClassInfo()

获取初始化实例类信息

返回:

String

getDcType

public java.lang.String getDcType()

DC类型

返回:

连接类型

printLog

public java.lang.String printLog()

指定者:

printLog 在接口中 DataCenter

printLog

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

指定者:

printLog 在接口中 DataCenter

printLog

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

指定者:

printLog 在接口中 DataCenter

printLog

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

指定者:

printLog 在接口中 DataCenter

convertRsToDs

public Datastore convertRsToDs(java.sql.ResultSet rs,
                               int start,
                               int end)

将JDBC数据集转化称Datastore

参数:

rs - JDBC数据集

start - 起始行,小于1时设置成1

end - 结束行，小于1或者大于最大行数的时候设置成最大行

返回:

Datastore

convertRsToDs

public Datastore convertRsToDs(java.sql.ResultSet rs,
                               java.lang.String sql,
                               java.lang.String[] colsType,
                               java.lang.Object[] obj,
                               long startTime)

将整个数据集都转化称Datastore

参数:

rs - JDBC数据集

sql - 执行SQL

colsType - 参数类型

obj - 参数值

startTime - 开始时间

返回:

Datastore

getExecutionLen

public long getExecutionLen()

最后一次执行时长

指定者:

getExecutionLen 在接口中 DataCenter

返回:

执行时长，单位：ms

addBatch

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

添加批量操作

指定者:

addBatch 在接口中 DataCenter

参数:

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

obj - 参数值

返回:

{true|false,|错误信息}

refreshBatchUpdate

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

刷新批量更新

指定者:

refreshBatchUpdate 在接口中 DataCenter

参数:

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

返回:

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

endBatchUpdateByParams

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

结束批量更新操作

指定者:

endBatchUpdateByParams 在接口中 DataCenter

参数:

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

返回:

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

endBatchUpdateByParams

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

结束批量更新操作

指定者:

endBatchUpdateByParams 在接口中 DataCenter

参数:

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

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

返回:

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

retrieveByParams2

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

指定者:

retrieveByParams2 在接口中 DataCenter

retrieveByParams2

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

指定者:

retrieveByParams2 在接口中 DataCenter

retrieveByParams2

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

从接口复制的说明: DataCenter

带参数查询数据集

指定者:

retrieveByParams2 在接口中 DataCenter

参数:

sql - 查询SQL

colsTypeList - 参数类型数组

objList - 参数值数组

返回:

查询数据集

retrieveByParams2

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

带参数查询数据集

指定者:

retrieveByParams2 在接口中 DataCenter

参数:

sql - 查询SQL

colsTypeList - 参数类型数组

objList - 参数值数组

cacheFlag - 缓存标志

返回:

查询数据集

retrieveObjByParams2

public 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

查询对象

指定者:

retrieveObjByParams2 在接口中 DataCenter

参数:

sql - SQL语句

queryObj - 带注释的PO对象

colsTypeList - 参数类型

colsValueList - 参数值

返回:

查询对象

抛出:

java.lang.Exception - 查询异常

updateByParams2

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

用参数的方式更新数据库

指定者:

updateByParams2 在接口中 DataCenter

参数:

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

colsTypeList - 参数类型

objList - 参数值数组

commit - 是否提交

返回:

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

checkAndInitCache

public void checkAndInitCache()

getDsCacheRedis

public DSCacheRedis getDsCacheRedis()

从接口复制的说明: DataCenter

获取redis

指定者:

getDsCacheRedis 在接口中 DataCenter

返回:

DSCacheRedis

processKey

public java.lang.String processKey(java.lang.String sql,
                                   java.lang.String key,
                                   java.lang.String[] colsType,
                                   java.lang.Object[] obj)

getCacheDs

public Datastore getCacheDs(java.lang.String key)

putCacheDs

public void putCacheDs(java.lang.String key,
                       Datastore ds)

closeCache

public void closeCache()

close

public void close()

getConnectStartTime

public long getConnectStartTime()

isUpdateSilence

public boolean isUpdateSilence()

setUpdateSilence

public void setUpdateSilence(boolean isUpdateSilence)

从接口复制的说明: DataCenter

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

指定者:

setUpdateSilence 在接口中 DataCenter

参数:

isUpdateSilence - 开头

replaceObject

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

指定者:

replaceObject 在接口中 DataCenter

createUpdateBuilder

public SqlUpdateBuilder createUpdateBuilder()

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

指定者:

createUpdateBuilder 在接口中 DataCenter

返回:

createQueryBuilder

public SqlBuilder createQueryBuilder()

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

指定者:

createQueryBuilder 在接口中 DataCenter

返回:

createColsTypeByValue

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

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

指定者:

createColsTypeByValue 在接口中 DataCenter

参数:

value -

返回:

initExternalDataSource

public static void initExternalDataSource(javax.sql.DataSource datasource,
                                          java.lang.Class<?> clazz)

初始化外部连接

参数:

datasource -

clazz -

setJDBCParam

public void setJDBCParam(java.lang.String driver,
                         java.lang.String url,
                         java.lang.String user,
                         java.lang.String password)

设置配置的连接信息

参数:

driver -

url -

user -

password -