模块 org.redkale

程序包 org.redkale.source

类 DataJdbcSource

java.lang.Object

org.redkale.service.AbstractService

org.redkale.source.AbstractDataSource

org.redkale.source.AbstractDataSqlSource

org.redkale.source.DataJdbcSource

所有已实现的接口:

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

@Local
@AutoLoad(false)
@ResourceType(DataSource.class)
@SourceType(DataJdbcSource.class)
public class DataJdbcSource
extends AbstractDataSqlSource

DataSource的JDBC实现类

详情见: https://redkale.org

作者:

zhangjx

嵌套类概要

嵌套类

修饰符和类型	类	说明
protected static class	DataJdbcSource.DataJdbcResultSet
protected class	DataJdbcSource.JdbcConnection
protected class	DataJdbcSource.JdbcConnectionPool

从类继承的嵌套类/接口 org.redkale.source.AbstractDataSqlSource

AbstractDataSqlSource.PageCountSql, AbstractDataSqlSource.PrepareInfo<T>, AbstractDataSqlSource.UpdateSqlInfo

从类继承的嵌套类/接口 org.redkale.source.AbstractDataSource

AbstractDataSource.BatchAction, AbstractDataSource.DefaultDataBatch, AbstractDataSource.DeleteBatchAction1, AbstractDataSource.DeleteBatchAction2, AbstractDataSource.DeleteBatchAction3, AbstractDataSource.InsertBatchAction1, AbstractDataSource.RunnableBatchAction, AbstractDataSource.SourceUrlInfo, AbstractDataSource.UpdateBatchAction1, AbstractDataSource.UpdateBatchAction2, AbstractDataSource.UpdateBatchAction3, AbstractDataSource.UpdateBatchAction4

字段概要

字段

修饰符和类型	字段	说明
protected DataJdbcSource.JdbcConnectionPool	readPool
protected DataJdbcSource.JdbcConnectionPool	writePool

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

cacheForbidden, clientAsyncGroup, clientNonBlocking, config, containSQL, dbtype, errorCompleteConsumer, FLIPPER_ONE, fullloader, logger, MAX_RETRYS, nativeSqlParser, notContainSQL, readConfProps, signFunc, slowmsError, slowmsWarn, sortOrderbySqls, sqlFormatter, sqlMonitor, tableCopySQL, tableNotExistSqlstates, workExecutor, writeConfProps

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

name, serialArrayFunc, sourceThreads

构造器概要

构造器

构造器	说明
DataJdbcSource()

方法概要

