com.sh.javax

类 MainSlaveDataCenter

java.lang.Object

com.sh.javax.DataCenterBase

com.sh.javax.MainSlaveDataCenter

所有已实现的接口:

DataCenter

public class MainSlaveDataCenter
extends DataCenterBase

Description: 数据中心对象，其中封装了JDBC数据操作的细节,只读。

Title:首亨软件

Company：首亨软件(重庆)有限公司

版本:

1.0

作者:

江兴春 Date: 2009-10-10

字段概要

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

CONFIG_CONN, External, External_CONN, LOCAL_CONN, POOL_CONN, 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

构造器概要

构造器

构造器和说明
MainSlaveDataCenter() 默认构造函数，数据中心直接读取配置文件的信息进行连接
MainSlaveDataCenter(javax.sql.DataSource dataSource) 已过时。
MainSlaveDataCenter(java.lang.String connType) 已过时。
MainSlaveDataCenter(java.lang.String connType, int poolType) 已过时。

方法概要

限定符和类型	方法和说明
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) 开始进行批量更新,目前只针对带参数类型
java.lang.String[]	beginBatchUpdateByParams(java.lang.String sql, java.lang.String[] colsType, int refreshCount) 开始进行批量更新,目前只针对带参数类型
void	commit() 提交事务
java.sql.Connection	connect() 连接默认数据库，数据库的配置在connection.cfg中
java.sql.Connection	connect(java.lang.String sector) 连接配置文件中指定的段,这个只对connType=config有效
void	disconnect() 断开默认的数据库连接
void	disconnect(java.sql.Connection con) 断开指定的连接
java.lang.String	getCacheDcType() 获取缓存使用的连接类型
static java.util.Map<java.lang.String,java.lang.String>	getDBInfo()
java.lang.String	getDBType() 获取当前连接的数据类型
java.lang.String	getDriverName()
java.lang.String	getJDBCPassword()
java.lang.String	getJDBCUrl()
java.lang.String	getJDBCUserId()
java.sql.Connection	getNewConnection() 获取新的连接，不从连接池中取
java.sql.ResultSet	getResultSet(java.lang.String sql) 根据SQL获取结果集
java.sql.ResultSet	getResultSet(java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj) 通过参数方式获取结果集
java.sql.ResultSet	getResultSetByStoreProc(java.lang.String procName, java.lang.String[] colsType, java.lang.Object[] obj) 通过参数方式获取结果集
boolean	isExDataCenter() 是否主数据库连接
boolean	isMainDataCenter() 是否主数据库连接
boolean	isReportDataCenter() 是否主数据库连接
static void	main(java.lang.String[] args)
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	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.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	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) 已过时。
void	setConnType(java.lang.String connType) 已过时。
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, int start, int end, 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[]	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) 更新表数据

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

addBatch, beginStatement, checkAndInitCache, checkRetrieveWatcher, checkValidAndReset, close, closeCache, closeStatement, convertRsToDs, convertRsToDs, createColsTypeByValue, createQueryBuilder, createUpdateBuilder, endBatchUpdateByParams, endBatchUpdateByParams, finishStatement, getAutoGeneratedKey, getAutoGeneratedKeyStr, getCacheDs, getClassInfo, getConnection, getConnectStartTime, getDcType, getDsCacheRedis, getExecutionLen, getIdleTime, getLastException, getLastExecuteSql, getParam, getQueryTimeout, getWriteEnable, hasConnected, initExternalDataSource, isClosed, isExecute, isTooLongIdle, isUpdateSilence, isValid, isValid, printLog, printLog, printLog, printLog, processKey, putCacheDs, refreshBatchUpdate, replaceObject, retrieveByParams2, retrieveByParams2, retrieveByParams2, retrieveByParams2, retrieveObjByParams2, setAutoGetGeneratedKey, setCheckTimerSchedule, setCheckTimerSchedule, setCheckTimerSchedule, setConnection, setConnectState, setInitClassInfo, setJDBCParam, setParam, setQueryTimeout, setUpdateSilence, setWriteEnable, updateByParams2, watcherRetrieveFinish

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

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

构造器详细资料

MainSlaveDataCenter

public MainSlaveDataCenter()

默认构造函数，数据中心直接读取配置文件的信息进行连接

MainSlaveDataCenter

public MainSlaveDataCenter(java.lang.String connType,
                           int poolType)

已过时。

构造函数，设置DataCenter选用何种连接池

参数:

connType - int 连接池类型

poolType - int

MainSlaveDataCenter

