com.heitaox.sql.executor.source.extend

类 CacheDatasource

java.lang.Object

com.heitaox.sql.executor.source.extend.CacheDatasource

所有已实现的接口:

DataSource

public class CacheDatasource
extends Object
implements DataSource

构造器概要

构造器

构造器和说明
CacheDatasource()

方法概要

限定符和类型	方法和说明
boolean	cache(String table, joinery.DataFrame df)
int	delete(List<PredicateEntity<Object>> predicateEntities, String tableName) delete data from data source
int	insert(List<Map<String,Object>> valueList, String tableName) insert data into the data source
joinery.DataFrame	queryAll(String tableNme, String tableAlias) get all the data in the table and converting it to DataFrame.
void	removeCache(String table)
int	update(Map<String,Object> updateItems, List<PredicateEntity<Object>> predicateEntities, String tableName) Update data to data source

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

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

从接口继承的方法 com.heitaox.sql.executor.source.DataSource

queryByPredicate

构造器详细资料

CacheDatasource

public CacheDatasource()

方法详细资料

queryAll

public joinery.DataFrame queryAll(String tableNme,
                                  String tableAlias)

从接口复制的说明: DataSource

get all the data in the table and converting it to DataFrame.

指定者:

queryAll 在接口中 DataSource

参数:

tableNme - tableName

tableAlias - tableAlias

返回:

DataFrame

insert

public int insert(List<Map<String,Object>> valueList,
                  String tableName)

从接口复制的说明: DataSource

insert data into the data source

指定者:

insert 在接口中 DataSource

参数:

valueList - valueList

tableName - tableName

返回:

success count

update

public int update(Map<String,Object> updateItems,
                  List<PredicateEntity<Object>> predicateEntities,
                  String tableName)
           throws IOException

从接口复制的说明: DataSource

Update data to data source

指定者:

update 在接口中 DataSource

参数:

updateItems - updateItems

predicateEntities - predicateEntities

tableName - tableName

返回:

success count

抛出:

IOException - IOException

delete

public int delete(List<PredicateEntity<Object>> predicateEntities,
                  String tableName)

从接口复制的说明: DataSource

delete data from data source

指定者:

delete 在接口中 DataSource

参数:

predicateEntities - predicateEntities

tableName - tableName

返回:

success count

cache

public boolean cache(String table,
                     joinery.DataFrame df)

removeCache

public void removeCache(String table)