修饰符和类型	方法	说明
static boolean	acceptsConf(AnyValue conf)
int	batch(DataBatch batch)	增删改的批量操作
CompletableFuture<Integer>	batchAsync(DataBatch batch)	增删改的批量操作
protected <T> int	bindStatementParameters(DataJdbcSource.JdbcConnection conn, PreparedStatement prestmt, EntityInfo<T> info, Attribute<T,Serializable>[] attrs, T entity)
protected List<String>	checkNotExistTables(DataJdbcSource.JdbcConnection conn, String[] tables)
protected List<String>	checkNotExistTablesNoThrows(DataJdbcSource.JdbcConnection conn, String[] tables)
protected <T> int	clearTableDB(EntityInfo<T> info, String[] tables, FilterNode node, String... sqls)
protected <T> CompletableFuture<Integer>	clearTableDBAsync(EntityInfo<T> info, String[] tables, FilterNode node, String... sqls)
void	close()
static DataResultSet	createDataResultSet(EntityInfo info, ResultSet set)
protected <T> int	createTableDB(EntityInfo<T> info, String copyTableSql, Serializable pk, String... sqls)
protected <T> CompletableFuture<Integer>	createTableDBAsync(EntityInfo<T> info, String copyTableSql, Serializable pk, String... sqls)
protected <T> int	deleteDB(EntityInfo<T> info, String[] tables, Flipper flipper, FilterNode node, Map<String,List<Serializable>> pkmap, String... sqls)
protected <T> CompletableFuture<Integer>	deleteDBAsync(EntityInfo<T> info, String[] tables, Flipper flipper, FilterNode node, Map<String,List<Serializable>> pkmap, String... sqls)
void	destroy(AnyValue config)	进程退出时，调用Service销毁 远程模式下该方法会重载成空方法 注意： 在此方法内不能调用MessageClient.sendMessage 方法，因为Application关闭时会先destroy掉MessageClient
int	directExecute(String sql)	已过时。
int[]	directExecute(String... sqls)	已过时。
<V> V	directQuery(String sql, Function<DataResultSet,V> handler)	已过时。
protected <T> int	dropTableDB(EntityInfo<T> info, String[] tables, FilterNode node, String... sqls)
protected <T> CompletableFuture<Integer>	dropTableDBAsync(EntityInfo<T> info, String[] tables, FilterNode node, String... sqls)
protected <T> boolean	existsDB(EntityInfo<T> info, String[] tables, String sql, boolean onlypk, Serializable pk, FilterNode node)
protected <T> CompletableFuture<Boolean>	existsDBAsync(EntityInfo<T> info, String[] tables, String sql, boolean onlypk, Serializable pk, FilterNode node)
protected <T> Serializable	findColumnDB(EntityInfo<T> info, String[] tables, String sql, boolean onlypk, String column, Serializable defValue, Serializable pk, FilterNode node)
protected <T> CompletableFuture<Serializable>	findColumnDBAsync(EntityInfo<T> info, String[] tables, String sql, boolean onlypk, String column, Serializable defValue, Serializable pk, FilterNode node)
protected <T> T	findDB(EntityInfo<T> info, Serializable pk)
protected <T> T	findDB(EntityInfo<T> info, String[] tables, String sql, boolean onlypk, SelectColumn selects, Serializable pk, FilterNode node)
protected <T> CompletableFuture<T>	findDBAsync(EntityInfo<T> info, String[] tables, String sql, boolean onlypk, SelectColumn selects, Serializable pk, FilterNode node)
<D extends Serializable,T> List<T>	findsList(Class<T> clazz, Stream<D> pks)	获取指定主键值的多个记录, 返回列表 等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}
<D extends Serializable,T> CompletableFuture<List<T>>	findsListAsync(Class<T> clazz, Stream<D> pks)	获取指定主键值的多个记录, 返回列表 等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}
protected <T> T	findUnCache(EntityInfo<T> info, SelectColumn selects, Serializable pk)
protected <T> CompletableFuture<T>	findUnCacheAsync(EntityInfo<T> info, SelectColumn selects, Serializable pk)
protected <T,N extends Number> Map<String,N>	getNumberMapDB(EntityInfo<T> info, String[] tables, String sql, FilterNode node, FilterFuncColumn... columns)
protected <T,N extends Number> CompletableFuture<Map<String,N>>	getNumberMapDBAsync(EntityInfo<T> info, String[] tables, String sql, FilterNode node, FilterFuncColumn... columns)
protected <T> Number	getNumberResultDB(EntityInfo<T> info, String[] tables, String sql, FilterFunc func, Number defVal, String column, FilterNode node)
protected <T> CompletableFuture<Number>	getNumberResultDBAsync(EntityInfo<T> info, String[] tables, String sql, FilterFunc func, Number defVal, String column, FilterNode node)
DataJdbcConnection	getReadJdbcConnection()
DataJdbcConnection	getWriteJdbcConnection()
void	init(AnyValue conf)	该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法
protected <T> int	insertDB(EntityInfo<T> info, T... entitys)
protected <T> CompletableFuture<Integer>	insertDBAsync(EntityInfo<T> info, T... entitys)
protected boolean	isAsync()
<V> V	nativeQuery(String sql, BiConsumer<Object,Object> consumer, Function<DataResultSet,V> handler)	直接本地执行SQL语句进行查询，远程模式不可用 通常用于复杂的关联查询
<V> V	nativeQuery(String sql, BiConsumer<Object,Object> consumer, Function<DataResultSet,V> handler, Map<String,Object> params)	通过原生带参数的sql查询结果
<V> CompletableFuture<V>	nativeQueryAsync(String sql, BiConsumer<Object,Object> consumer, Function<DataResultSet,V> handler)	通过原生的sql查询结果
<V> CompletableFuture<V>	nativeQueryAsync(String sql, BiConsumer<Object,Object> consumer, Function<DataResultSet,V> handler, Map<String,Object> params)	通过原生带参数的sql查询结果
<V> Sheet<V>	nativeQuerySheet(Class<V> type, String sql, Flipper flipper, Map<String,Object> params)
<V> CompletableFuture<Sheet<V>>	nativeQuerySheetAsync(Class<V> type, String sql, RowBound round, Map<String,Object> params)
int	nativeUpdate(String sql)	直接本地执行SQL语句进行增删改操作，远程模式不可用 通常用于复杂的更新操作
int	nativeUpdate(String sql, Map<String,Object> params)	执行原生带参数的sql
CompletableFuture<Integer>	nativeUpdateAsync(String sql)	执行原生无参数的sql
CompletableFuture<Integer>	nativeUpdateAsync(String sql, Map<String,Object> params)	执行原生带参数的sql
int[]	nativeUpdates(String... sqls)	直接本地执行SQL语句进行增删改操作，远程模式不可用 通常用于复杂的更新操作
CompletableFuture<int[]>	nativeUpdatesAsync(String... sqls)	执行多条原生无参数的sql
void	offerJdbcConnection(DataJdbcConnection conn)
protected <T> PreparedStatement	prepareInsertEntityStatement(DataJdbcSource.JdbcConnection conn, String sql, EntityInfo<T> info, T... entitys)
protected <T> List<PreparedStatement>	prepareInsertEntityStatements(DataJdbcSource.JdbcConnection conn, EntityInfo<T> info, Map<String,AbstractDataSqlSource.PrepareInfo<T>> prepareInfos, T... entitys)
protected String	prepareParamSign(int index)
protected <T> PreparedStatement	prepareUpdateEntityStatement(DataJdbcSource.JdbcConnection conn, String prepareSQL, EntityInfo<T> info, T... entitys)
protected <T> List<PreparedStatement>	prepareUpdateEntityStatements(DataJdbcSource.JdbcConnection conn, EntityInfo<T> info, Map<String,AbstractDataSqlSource.PrepareInfo<T>> prepareInfos, T... entitys)
protected <T,K extends Serializable,N extends Number> Map<K,N>	queryColumnMapDB(EntityInfo<T> info, String[] tables, String sql, String keyColumn, FilterFunc func, String funcColumn, FilterNode node)
protected <T,K extends Serializable,N extends Number> Map<K[],N[]>	queryColumnMapDB(EntityInfo<T> info, String[] tables, String sql, ColumnNode[] funcNodes, String[] groupByColumns, FilterNode node)
protected <T,K extends Serializable,N extends Number> CompletableFuture<Map<K,N>>	queryColumnMapDBAsync(EntityInfo<T> info, String[] tables, String sql, String keyColumn, FilterFunc func, String funcColumn, FilterNode node)
protected <T,K extends Serializable,N extends Number> CompletableFuture<Map<K[],N[]>>	queryColumnMapDBAsync(EntityInfo<T> info, String[] tables, String sql, ColumnNode[] funcNodes, String[] groupByColumns, FilterNode node)
protected <T> Sheet<T>	querySheetDB(EntityInfo<T> info, boolean readCache, boolean needTotal, boolean distinct, SelectColumn selects, Flipper flipper, FilterNode node)
protected <T> CompletableFuture<Sheet<T>>	querySheetDBAsync(EntityInfo<T> info, boolean readCache, boolean needTotal, boolean distinct, SelectColumn selects, Flipper flipper, FilterNode node, boolean inCacheLoad)
protected <T> Sheet<T>	querySheetFullListDB(EntityInfo<T> info)
protected int	readMaxConns()
protected DataJdbcSource.JdbcConnectionPool	readPool()
protected <T> int	updateColumnDB(EntityInfo<T> info, Flipper flipper, AbstractDataSqlSource.UpdateSqlInfo sql)
protected <T> CompletableFuture<Integer>	updateColumnDBAsync(EntityInfo<T> info, Flipper flipper, AbstractDataSqlSource.UpdateSqlInfo sql)
protected <T> int	updateEntityDB(EntityInfo<T> info, T... entitys)
protected <T> CompletableFuture<Integer>	updateEntityDBAsync(EntityInfo<T> info, T... entitys)
protected void	updateOneResourceChange(Properties newProps, ResourceEvent[] events)
protected void	updateReadResourceChange(Properties newReadProps, ResourceEvent[] events)
protected void	updateWriteResourceChange(Properties newWriteProps, ResourceEvent[] events)
protected int	writeMaxConns()
protected DataJdbcSource.JdbcConnectionPool	writePool()

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

