org.redkale.source

类 DataJdbcSource

java.lang.Object

org.redkale.service.AbstractService

org.redkale.source.DataSqlSource<Connection>

org.redkale.source.DataJdbcSource

所有已实现的接口:

AutoCloseable, Function<Class,EntityInfo>, Service, DataCacheListener, DataSource, Resourcable

@Local
 @AutoLoad(value=false)
 @ResourceType(value=DataSource.class)
public class DataJdbcSource
extends DataSqlSource<Connection>

DataSource的JDBC实现类

详情见: https://redkale.org

作者:

zhangjx

字段概要

从类继承的字段 org.redkale.source.DataSqlSource

bufferPool, cacheForbidden, cacheListener, executor, FLIPPER_ONE, fullloader, futureCompleteConsumer, logger, name, persistxml, readPool, threads, writePool

构造器概要

构造器

构造器和说明
DataJdbcSource(String unitName, URL persistxml, Properties readprop, Properties writeprop)

方法概要

限定符和类型	方法和说明
protected <T> PreparedStatement	createInsertPreparedStatement(Connection conn, String sql, EntityInfo<T> info, T... values)
protected PoolSource<Connection>	createPoolSource(DataSource source, String rwtype, ArrayBlockingQueue queue, Semaphore semaphore, Properties prop)
protected <T> CompletableFuture<Integer>	deleteDB(EntityInfo<T> info, Flipper flipper, String sql)
int[]	directExecute(String... sqls) 直接本地执行SQL语句进行增删改操作，远程模式不可用 通常用于复杂的更新操作
int	directExecute(String sql) 直接本地执行SQL语句进行增删改操作，远程模式不可用 通常用于复杂的更新操作
<V> V	directQuery(String sql, Function<ResultSet,V> handler) 直接本地执行SQL语句进行查询，远程模式不可用 通常用于复杂的关联查询
protected <T> CompletableFuture<Boolean>	existsDB(EntityInfo<T> info, String sql, boolean onlypk)
protected <T> CompletableFuture<Serializable>	findColumnDB(EntityInfo<T> info, String sql, boolean onlypk, String column, Serializable defValue)
protected <T> CompletableFuture<T>	findDB(EntityInfo<T> info, String sql, boolean onlypk, SelectColumn selects)
protected <T,N extends Number> CompletableFuture<Map<String,N>>	getNumberMapDB(EntityInfo<T> info, String sql, FilterFuncColumn... columns)
protected <T> CompletableFuture<Number>	getNumberResultDB(EntityInfo<T> info, String sql, Number defVal, String column)
protected <T> CompletableFuture<Integer>	insertDB(EntityInfo<T> info, T... values)
protected boolean	isAsync()
protected String	prepareParamSign(int index)
protected <T,K extends Serializable,N extends Number> CompletableFuture<Map<K,N>>	queryColumnMapDB(EntityInfo<T> info, String sql, String keyColumn)
protected <T> CompletableFuture<Sheet<T>>	querySheetDB(EntityInfo<T> info, boolean needtotal, SelectColumn selects, Flipper flipper, FilterNode node)
protected <T> CompletableFuture<Integer>	updateDB(EntityInfo<T> info, Flipper flipper, String sql, boolean prepared, Object... params)
protected <T> CompletableFuture<Integer>	updateDB(EntityInfo<T> info, T... values)

从类继承的方法 org.redkale.source.DataSqlSource

apply, checkEntity, close, createSQLExpress, createSQLJoin, createSQLOrderby, delete, delete, delete, delete, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteCache, deleteCache, deleteCache, deleteCompose, deleteCompose, destroy, exists, exists, exists, existsAsync, existsAsync, existsAsync, existsCompose, existsCompose, find, find, find, find, find, find, find, findAsync, findAsync, findAsync, findAsync, findAsync, findAsync, findAsync, findColumn, findColumn, findColumn, findColumn, findColumn, findColumn, findColumnAsync, findColumnAsync, findColumnAsync, findColumnAsync, findColumnAsync, findColumnAsync, findColumnCompose, findColumnCompose, findCompose, findCompose, getExecutor, getJoinTabalis, getNumberMap, getNumberMap, getNumberMap, getNumberMapAsync, getNumberMapAsync, getNumberMapAsync, getNumberMapCompose, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultCompose, getReadPoolSource, getType, getWritePoolSource, infoGetValue, init, insert, insertAsync, insertCache, insertCache, isOnlyCache, loadEntityInfo, multisplit, queryColumnList, queryColumnList, queryColumnList, queryColumnList, queryColumnList, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapCompose, queryColumnSet, queryColumnSet, queryColumnSet, queryColumnSetAsync, queryColumnSetAsync, queryColumnSetAsync, queryColumnSheet, queryColumnSheet, queryColumnSheetAsync, queryColumnSheetAsync, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryMap, queryMap, queryMap, queryMap, queryMap, queryMap, queryMapAsync, queryMapAsync, queryMapAsync, queryMapAsync, queryMapAsync, queryMapAsync, querySheet, querySheet, querySheet, querySheet, querySheetAsync, querySheetAsync, querySheetAsync, querySheetAsync, querySheetCompose, refreshCache, reloadCache, resourceName, update, updateAsync, updateCache, updateCache, updateCache, updateCache, updateCache, updateCache, updateCache, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnCompose, updateColumnCompose, updateColumnCompose, updateColumnCompose, updateColumnCompose

