@Local @AutoLoad(value=false) @ResourceType(value=DataSource.class) public class DataMemorySource extends DataSqlSource<java.lang.Void>
详情见: https://redkale.org
bufferPool, cacheForbidden, cacheListener, executor, FLIPPER_ONE, fullloader, futureCompleteConsumer, logger, name, persistxml, readPool, sqlFormatter, threads, writePool
构造器和说明 |
---|
DataMemorySource(java.lang.String unitName,
java.net.URL persistxml,
java.util.Properties readprop,
java.util.Properties writeprop) |
限定符和类型 | 方法和说明 |
---|---|
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
clearTableDB(EntityInfo<T> info,
java.lang.String sql) |
protected PoolSource<java.lang.Void> |
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) |
int |
directExecute(java.lang.String sql) |
<V> V |
directQuery(java.lang.String sql,
java.util.function.Function<java.sql.ResultSet,V> handler) |
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) |
java.lang.String |
getType()
获取数据源类型
|
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> |
insertDB(EntityInfo<T> info,
T... entitys) |
protected boolean |
isAsync() |
protected boolean |
isOnlyCache(EntityInfo info) |
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, getWritePoolSource, init, insert, insertAsync, insertCache, insertCache, 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 DataMemorySource(java.lang.String unitName, java.net.URL persistxml, java.util.Properties readprop, java.util.Properties writeprop)
@Local public java.lang.String getType()
DataSource
getType
在接口中 DataSource
getType
在类中 DataSqlSource<java.lang.Void>
protected boolean isOnlyCache(EntityInfo info)
isOnlyCache
在类中 DataSqlSource<java.lang.Void>
@Local public int directExecute(java.lang.String sql)
directExecute
在类中 DataSqlSource<java.lang.Void>
@Local public int[] directExecute(java.lang.String... sqls)
directExecute
在类中 DataSqlSource<java.lang.Void>
@Local public <V> V directQuery(java.lang.String sql, java.util.function.Function<java.sql.ResultSet,V> handler)
directQuery
在类中 DataSqlSource<java.lang.Void>
protected boolean isAsync()
isAsync
在类中 DataSqlSource<java.lang.Void>
protected java.lang.String prepareParamSign(int index)
prepareParamSign
在类中 DataSqlSource<java.lang.Void>
protected PoolSource<java.lang.Void> createPoolSource(DataSource source, java.lang.String rwtype, java.util.concurrent.ArrayBlockingQueue queue, java.util.concurrent.Semaphore semaphore, java.util.Properties prop)
createPoolSource
在类中 DataSqlSource<java.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> insertDB(EntityInfo<T> info, T... entitys)
insertDB
在类中 DataSqlSource<java.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteDB(EntityInfo<T> info, Flipper flipper, java.lang.String sql)
deleteDB
在类中 DataSqlSource<java.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableDB(EntityInfo<T> info, java.lang.String sql)
clearTableDB
在类中 DataSqlSource<java.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableDB(EntityInfo<T> info, java.lang.String sql)
dropTableDB
在类中 DataSqlSource<java.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateDB(EntityInfo<T> info, T... entitys)
updateDB
在类中 DataSqlSource<java.lang.Void>
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.lang.Void>
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.lang.Void>
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.lang.Void>
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.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<T> findDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk, SelectColumn selects)
findDB
在类中 DataSqlSource<java.lang.Void>
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.lang.Void>
protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsDB(EntityInfo<T> info, java.lang.String sql, boolean onlypk)
existsDB
在类中 DataSqlSource<java.lang.Void>
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.lang.Void>