afterResourceChange, apply, autoddl, checkIllegalColumn, clearTable, clearTable, clearTableAsync, clearTableCache, clearTableSql, compile, complete, createOrderbySql, createPageCountSql, createSQLExpress, createSQLJoin, createTable, createTableAsync, createTableSqls, dbtype, decryptProperty, delete, delete, delete, delete, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteCache, deleteCache, deleteSql, deleteSql, dropTable, dropTableAsync, dropTableCache, dropTableSql, exists, exists, existsAsync, existsAsync, existsDBApply, existsSql, existsSql, find, find, findAsync, findAsync, findColumn, findColumn, findColumnAsync, findColumnAsync, findColumnDBApply, findColumnSql, findColumnSql, findDBApply, finds, findsAsync, findsDBAsync, findSql, findSql, formatValueToString, getEntityAttrValue, getInsertDollarPrepareInfo, getInsertQuestionPrepareInfo, getNumberMap, getNumberMapAsync, getNumberMapDBApply, getNumberMapSql, getNumberResult, getNumberResultAsync, getNumberResultDBApply, getNumberResultSql, getSignFunc, getSQLAttrValue, getTableCopySql, getType, getUpdateDollarPrepareInfo, getUpdateQuestionPrepareInfo, initProperties, insert, insertAsync, insertCache, isTableNotExist, loadCache, loadEntityInfo, multiSplit, nativeParse, nativeQuerySheet, onResourceChange, parseNotExistTableName, queryColumnList, queryColumnListAsync, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapDBApply, queryColumnMapDBApply, queryColumnMapSql, queryColumnMapSql, queryColumnSet, queryColumnSetAsync, queryColumnSheet, queryColumnSheetAsync, queryList, queryListAsync, queryMap, queryMap, queryMapAsync, queryMapAsync, querySet, querySetAsync, querySheet, querySheet, querySheetAsync, querySheetAsync, refreshCache, reloadCache, slowLog, toString, update, updateAsync, updateCache, updateCache, updateCache, updateCache, updateCache, updateCache, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnSql, updateColumnSql, updateColumnSql, updateColumnSql, updateColumnSql

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