public MainSlaveDataCenter(java.lang.String connType)

已过时。

构造函数，设置DataCenter选用何种连接池,DataCenter.LOCAL_CONN时，setConfig必须赋值

参数:

connType - int 连接池类型

MainSlaveDataCenter

public MainSlaveDataCenter(javax.sql.DataSource dataSource)

已过时。

传dataSource对象的构造函数

参数:

dataSource - dataSource对象

方法详细资料

getCacheDcType

public java.lang.String getCacheDcType()

从接口复制的说明: DataCenter

获取缓存使用的连接类型

返回:

String

getDBType

public java.lang.String getDBType()

从接口复制的说明: DataCenter

获取当前连接的数据类型

返回:

String

isMainDataCenter

public boolean isMainDataCenter()

从接口复制的说明: DataCenter

是否主数据库连接

返回:

boolean

isReportDataCenter

public boolean isReportDataCenter()

从接口复制的说明: DataCenter

是否主数据库连接

返回:

boolean

isExDataCenter

public boolean isExDataCenter()

从接口复制的说明: DataCenter

是否主数据库连接

返回:

boolean

getDriverName

public java.lang.String getDriverName()

getJDBCUrl

public java.lang.String getJDBCUrl()

getJDBCUserId

public java.lang.String getJDBCUserId()

getJDBCPassword

public java.lang.String getJDBCPassword()

getDBInfo

public static java.util.Map<java.lang.String,java.lang.String> getDBInfo()

connect

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

连接默认数据库，数据库的配置在connection.cfg中

返回:

数据库连接

抛出:

java.lang.Exception - Exception

connect

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

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

参数:

sector - 段名称

返回:

数据库连接

抛出:

java.lang.Exception - Exception

getNewConnection

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

获取新的连接，不从连接池中取

返回:

Connection

抛出:

java.lang.Exception - Exception

setConfig

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

设置数据连接属性

参数:

JDBCDriver - String

JDBCConnectionURL - String

userID - String

password - String

setConfig

public 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 - String

JDBCConnectionURL - String

userID - String

password - String

maxActive - int

maxIdle - int

maxWait - int

disconnect

public void disconnect(java.sql.Connection con)

断开指定的连接

参数:

con - 数据库连接

disconnect

public void disconnect()

断开默认的数据库连接

getResultSet

public java.sql.ResultSet getResultSet(java.lang.String sql)

根据SQL获取结果集

参数:

sql - 查询语句

返回:

结果集

getResultSet

public java.sql.ResultSet getResultSet(java.lang.String sql,
                                       java.lang.String[] colsType,
                                       java.lang.Object[] obj)

通过参数方式获取结果集

参数:

sql - 查询语句

colsType - 参数类型

obj - 参数值

返回:

结果集

getResultSetByStoreProc

public java.sql.ResultSet getResultSetByStoreProc(java.lang.String procName,
                                                  java.lang.String[] colsType,
                                                  java.lang.Object[] obj)

通过参数方式获取结果集

参数:

procName - 存储过程名称

colsType - 参数类型

obj - 参数值

返回:

结果集

retrieve

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

从指定的数据中检索数据

参数:

con - 数据库连接

sql - 查询语句

cacheFlag - 是否使用缓存

返回:

Datastore数据集

抛出:

java.lang.Exception - Exception

retrieve

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

从指定的数据中检索数据 不使用缓存

参数:

con - 数据库连接

sql - 查询语句

返回:

Datastore数据集

抛出:

java.lang.Exception - Exception

retrieve

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

从默认的数据库中获取数据 默认不使用缓存

参数:

sql - String

返回:

Datastore

抛出:

java.lang.Exception - Exception

retrieve

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

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

参数:

sql - String

cacheFlag - 是否使用缓存

返回:

Datastore

抛出:

java.lang.Exception - Exception

retrieveObj

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

通过对象查找

参数:

sql - String

queryObj - Class

返回:

Object

抛出:

java.lang.Exception - Exception

retrieveObj

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

查询对象 不使用缓存

参数:

sql - SQL语句

queryObj - 带注释的PO对象

cacheFlag - 是否使用缓存

返回:

查询对象

抛出:

java.lang.Exception - Exception

retrieveObjByParams

public 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 - Exception

retrieveObjByParams

public 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

public 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语句

colsType - 参数类型

colsValue - 参数值

queryObj - 带注释的PO对象

cacheFlag - 是否使用缓存

返回:

查询对象

抛出:

java.lang.Exception - Exception

retrieveObjList

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

