com.sh.javax

类 JDBCDataCenter

java.lang.Object

com.sh.javax.DataCenterBase

com.sh.javax.JDBCDataCenter

所有已实现的接口:

DataCenter

直接已知子类:

AutoCloseableExDataCenter

public class JDBCDataCenter
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

构造器概要

构造器

构造器和说明
JDBCDataCenter() 默认构造函数，数据中心直接读取配置文件的信息进行连接

方法概要

限定符和类型	方法和说明
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() 获取缓存使用的连接类型
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() 是否主数据库连接
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	setCharSet(java.lang.String charSet)
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

构造器详细资料

JDBCDataCenter

public JDBCDataCenter()

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

方法详细资料

getCacheDcType

public java.lang.String getCacheDcType()

从接口复制的说明: DataCenter

获取缓存使用的连接类型

返回:

String

getDBType

public java.lang.String getDBType()

获取数据类型，需要在设置驱动参数之后调用

返回:

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()

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 - 已失效

maxIdle - 已失效

maxWait - 已失效

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

返回:

查询对象

抛出:

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

queryObj - 带注释的PO对象

cacheFlag - 是否使用缓存

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

colsValue - String数据

返回:

查询对象

抛出:

java.lang.Exception - Exception

retrieveObjList

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

不带参数的多数据集查询

参数:

sql - String

queryObj - Class

返回:

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

queryObj - Class

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

colsType - 参数值类型

colsValue - 参数值

queryObj - 查询对象class

返回:

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

colsType - 参数类型

colsValue - 参数值

queryObj - 查询对象class

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

返回:

{true|false,""}

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 - 参数值数组，多行数据

返回:

Datastore

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

返回:

Datastore

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,操作关键字(后续操作会用到)|错误信息}

setCharSet

public void setCharSet(java.lang.String charSet)