checkEntity, clearTableAsync, completeExceptionally, createPredicate, dropTable, dropTableAsync, executorToString, exists, existsAsync, find, find, find, find, find, findAsync, findAsync, findAsync, findAsync, findAsync, findColumn, findColumn, findColumn, findColumn, findColumnAsync, findColumnAsync, findColumnAsync, findColumnAsync, getEntityInfo, getEntityValue, getExecutor, getJoinTabalis, getNumberMap, getNumberMap, getNumberMapAsync, getNumberMapAsync, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, insert, insert, insertAsync, insertAsync, isCacheUseable, isOnlyCache, loadEntityInfo, parseSourceUrl, queryColumnList, queryColumnList, queryColumnList, queryColumnList, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnSet, queryColumnSet, queryColumnSet, queryColumnSet, queryColumnSetAsync, queryColumnSetAsync, queryColumnSetAsync, queryColumnSetAsync, queryColumnSheet, queryColumnSheetAsync, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryMap, queryMap, queryMap, queryMap, queryMapAsync, queryMapAsync, queryMapAsync, queryMapAsync, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySheet, querySheet, querySheet, querySheetAsync, querySheetAsync, querySheetAsync, resourceName, setSourceExecutor, supplyAsync, updateColumn, updateColumn, updateColumn, updateColumnAsync, updateColumnAsync, updateColumnAsync

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

runAsync, serviceName, serviceType

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

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

从接口继承的方法 org.redkale.source.DataSource

clearTableAsync, delete, delete, deleteAsync, deleteAsync, dropTable, dropTableAsync, exists, existsAsync, find, find, find, find, find, find, findAsync, findAsync, findAsync, findAsync, findAsync, findAsync, findColumn, findColumn, findColumn, findColumn, findColumnAsync, findColumnAsync, findColumnAsync, findColumnAsync, finds, finds, finds, findsAsync, findsAsync, findsAsync, getNumberMap, getNumberMap, getNumberMapAsync, getNumberMapAsync, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, insert, insert, insertAsync, insertAsync, queryColumnList, queryColumnList, queryColumnList, queryColumnList, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnListAsync, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMap, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnMapAsync, queryColumnSet, queryColumnSet, queryColumnSet, queryColumnSet, queryColumnSetAsync, queryColumnSetAsync, queryColumnSetAsync, queryColumnSetAsync, queryColumnSheet, queryColumnSheet, queryColumnSheetAsync, queryColumnSheetAsync, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryList, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryListAsync, queryMap, queryMap, queryMap, queryMap, queryMapAsync, queryMapAsync, queryMapAsync, queryMapAsync, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySet, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySetAsync, querySheet, querySheet, querySheet, querySheet, querySheet, querySheetAsync, querySheetAsync, querySheetAsync, querySheetAsync, querySheetAsync, update, update, updateAsync, updateAsync, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumn, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync, updateColumnAsync

从接口继承的方法 org.redkale.source.DataSqlSource

nativeQuery, nativeQuery, nativeQuery, nativeQueryAsync, nativeQueryAsync, nativeQueryAsync, nativeQueryList, nativeQueryList, nativeQueryList, nativeQueryListAsync, nativeQueryListAsync, nativeQueryListAsync, nativeQueryMap, nativeQueryMap, nativeQueryMap, nativeQueryMapAsync, nativeQueryMapAsync, nativeQueryMapAsync, nativeQueryOne, nativeQueryOne, nativeQueryOne, nativeQueryOneAsync, nativeQueryOneAsync, nativeQueryOneAsync, nativeQuerySheet, nativeQuerySheet, nativeQuerySheet, nativeQuerySheetAsync, nativeQuerySheetAsync, nativeQuerySheetAsync, nativeQueryStrStrMapAsync, nativeQueryToIntStrMap, nativeQueryToIntStrMap, nativeQueryToIntStrMap, nativeQueryToIntStrMapAsync, nativeQueryToIntStrMapAsync, nativeQueryToIntStrMapAsync, nativeQueryToStrStrMap, nativeQueryToStrStrMap, nativeQueryToStrStrMap, nativeQueryToStrStrMapAsync, nativeQueryToStrStrMapAsync, nativeUpdate, nativeUpdateAsync

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

andThen, compose

从接口继承的方法 org.redkale.inject.Resourcable

resourceName

字段详细资料

readPool

protected DataJdbcSource.JdbcConnectionPool readPool

writePool

protected DataJdbcSource.JdbcConnectionPool writePool

构造器详细资料

DataJdbcSource

public DataJdbcSource()

方法详细资料

init

public void init(AnyValue conf)

从接口复制的说明: Service

该方法必须是可以重复调用， 当reload时需要重复调用init方法 远程模式下该方法会重载成空方法

指定者:

init 在接口中 Service

覆盖:

init 在类中 AbstractDataSqlSource

参数:

conf - 配置参数

updateOneResourceChange

protected void updateOneResourceChange(Properties newProps,
                                       ResourceEvent[] events)

覆盖:

updateOneResourceChange 在类中 AbstractDataSqlSource

updateReadResourceChange

protected void updateReadResourceChange(Properties newReadProps,
                                        ResourceEvent[] events)

覆盖:

