public interface RDSAPI
支持日志和审计的操作:update、query、getXXX、batch、execute
DBSql
限定符和类型 | 方法和说明 |
---|---|
int[] |
batch(java.lang.String[] sql)
一个Statement中批量执行多条sql
|
int[] |
batch(java.lang.String sql,
BatchPreparedStatementSetter bss)
一个Statement中批量执行单条sql
|
static void |
close(java.sql.Connection conn) |
static void |
close(java.sql.Connection conn,
java.sql.Statement stmt,
java.sql.ResultSet rset) |
<T> T |
execute(<any> callback)
带数据库连接的回调方法,该方法将自动关闭连接
|
double |
getDouble(java.lang.String sql,
java.lang.Object... args)
查询sql取第一条数据集的第一列double值,如果没有满足要求的数据,返回0d
|
int |
getInt(java.lang.String sql,
java.lang.Object... args)
查询sql取第一条数据集的第一列int值,如果没有满足要求的数据,返回0
|
long |
getLong(java.lang.String sql,
java.lang.Object... args)
查询sql取第一条数据集的第一列long值,如果没有满足要求的数据,返回0
|
RowMap |
getMap(java.lang.String sql,
java.lang.Object... args)
查询sql取第一条数据集,返回列名/列值的Map结构,如果没有满足要求的数据,返回null
|
java.util.List<RowMap> |
getMaps(java.lang.String sql,
java.lang.Object... args) |
<T> T |
getObject(java.lang.String sql,
java.lang.Class<T> type,
java.lang.Object... args)
查询sql取第一条数据集的第一列值,如果没有满足要求的数据,返回null
|
<T> T |
getObject(java.lang.String sql,
RowMapper<T> rowMapper,
java.lang.Object... args)
查询sql取第一条数据集,如果没有满足要求的数据,返回null
|
java.lang.String |
getString(java.lang.String sql,
java.lang.Object... args)
查询sql取第一条数据集的第一列String值,如果没有满足要求的数据,返回空串
|
SUPPLY |
getSupply()
获得当前数据库类型
|
java.sql.Timestamp |
getTimestamp(java.lang.String sql,
java.lang.Object... args)
查询sql取第一条数据集的第一列Timestamp值,如果没有满足要求的数据,返回null
|
java.util.List<PoolTrackModel> |
getTrace()
获得当前CC RDS活动连接对象的跟踪信息,详细堆栈需日志参数开启
|
java.sql.Connection |
open() |
<T> java.util.List<T> |
query(java.lang.String sql,
java.util.Map<java.lang.String,java.lang.Object> paraMap,
RowMapper<T> rowMapper) |
<T> T |
query(java.lang.String sql,
ResultSetExtractor<T> rsh,
java.lang.Object... args)
查询sql,使用rh处理结果数据集,并返回值
|
void |
query(java.lang.String sql,
ResultSetHandler rsh,
java.lang.Object... args)
查询sql,使用rh处理结果数据集,不返回值
|
<T> java.util.List<T> |
query(java.lang.String sql,
RowMapper<T> rowMapper,
java.lang.Object... args)
查询sql,针对数据集每一条数据转换为目标对象
|
void |
setConnectTimeout(java.lang.Integer timeOut) |
void |
setFetchSize(int fetchSize)
设置resultSet每次向数据库取的行数
|
void |
setMaxRows(int maxRows)
设置resultSet最多返回的行数
|
void |
setRdsExecContext(RdsExecAPIContext rdsExecContext)
运行时日志所需参数
|
int |
update(java.lang.String sql,
java.util.Map<java.lang.String,java.lang.Object> paraMap)
具名参数方式执行更新语句,SQL语句中使用英文半角冒号和变量名命名占位符,如:where abc=:abc
|
int |
update(java.lang.String sql,
java.lang.Object... args)
执行一条可含有?
|
java.sql.Connection open() throws AWSDataAccessException
static void close(java.sql.Connection conn)
static void close(java.sql.Connection conn, java.sql.Statement stmt, java.sql.ResultSet rset)
<T> T execute(<any> callback) throws AWSDataAccessException
callback
- 回调函数,不需要关闭连接资源AWSDataAccessException
<T> java.util.List<T> query(java.lang.String sql, RowMapper<T> rowMapper, java.lang.Object... args) throws AWSDataAccessException
sql
- sql语句rowMapper
- 数据集转换对象args
- 参数值AWSDataAccessException
<T> java.util.List<T> query(java.lang.String sql, java.util.Map<java.lang.String,java.lang.Object> paraMap, RowMapper<T> rowMapper) throws AWSDataAccessException
<T> T query(java.lang.String sql, ResultSetExtractor<T> rsh, java.lang.Object... args) throws AWSDataAccessException
void query(java.lang.String sql, ResultSetHandler rsh, java.lang.Object... args) throws AWSDataAccessException
<T> T getObject(java.lang.String sql, RowMapper<T> rowMapper, java.lang.Object... args) throws AWSDataAccessException
<T> T getObject(java.lang.String sql, java.lang.Class<T> type, java.lang.Object... args) throws AWSDataAccessException
type
- 返回type对应的类型,该类型为ResultSet中支持的get类型AWSDataAccessException
RowMap getMap(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
java.util.List<RowMap> getMaps(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
java.lang.String getString(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
int getInt(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
java.sql.Timestamp getTimestamp(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
long getLong(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
double getDouble(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
int update(java.lang.String sql, java.lang.Object... args) throws AWSDataAccessException
int update(java.lang.String sql, java.util.Map<java.lang.String,java.lang.Object> paraMap)
sql
- 带绑定变量的SQL语句,支持INSERT、UPDATE、DELETE、CREATE、ALTER、DROP等语法paraMap
- paraMap - 绑定变量值的Map,key-变量名(区分大小写,建议统一大写);value-变量值int[] batch(java.lang.String[] sql)
int[] batch(java.lang.String sql, BatchPreparedStatementSetter bss)
SUPPLY getSupply() throws AWSDataAccessException
java.util.List<PoolTrackModel> getTrace()
void setFetchSize(int fetchSize)
fetchSize
- 默认值为-1,使用jdbc驱动默认设置Statement.setFetchSize(int)
void setMaxRows(int maxRows)
maxRows
- 默认值为-1,使用jdbc驱动默认设置Statement.setMaxRows(int)
void setRdsExecContext(RdsExecAPIContext rdsExecContext)
void setConnectTimeout(java.lang.Integer timeOut)
Copyright © Actionsoft Co., Ltd. All Rights Reserved.