不带参数的多数据集查询

参数:

sql - SQL

queryObj - 查询对象

返回:

List

抛出:

java.lang.Exception - Exception

retrieveObjList

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

不带参数的多数据集查询

参数:

sql - SQL

queryObj - 查询对象

cacheFlag - 是否使用缓存

返回:

List

抛出:

java.lang.Exception - Exception

retrieveObjList

public 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 - 查询对象

返回:

List

抛出:

java.lang.Exception - Exception

retrieveObjList

public 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

public 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 - 是否使用缓存

返回:

List

抛出:

java.lang.Exception - Exception

update

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

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

参数:

con - 数据库连接

sql - 更新语句

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

返回:

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

update

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

执行SQL并提交数据

参数:

sql - 修改数据库的语句

返回:

同上

updateObject

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

更新表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

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

返回:

String[]

抛出:

java.lang.Exception - Exception

updateObject

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

更新表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

返回:

String[]

抛出:

java.lang.Exception - Exception

addObject

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

添加表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

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

返回:

String[]

replaceObject

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

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

参数:

obj - 实例对象

commit - 是否自动提交事务

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

返回:

String[]

addObject

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

添加表数据

参数:

obj - 实例对象

commit - 是否自动提交事务

返回:

String[]

抛出:

java.lang.Exception - Exception

update

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

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

参数:

sql - 更新语句

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

返回:

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

commit

public void commit()

提交事务

rollback

public void rollback()

事务回滚

updateByParams

public 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 - 是否提交

返回:

同上

updateByParams

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

用参数的方式更新数据库

参数:

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

colsType - 参数类型

obj - 参数值数组

返回:

同上

updateByParams

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

用参数的方式更新数据库

参数:

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

obj - 参数值数组

返回:

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

updateByParams

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

用参数的方式更新数据库

参数:

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

colsType - 参数类型

obj - 参数值数组

commit - 是否提交

返回:

同上

updateByParams

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

用参数的方式更新数据库

参数:

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

obj - 参数值数组

commit - 是否提交

返回:

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

updateByParams

public 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 - 是否提交

返回:

同上

updateByParams

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

用参数的方式更新数据库

参数:

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

colsType - 参数类型

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

commit - 是否提交

返回:

同上

updateByStoreProc

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

updateByStoreProc

public 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 - 是否提交

返回:

同上

updateByStoreProc

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

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

返回:

同上

updateByStoreProc

public 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

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

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

commit - 是否提交

返回:

同上

updateByStoreProc

public 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 - 是否提交

返回:

同上

updateByStoreProc

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

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

参数:

procName - 存储过程名称

colsType - 参数类型数组

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

commit - 是否提交

返回:

同上

retrieveByParams

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

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

参数:

sql - SQL

colsType - 参数类型数组

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

返回:

同上

retrieveByParams

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

带参数查询数据集

参数:

sql - 查询SQL

obj - 参数值数组

返回:

查询数据集

retrieveByParams

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

带参数查询数据集

参数:

sql - 查询SQL

obj - 参数值数组

cacheFlag - 是否使用缓存

返回:

查询数据集

retrieveByParams

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

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

参数:

sql - SQL

colsType - 参数类型数组

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

cacheFlag - 使用缓存

返回:

同上

retrieveByStoreProc

public Datastore retrieveByStoreProc(java.lang.String procName)

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

参数:

procName - 存储过程名称 ,存储过程需要返回游标类型

返回:

数据集Datastore

retrieveByStoreProc

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

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

参数:

procName - 存储过程名称,存储过程需要最后一个参数需要返回游标类型

colsType - 参数类型数组,忽略最后一个返回游标类型的参数

obj - 参数值数组，多行数据,忽略最后一个返回游标类型的参数

返回:

数据集Datastore

retrieveListByStoreProc

public 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

setAutoCommit

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

设置DataCenter是否自动提交

参数:

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

抛出:

java.sql.SQLException - SQLException

setConnType

public void setConnType(java.lang.String connType)

已过时。

设置获取数据库连接的方式

参数:

connType - String strutsPool/config

beginBatchUpdateByParams

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

开始进行批量更新,目前只针对带参数类型

参数:

sql - 执行SQL

colsType - SQL参数类型

返回:

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

beginBatchUpdateByParams

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

开始进行批量更新,目前只针对带参数类型

参数:

sql - 执行SQL

colsType - SQL参数类型

refreshCount - 批量队列到达该值时刷新

返回:

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

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

抛出:

java.lang.Exception