updateReadResourceChange 在类中 AbstractDataSqlSource

updateWriteResourceChange

protected void updateWriteResourceChange(Properties newWriteProps,
                                         ResourceEvent[] events)

覆盖:

updateWriteResourceChange 在类中 AbstractDataSqlSource

readMaxConns

protected int readMaxConns()

指定者:

readMaxConns 在类中 AbstractDataSqlSource

writeMaxConns

protected int writeMaxConns()

指定者:

writeMaxConns 在类中 AbstractDataSqlSource

destroy

public void destroy(AnyValue config)

从接口复制的说明: Service

进程退出时，调用Service销毁 远程模式下该方法会重载成空方法 注意： 在此方法内不能调用MessageClient.sendMessage 方法，因为Application关闭时会先destroy掉MessageClient

指定者:

destroy 在接口中 Service

覆盖:

destroy 在类中 AbstractDataSqlSource

参数:

config - 配置参数

close

public void close()
           throws Exception

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 AbstractDataSqlSource

抛出:

Exception

acceptsConf

public static boolean acceptsConf(AnyValue conf)

readPool

protected DataJdbcSource.JdbcConnectionPool readPool()

writePool

protected DataJdbcSource.JdbcConnectionPool writePool()

getReadJdbcConnection

@Local
public DataJdbcConnection getReadJdbcConnection()

getWriteJdbcConnection

@Local
public DataJdbcConnection getWriteJdbcConnection()

offerJdbcConnection

@Local
public void offerJdbcConnection(DataJdbcConnection conn)

prepareParamSign

protected final String prepareParamSign(int index)

指定者:

prepareParamSign 在类中 AbstractDataSqlSource

isAsync

protected final boolean isAsync()

指定者:

isAsync 在类中 AbstractDataSqlSource

prepareInsertEntityStatements

protected <T> List<PreparedStatement> prepareInsertEntityStatements(DataJdbcSource.JdbcConnection conn,
                                                                    EntityInfo<T> info,
                                                                    Map<String,AbstractDataSqlSource.PrepareInfo<T>> prepareInfos,
                                                                    T... entitys)
                                                             throws SQLException

抛出:

SQLException

prepareInsertEntityStatement

protected <T> PreparedStatement prepareInsertEntityStatement(DataJdbcSource.JdbcConnection conn,
                                                             String sql,
                                                             EntityInfo<T> info,
                                                             T... entitys)
                                                      throws SQLException

抛出:

SQLException

prepareUpdateEntityStatements

protected <T> List<PreparedStatement> prepareUpdateEntityStatements(DataJdbcSource.JdbcConnection conn,
                                                                    EntityInfo<T> info,
                                                                    Map<String,AbstractDataSqlSource.PrepareInfo<T>> prepareInfos,
                                                                    T... entitys)
                                                             throws SQLException

抛出:

SQLException

prepareUpdateEntityStatement

protected <T> PreparedStatement prepareUpdateEntityStatement(DataJdbcSource.JdbcConnection conn,
                                                             String prepareSQL,
                                                             EntityInfo<T> info,
                                                             T... entitys)
                                                      throws SQLException

抛出:

SQLException

bindStatementParameters

protected <T> int bindStatementParameters(DataJdbcSource.JdbcConnection conn,
                                          PreparedStatement prestmt,
                                          EntityInfo<T> info,
                                          Attribute<T,Serializable>[] attrs,
                                          T entity)
                                   throws SQLException

抛出:

SQLException

batch

public int batch(DataBatch batch)

从接口复制的说明: DataSource

增删改的批量操作

指定者:

batch 在接口中 DataSource

覆盖:

batch 在类中 AbstractDataSource

参数:

batch - 批量对象

返回:

-1表示失败，正数为成功

batchAsync

public CompletableFuture<Integer> batchAsync(DataBatch batch)

从接口复制的说明: DataSource

增删改的批量操作

指定者:

batchAsync 在接口中 DataSource

覆盖:

batchAsync 在类中 AbstractDataSource

参数:

batch - 批量对象

返回:

-1表示失败，正数为成功

insertDBAsync

protected <T> CompletableFuture<Integer> insertDBAsync(EntityInfo<T> info,
                                                       T... entitys)

指定者:

insertDBAsync 在类中 AbstractDataSqlSource

insertDB

protected <T> int insertDB(EntityInfo<T> info,
                           T... entitys)

覆盖:

insertDB 在类中 AbstractDataSqlSource

deleteDBAsync

protected <T> CompletableFuture<Integer> deleteDBAsync(EntityInfo<T> info,
                                                       String[] tables,
                                                       Flipper flipper,
                                                       FilterNode node,
                                                       Map<String,List<Serializable>> pkmap,
                                                       String... sqls)

指定者:

deleteDBAsync 在类中 AbstractDataSqlSource

deleteDB

protected <T> int deleteDB(EntityInfo<T> info,
                           String[] tables,
                           Flipper flipper,
                           FilterNode node,
                           Map<String,List<Serializable>> pkmap,
                           String... sqls)

覆盖:

deleteDB 在类中 AbstractDataSqlSource

