@Local @AutoLoad(value=false) @ResourceType(value=DataSource.class) public class DataJdbcSource extends DataSqlSource<java.sql.Connection>
详情见: https://redkale.org
bufferPool, cacheForbidden, cacheListener, executor, FLIPPER_ONE, fullloader, futureCompleteConsumer, logger, name, persistxml, readPool, sqlFormatter, threads, writePool
构造器和说明 |
---|
DataJdbcSource(java.lang.String unitName,
java.net.URL persistxml,
java.util.Properties readprop,
java.util.Properties writeprop) |
限定符和类型 | 方法和说明 |
---|---|
protected <T> int |
batchStatementParameters(java.sql.Connection conn,
java.sql.PreparedStatement prestmt,
EntityInfo<T> info,
Attribute<T,java.io.Serializable>[] attrs,
T entity) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
clearTableDB(EntityInfo<T> info,
java.lang.String sql) |
protected <T> java.sql.PreparedStatement |
createInsertPreparedStatement(java.sql.Connection conn,
java.lang.String sql,
EntityInfo<T> info,
T... entitys) |
protected PoolSource<java.sql.Connection> |
createPoolSource(DataSource source,
java.lang.String rwtype,
java.util.concurrent.ArrayBlockingQueue queue,
java.util.concurrent.Semaphore semaphore,
java.util.Properties prop) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
deleteDB(EntityInfo<T> info,
Flipper flipper,
java.lang.String sql) |
int[] |
directExecute(java.lang.String... sqls)
直接本地执行SQL语句进行增删改操作,远程模式不可用
通常用于复杂的更新操作 |
int |
directExecute(java.lang.String sql)
直接本地执行SQL语句进行增删改操作,远程模式不可用
通常用于复杂的更新操作 |
<V> V |
directQuery(java.lang.String sql,
java.util.function.Function<java.sql.ResultSet,V> handler)
直接本地执行SQL语句进行查询,远程模式不可用
通常用于复杂的关联查询 |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
dropTableDB(EntityInfo<T> info,
java.lang.String sql) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> |
existsDB(EntityInfo<T> info,
java.lang.String sql,
boolean onlypk) |
protected <T> java.util.concurrent.CompletableFuture<java.io.Serializable> |
findColumnDB(EntityInfo<T> info,
java.lang.String sql,
boolean onlypk,
java.lang.String column,
java.io.Serializable defValue) |
protected <T> java.util.concurrent.CompletableFuture<T> |
findDB(EntityInfo<T> info,
java.lang.String sql,
boolean onlypk,
SelectColumn selects) |
protected <T,N extends java.lang.Number> |
getNumberMapDB(EntityInfo<T> info,
java.lang.String sql,
FilterFuncColumn... columns) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Number> |
getNumberResultDB(EntityInfo<T> info,
java.lang.String sql,
java.lang.Number defVal,
java.lang.String column) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
insertDB(EntityInfo<T> info,
T... entitys) |
protected boolean |
isAsync() |
protected java.lang.String |
prepareParamSign(int index) |
protected <T,K extends java.io.Serializable,N extends java.lang.Number> |
queryColumnMapDB(EntityInfo<T> info,
java.lang.String sql,
java.lang.String keyColumn) |
protected <T> java.util.concurrent.CompletableFuture<Sheet<T>> |
querySheetDB(EntityInfo<T> info,
boolean readcache,
boolean needtotal,
SelectColumn selects,
Flipper flipper,
FilterNode node) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateDB(EntityInfo<T> info,
Flipper flipper,
java.lang.String sql,
boolean prepared,
java.lang.Object... params) |
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
updateDB(EntityInfo<T> info,
T... entitys) |
apply, checkEntity, clearTable, clearTable, clearTableAsync, clearTableAsync, clearTableCache, clearTableCompose, close, createSQLExpress, createSQLJoin, createSQLOrderby, delete, delete, delete, delete, deleteAsync, deleteAsync, deleteAsync, deleteAsync, deleteCache, deleteCache, deleteCache, deleteCompose, deleteCompose, destroy, dropTable, dropTable, dropTableAsync, dropTableAsync, dropTableCache, dropTableCompose, 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, formatValueToString, getEntityValue, getExecutor, getFieldValue, getFieldValue, getJoinTabalis, getNumberMap, getNumberMap, getNumberMap, getNumberMapAsync, getNumberMapAsync, getNumberMapAsync, getNumberMapCompose, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResult, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultAsync, getNumberResultCompose, getReadPoolSource, getType, getWritePoolSource, 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
runAsync
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
delete, delete, deleteAsync, deleteAsync, update, update, updateAsync, updateAsync
public DataJdbcSource(java.lang.String unitName, java.net.URL persistxml, java.util.Properties readprop, java.util.Properties writeprop)
protected final java.lang.String prepareParamSign(int index)
prepareParamSign
在类中 DataSqlSource<java.sql.Connection>
protected final boolean isAsync()
isAsync
在类中 DataSqlSource<java.sql.Connection>
protected PoolSource<java.sql.Connection> createPoolSource(DataSource source, java.lang.String rwtype, java.util.concurrent.ArrayBlockingQueue queue, java.util.concurrent.Semaphore semaphore, java.util.Properties prop)
createPoolSource
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> insertDB(EntityInfo<T> info, T... entitys)
insertDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.sql.PreparedStatement createInsertPreparedStatement(java.sql.Connection conn, java.lang.String sql, EntityInfo<T> info, T... entitys) throws java.sql.SQLException
java.sql.SQLException
protected <T> int batchStatementParameters(java.sql.Connection conn, java.sql.PreparedStatement prestmt, EntityInfo<T> info, Attribute<T,java.io.Serializable>[] attrs, T entity) throws java.sql.SQLException
java.sql.SQLException
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteDB(EntityInfo<T> info, Flipper flipper, java.lang.String sql)
deleteDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableDB(EntityInfo<T> info, java.lang.String sql)
clearTableDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableDB(EntityInfo<T> info, java.lang.String sql)
dropTableDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateDB(EntityInfo<T> info, T... entitys)
updateDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateDB(EntityInfo<T> info, Flipper flipper, java.lang.String sql, boolean prepared, java.lang.Object... params)
updateDB
在类中 DataSqlSource<java.sql.Connection>
protected <T,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>> getNumberMapDB(EntityInfo<T> info, java.lang.String sql, FilterFuncColumn... columns)
getNumberMapDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Number> getNumberResultDB(EntityInfo<T> info, java.lang.String sql, java.lang.Number defVal, java.lang.String column)
getNumberResultDB
在类中 DataSqlSource<java.sql.Connection>
protected <T,K extends java.io.Serializable,N extends java.lang.Number> java.util.concurrent.CompletableFuture<java.util.Map<K,N>> queryColumnMapDB(EntityInfo<T> info, java.lang.String sql, java.lang.String keyColumn)
queryColumnMapDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<T> findDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk, SelectColumn selects)
findDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.io.Serializable> findColumnDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk, java.lang.String column, java.io.Serializable defValue)
findColumnDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk)
existsDB
在类中 DataSqlSource<java.sql.Connection>
protected <T> java.util.concurrent.CompletableFuture<Sheet<T>> querySheetDB(EntityInfo<T> info, boolean readcache, boolean needtotal, SelectColumn selects, Flipper flipper, FilterNode node)
querySheetDB
在类中 DataSqlSource<java.sql.Connection>
@Local public int directExecute(java.lang.String sql)
directExecute
在类中 DataSqlSource<java.sql.Connection>
sql
- SQL语句@Local public int[] directExecute(java.lang.String... sqls)
directExecute
在类中 DataSqlSource<java.sql.Connection>
sqls
- SQL语句@Local public <V> V directQuery(java.lang.String sql, java.util.function.Function<java.sql.ResultSet,V> handler)
directQuery
在类中 DataSqlSource<java.sql.Connection>
V
- 泛型sql
- SQL语句handler
- 回调函数