org.redkale.source

类 DataMemorySource

java.lang.Object

org.redkale.service.AbstractService

org.redkale.source.DataSqlSource<java.lang.Void>

org.redkale.source.DataMemorySource

所有已实现的接口:

java.lang.AutoCloseable, java.util.function.Function<java.lang.Class,EntityInfo>, Service, DataCacheListener, DataSource, Resourcable

@Local
 @AutoLoad(value=false)
 @ResourceType(value=DataSource.class)
public class DataMemorySource
extends DataSqlSource<java.lang.Void>

DataSource的Memory实现类
注意: javax.persistence.jdbc.url 需要指定为 memory:source

详情见: https://redkale.org

字段概要

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

bufferPool, cacheForbidden, cacheListener, executor, FLIPPER_ONE, fullloader, futureCompleteConsumer, logger, name, persistxml, readPool, 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> java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,N>>	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> java.util.concurrent.CompletableFuture<java.util.Map<K,N>>	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 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)

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

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, 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

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

runAsync

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

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

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

delete, delete, deleteAsync, deleteAsync, update, update, updateAsync, updateAsync

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

andThen, compose, identity

构造器详细资料

DataMemorySource

public DataMemorySource(java.lang.String unitName,
                        java.net.URL persistxml,
                        java.util.Properties readprop,
                        java.util.Properties writeprop)

方法详细资料

getType

@Local
public java.lang.String getType()

从接口复制的说明: DataSource

获取数据源类型

指定者:

getType 在接口中 DataSource

覆盖:

getType 在类中 DataSqlSource<java.lang.Void>

返回:

String

isOnlyCache

protected boolean isOnlyCache(EntityInfo info)

覆盖:

isOnlyCache 在类中 DataSqlSource<java.lang.Void>

directExecute

@Local
public int directExecute(java.lang.String sql)

指定者:

directExecute 在类中 DataSqlSource<java.lang.Void>

directExecute

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

指定者:

directExecute 在类中 DataSqlSource<java.lang.Void>

directQuery

@Local
public <V> V directQuery(java.lang.String sql,
                                 java.util.function.Function<java.sql.ResultSet,V> handler)

指定者:

directQuery 在类中 DataSqlSource<java.lang.Void>

isAsync

protected boolean isAsync()

指定者:

isAsync 在类中 DataSqlSource<java.lang.Void>

prepareParamSign

protected java.lang.String prepareParamSign(int index)

指定者:

prepareParamSign 在类中 DataSqlSource<java.lang.Void>

createPoolSource

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>

insertDB

protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> insertDB(EntityInfo<T> info,
                                                                                 T... entitys)

指定者:

insertDB 在类中 DataSqlSource<java.lang.Void>

deleteDB

protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> deleteDB(EntityInfo<T> info,
                                                                                 Flipper flipper,
                                                                                 java.lang.String sql)

指定者:

deleteDB 在类中 DataSqlSource<java.lang.Void>

clearTableDB

protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> clearTableDB(EntityInfo<T> info,
                                                                                     java.lang.String sql)

指定者:

clearTableDB 在类中 DataSqlSource<java.lang.Void>

dropTableDB

protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> dropTableDB(EntityInfo<T> info,
                                                                                    java.lang.String sql)

指定者:

dropTableDB 在类中 DataSqlSource<java.lang.Void>

updateDB

protected <T> java.util.concurrent.CompletableFuture<java.lang.Integer> updateDB(EntityInfo<T> info,
                                                                                 T... entitys)

指定者:

updateDB 在类中 DataSqlSource<java.lang.Void>

updateDB

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>

getNumberMapDB

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>

getNumberResultDB

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>

queryColumnMapDB

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>

findDB

protected <T> java.util.concurrent.CompletableFuture<T> findDB(EntityInfo<T> info,
                                                               java.lang.String sql,
                                                               boolean onlypk,
                                                               SelectColumn selects)

指定者:

findDB 在类中 DataSqlSource<java.lang.Void>

findColumnDB

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>

existsDB

protected <T> java.util.concurrent.CompletableFuture<java.lang.Boolean> existsDB(EntityInfo<T> info,
                                                                                 java.lang.String sql,
                                                                                 boolean onlypk)

指定者:

existsDB 在类中 DataSqlSource<java.lang.Void>

querySheetDB

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

指定者:

querySheetDB 在类中 DataSqlSource<java.lang.Void>