clearTableDBAsync

protected <T> CompletableFuture<Integer> clearTableDBAsync(EntityInfo<T> info,
                                                           String[] tables,
                                                           FilterNode node,
                                                           String... sqls)

指定者:

clearTableDBAsync 在类中 AbstractDataSqlSource

clearTableDB

protected <T> int clearTableDB(EntityInfo<T> info,
                               String[] tables,
                               FilterNode node,
                               String... sqls)

覆盖:

clearTableDB 在类中 AbstractDataSqlSource

createTableDBAsync

protected <T> CompletableFuture<Integer> createTableDBAsync(EntityInfo<T> info,
                                                            String copyTableSql,
                                                            Serializable pk,
                                                            String... sqls)

指定者:

createTableDBAsync 在类中 AbstractDataSqlSource

dropTableDBAsync

protected <T> CompletableFuture<Integer> dropTableDBAsync(EntityInfo<T> info,
                                                          String[] tables,
                                                          FilterNode node,
                                                          String... sqls)

指定者:

dropTableDBAsync 在类中 AbstractDataSqlSource

createTableDB

protected <T> int createTableDB(EntityInfo<T> info,
                                String copyTableSql,
                                Serializable pk,
                                String... sqls)

覆盖:

createTableDB 在类中 AbstractDataSqlSource

dropTableDB

protected <T> int dropTableDB(EntityInfo<T> info,
                              String[] tables,
                              FilterNode node,
                              String... sqls)

覆盖:

dropTableDB 在类中 AbstractDataSqlSource

updateEntityDBAsync

protected <T> CompletableFuture<Integer> updateEntityDBAsync(EntityInfo<T> info,
                                                             T... entitys)

指定者:

updateEntityDBAsync 在类中 AbstractDataSqlSource

updateEntityDB

protected <T> int updateEntityDB(EntityInfo<T> info,
                                 T... entitys)

覆盖:

updateEntityDB 在类中 AbstractDataSqlSource

updateColumnDBAsync

protected <T> CompletableFuture<Integer> updateColumnDBAsync(EntityInfo<T> info,
                                                             Flipper flipper,
                                                             AbstractDataSqlSource.UpdateSqlInfo sql)

指定者:

updateColumnDBAsync 在类中 AbstractDataSqlSource

updateColumnDB

protected <T> int updateColumnDB(EntityInfo<T> info,
                                 Flipper flipper,
                                 AbstractDataSqlSource.UpdateSqlInfo sql)

覆盖:

updateColumnDB 在类中 AbstractDataSqlSource

getNumberMapDBAsync

protected <T,N extends Number> CompletableFuture<Map<String,N>> getNumberMapDBAsync(EntityInfo<T> info,
                                                                                                String[] tables,
                                                                                                String sql,
                                                                                                FilterNode node,
                                                                                                FilterFuncColumn... columns)

指定者:

getNumberMapDBAsync 在类中 AbstractDataSqlSource

getNumberMapDB

protected <T,N extends Number> Map<String,N> getNumberMapDB(EntityInfo<T> info,
                                                                        String[] tables,
                                                                        String sql,
                                                                        FilterNode node,
                                                                        FilterFuncColumn... columns)

覆盖:

getNumberMapDB 在类中 AbstractDataSqlSource

getNumberResultDBAsync

protected <T> CompletableFuture<Number> getNumberResultDBAsync(EntityInfo<T> info,
                                                               String[] tables,
                                                               String sql,
                                                               FilterFunc func,
                                                               Number defVal,
                                                               String column,
                                                               FilterNode node)

指定者:

getNumberResultDBAsync 在类中 AbstractDataSqlSource

getNumberResultDB

protected <T> Number getNumberResultDB(EntityInfo<T> info,
                                       String[] tables,
                                       String sql,
                                       FilterFunc func,
                                       Number defVal,
                                       String column,
                                       FilterNode node)

覆盖:

getNumberResultDB 在类中 AbstractDataSqlSource

queryColumnMapDBAsync

protected <T,K extends Serializable,N extends Number> CompletableFuture<Map<K,N>> queryColumnMapDBAsync(EntityInfo<T> info,
                                                                                                                          String[] tables,
                                                                                                                          String sql,
                                                                                                                          String keyColumn,
                                                                                                                          FilterFunc func,
                                                                                                                          String funcColumn,
                                                                                                                          FilterNode node)

指定者:

queryColumnMapDBAsync 在类中 AbstractDataSqlSource

queryColumnMapDB

protected <T,K extends Serializable,N extends Number> Map<K,N> queryColumnMapDB(EntityInfo<T> info,
                                                                                                  String[] tables,
                                                                                                  String sql,
                                                                                                  String keyColumn,
                                                                                                  FilterFunc func,
                                                                                                  String funcColumn,
                                                                                                  FilterNode node)

覆盖:

queryColumnMapDB 在类中 AbstractDataSqlSource

queryColumnMapDBAsync