从类继承的方法 org.redkale.service.AbstractService

runAsync

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

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

从接口继承的方法 java.util.function.Function

andThen, compose, identity

构造器详细资料

DataJdbcSource

public DataJdbcSource(String unitName,
                      URL persistxml,
                      Properties readprop,
                      Properties writeprop)

方法详细资料

prepareParamSign

protected final String prepareParamSign(int index)

指定者:

prepareParamSign 在类中 DataSqlSource<Connection>

isAsync

protected final boolean isAsync()

指定者:

isAsync 在类中 DataSqlSource<Connection>

createPoolSource

protected PoolSource<Connection> createPoolSource(DataSource source,
                                                  String rwtype,
                                                  ArrayBlockingQueue queue,
                                                  Semaphore semaphore,
                                                  Properties prop)

指定者:

createPoolSource 在类中 DataSqlSource<Connection>

insertDB

protected <T> CompletableFuture<Integer> insertDB(EntityInfo<T> info,
                                                  T... values)

指定者:

insertDB 在类中 DataSqlSource<Connection>

createInsertPreparedStatement

protected <T> PreparedStatement createInsertPreparedStatement(Connection conn,
                                                              String sql,
                                                              EntityInfo<T> info,
                                                              T... values)
                                                       throws SQLException

抛出:

SQLException

deleteDB

protected <T> CompletableFuture<Integer> deleteDB(EntityInfo<T> info,
                                                  Flipper flipper,
                                                  String sql)

指定者:

deleteDB 在类中 DataSqlSource<Connection>

updateDB

protected <T> CompletableFuture<Integer> updateDB(EntityInfo<T> info,
                                                  T... values)

指定者:

updateDB 在类中 DataSqlSource<Connection>

updateDB

protected <T> CompletableFuture<Integer> updateDB(EntityInfo<T> info,
                                                  Flipper flipper,
                                                  String sql,
                                                  boolean prepared,
                                                  Object... params)

指定者:

updateDB 在类中 DataSqlSource<Connection>

getNumberMapDB

protected <T,N extends Number> CompletableFuture<Map<String,N>> getNumberMapDB(EntityInfo<T> info,
                                                                               String sql,
                                                                               FilterFuncColumn... columns)

指定者:

getNumberMapDB 在类中 DataSqlSource<Connection>

getNumberResultDB

protected <T> CompletableFuture<Number> getNumberResultDB(EntityInfo<T> info,
                                                          String sql,
                                                          Number defVal,
                                                          String column)

指定者:

getNumberResultDB 在类中 DataSqlSource<Connection>

queryColumnMapDB

protected <T,K extends Serializable,N extends Number> CompletableFuture<Map<K,N>> queryColumnMapDB(EntityInfo<T> info,
                                                                                                   String sql,
                                                                                                   String keyColumn)

指定者:

queryColumnMapDB 在类中 DataSqlSource<Connection>

findDB

protected <T> CompletableFuture<T> findDB(EntityInfo<T> info,
                                          String sql,
                                          boolean onlypk,
                                          SelectColumn selects)

指定者:

findDB 在类中 DataSqlSource<Connection>

findColumnDB

protected <T> CompletableFuture<Serializable> findColumnDB(EntityInfo<T> info,
                                                           String sql,
                                                           boolean onlypk,
                                                           String column,
                                                           Serializable defValue)

指定者:

findColumnDB 在类中 DataSqlSource<Connection>

existsDB

protected <T> CompletableFuture<Boolean> existsDB(EntityInfo<T> info,
                                                  String sql,
                                                  boolean onlypk)

指定者:

existsDB 在类中 DataSqlSource<Connection>

querySheetDB

protected <T> CompletableFuture<Sheet<T>> querySheetDB(EntityInfo<T> info,
                                                       boolean needtotal,
                                                       SelectColumn selects,
                                                       Flipper flipper,
                                                       FilterNode node)

指定者:

querySheetDB 在类中 DataSqlSource<Connection>

directExecute

@Local
public int directExecute(String sql)

直接本地执行SQL语句进行增删改操作，远程模式不可用
通常用于复杂的更新操作

指定者:

directExecute 在类中 DataSqlSource<Connection>

参数:

sql - SQL语句

返回:

结果数组

directExecute

@Local
public int[] directExecute(String... sqls)

直接本地执行SQL语句进行增删改操作，远程模式不可用
通常用于复杂的更新操作

指定者:

directExecute 在类中 DataSqlSource<Connection>

参数:

sqls - SQL语句

返回:

结果数组

directQuery

@Local
public <V> V directQuery(String sql,
                                Function<ResultSet,V> handler)

直接本地执行SQL语句进行查询，远程模式不可用
通常用于复杂的关联查询

指定者:

directQuery 在类中 DataSqlSource<Connection>

类型参数:

V - 泛型

参数:

sql - SQL语句

handler - 回调函数

返回:

结果