protected <T,K extends Serializable,N extends Number> CompletableFuture<Map<K[],N[]>> queryColumnMapDBAsync(EntityInfo<T> info,
                                                                                                                              String[] tables,
                                                                                                                              String sql,
                                                                                                                              ColumnNode[] funcNodes,
                                                                                                                              String[] groupByColumns,
                                                                                                                              FilterNode node)

指定者:

queryColumnMapDBAsync 在类中 AbstractDataSqlSource

queryColumnMapDB

protected <T,K extends Serializable,N extends Number> Map<K[],N[]> queryColumnMapDB(EntityInfo<T> info,
                                                                                                      String[] tables,
                                                                                                      String sql,
                                                                                                      ColumnNode[] funcNodes,
                                                                                                      String[] groupByColumns,
                                                                                                      FilterNode node)

覆盖:

queryColumnMapDB 在类中 AbstractDataSqlSource

findUnCache

protected <T> T findUnCache(EntityInfo<T> info,
                            SelectColumn selects,
                            Serializable pk)

覆盖:

findUnCache 在类中 AbstractDataSqlSource

findUnCacheAsync

protected <T> CompletableFuture<T> findUnCacheAsync(EntityInfo<T> info,
                                                    SelectColumn selects,
                                                    Serializable pk)

覆盖:

findUnCacheAsync 在类中 AbstractDataSqlSource

findDB

protected <T> T findDB(EntityInfo<T> info,
                       Serializable pk)

findDBAsync

protected <T> CompletableFuture<T> findDBAsync(EntityInfo<T> info,
                                               String[] tables,
                                               String sql,
                                               boolean onlypk,
                                               SelectColumn selects,
                                               Serializable pk,
                                               FilterNode node)

指定者:

findDBAsync 在类中 AbstractDataSqlSource

findDB

protected <T> T findDB(EntityInfo<T> info,
                       String[] tables,
                       String sql,
                       boolean onlypk,
                       SelectColumn selects,
                       Serializable pk,
                       FilterNode node)

覆盖:

findDB 在类中 AbstractDataSqlSource

findColumnDBAsync

protected <T> CompletableFuture<Serializable> findColumnDBAsync(EntityInfo<T> info,
                                                                String[] tables,
                                                                String sql,
                                                                boolean onlypk,
                                                                String column,
                                                                Serializable defValue,
                                                                Serializable pk,
                                                                FilterNode node)

指定者:

findColumnDBAsync 在类中 AbstractDataSqlSource

findColumnDB

protected <T> Serializable findColumnDB(EntityInfo<T> info,
                                        String[] tables,
                                        String sql,
                                        boolean onlypk,
                                        String column,
                                        Serializable defValue,
                                        Serializable pk,
                                        FilterNode node)

覆盖:

findColumnDB 在类中 AbstractDataSqlSource

existsDBAsync

protected <T> CompletableFuture<Boolean> existsDBAsync(EntityInfo<T> info,
                                                       String[] tables,
                                                       String sql,
                                                       boolean onlypk,
                                                       Serializable pk,
                                                       FilterNode node)

指定者:

existsDBAsync 在类中 AbstractDataSqlSource

existsDB

protected <T> boolean existsDB(EntityInfo<T> info,
                               String[] tables,
                               String sql,
                               boolean onlypk,
                               Serializable pk,
                               FilterNode node)

覆盖:

existsDB 在类中 AbstractDataSqlSource

findsList

public <D extends Serializable,T> List<T> findsList(Class<T> clazz,
                                                          Stream<D> pks)

从接口复制的说明: DataSource

获取指定主键值的多个记录, 返回列表
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}

指定者:

findsList 在接口中 DataSource

覆盖:

findsList 在类中 AbstractDataSqlSource

类型参数:

D - 主键泛型

T - Entity泛型

参数:

clazz - Entity类

pks - 主键值集合

返回:

Entity对象

findsListAsync

public <D extends Serializable,T> CompletableFuture<List<T>> findsListAsync(Class<T> clazz,
                                                                                  Stream<D> pks)

从接口复制的说明: DataSource

获取指定主键值的多个记录, 返回列表
等价SQL: SELECT {column1},{column2}, ··· FROM {table} WHERE {primary} = {id1,id2, ···}

指定者:

findsListAsync 在接口中 DataSource

覆盖:

findsListAsync 在类中 AbstractDataSqlSource

类型参数:

D - 主键泛型

T - Entity泛型

参数:

clazz - Entity类

pks - 主键值集合

返回:

Entity对象

querySheetDBAsync

protected <T> CompletableFuture<Sheet<T>> querySheetDBAsync(EntityInfo<T> info,
                                                            boolean readCache,
                                                            boolean needTotal,
                                                            boolean distinct,
                                                            SelectColumn selects,
                                                            Flipper flipper,
                                                            FilterNode node,
                                                            boolean inCacheLoad)

指定者:

querySheetDBAsync 在类中 AbstractDataSqlSource

querySheetFullListDB

protected <T> Sheet<T> querySheetFullListDB(EntityInfo<T> info)

querySheetDB

protected <T> Sheet<T> querySheetDB(EntityInfo<T> info,
                                    boolean readCache,
                                    boolean needTotal,
                                    boolean distinct,
                                    SelectColumn selects,
                                    Flipper flipper,
                                    FilterNode node)

覆盖:

querySheetDB 在类中 AbstractDataSqlSource

checkNotExistTablesNoThrows

protected List<String> checkNotExistTablesNoThrows(DataJdbcSource.JdbcConnection conn,
                                                   String[] tables)

checkNotExistTables

protected List<String> checkNotExistTables(DataJdbcSource.JdbcConnection conn,
                                           String[] tables)
                                    throws SQLException

抛出:

SQLException

nativeUpdates

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

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

指定者:

nativeUpdates 在接口中 DataSqlSource

覆盖:

nativeUpdates 在类中 AbstractDataSqlSource

参数:

sqls - SQL语句

返回:

结果数组

nativeUpdate

@Local
public int nativeUpdate(String sql)

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

指定者:

nativeUpdate 在接口中 DataSqlSource

覆盖:

nativeUpdate 在类中 AbstractDataSqlSource

参数:

sql - SQL语句

返回:

结果数组

nativeUpdate

@Local
public int nativeUpdate(String sql,
                        Map<String,Object> params)

从接口复制的说明: DataSqlSource

执行原生带参数的sql

指定者:

nativeUpdate 在接口中 DataSqlSource

覆盖:

nativeUpdate 在类中 AbstractDataSqlSource

参数:

sql - 带参数的sql语句

params - 参数值集合

返回:

执行条数

nativeQuery

@Local
public <V> V nativeQuery(String sql,
                         BiConsumer<Object,Object> consumer,
                         Function<DataResultSet,V> handler)

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

指定者:

nativeQuery 在接口中 DataSqlSource

覆盖:

nativeQuery 在类中 AbstractDataSqlSource

类型参数:

V - 泛型

参数:

sql - SQL语句

consumer - 连接处理函数

handler - 回调函数

返回:

结果

nativeQuery

@Local
public <V> V nativeQuery(String sql,
                         BiConsumer<Object,Object> consumer,
                         Function<DataResultSet,V> handler,
                         Map<String,Object> params)

从接口复制的说明: DataSqlSource

通过原生带参数的sql查询结果

指定者:

nativeQuery 在接口中 DataSqlSource

覆盖:

nativeQuery 在类中 AbstractDataSqlSource

类型参数:

V - 泛型

参数:

sql - 带参数的sql语句

consumer - BiConsumer 参数1: connection, 参数2: statement

handler - DataResultSet的回调函数

params - 参数值集合

返回:

结果对象

nativeQuerySheet

public <V> Sheet<V> nativeQuerySheet(Class<V> type,
                                     String sql,
                                     Flipper flipper,
                                     Map<String,Object> params)

nativeQueryAsync

public <V> CompletableFuture<V> nativeQueryAsync(String sql,
                                                 BiConsumer<Object,Object> consumer,
                                                 Function<DataResultSet,V> handler,
                                                 Map<String,Object> params)

从接口复制的说明: DataSqlSource

通过原生带参数的sql查询结果

类型参数:

V - 泛型

参数:

sql - 带参数的sql语句

consumer - BiConsumer 参数1: connection, 参数2: statement

handler - DataResultSet的回调函数

params - 参数值集合

返回:

结果对象

nativeQueryAsync

public <V> CompletableFuture<V> nativeQueryAsync(String sql,
                                                 BiConsumer<Object,Object> consumer,
                                                 Function<DataResultSet,V> handler)

从接口复制的说明: DataSqlSource

通过原生的sql查询结果

类型参数:

V - 泛型

参数:

sql - 无参数的sql语句

consumer - BiConsumer 参数1: connection, 参数2: statement

handler - DataResultSet的回调函数

返回:

结果对象

nativeUpdateAsync

public CompletableFuture<Integer> nativeUpdateAsync(String sql,
                                                    Map<String,Object> params)

从接口复制的说明: DataSqlSource

执行原生带参数的sql

参数:

sql - 带参数的sql语句

params - 参数值集合

返回:

执行条数

nativeUpdateAsync

public CompletableFuture<Integer> nativeUpdateAsync(String sql)

从接口复制的说明: DataSqlSource

执行原生无参数的sql

参数:

sql - 无参数的sql语句

返回:

执行条数

nativeUpdatesAsync

public CompletableFuture<int[]> nativeUpdatesAsync(String... sqls)

从接口复制的说明: DataSqlSource

执行多条原生无参数的sql

参数:

sqls - 无参数的sql语句

返回:

执行条数

nativeQuerySheetAsync

public <V> CompletableFuture<Sheet<V>> nativeQuerySheetAsync(Class<V> type,
                                                             String sql,
                                                             RowBound round,
                                                             Map<String,Object> params)

directExecute

@Deprecated
public int directExecute(String sql)

已过时。

directExecute

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

已过时。

directQuery

@Deprecated
public <V> V directQuery(String sql,
                         Function<DataResultSet,V> handler)

已过时。

createDataResultSet

public static DataResultSet createDataResultSet(@Nullable
                                                EntityInfo info,
                                                ResultSet set)