com.heitaox.sql.executor.source

接口 DataSource

所有已知子接口:

FileDataSource, NoSQLDataSource, RDBMSDataSource

所有已知实现类:

CacheDatasource, ExcelDataSource, NullDataSource, StandardSqlDataSource

public interface DataSource

方法概要

限定符和类型	方法和说明
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.
default joinery.DataFrame	queryByPredicate(String table, String tableAlias, List<PredicateEntity<Object>> predicateEntities) users can rewrite this method by getting the data based on the filter criteria and converting it to the default implementation of DataFrame.
int	update(Map<String,Object> updateItems, List<PredicateEntity<Object>> predicateEntities, String tableName) Update data to data source

方法详细资料

queryAll

joinery.DataFrame queryAll(String tableNme,
                           String tableAlias)

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

参数:

tableNme - tableName

tableAlias - tableAlias

返回:

DataFrame

queryByPredicate

default joinery.DataFrame queryByPredicate(String table,
                                           String tableAlias,
                                           List<PredicateEntity<Object>> predicateEntities)

users can rewrite this method by getting the data based on the filter criteria and converting it to the default implementation of DataFrame.

参数:

table - tableNme

tableAlias - tableAlias

predicateEntities - Ascertain condition

返回:

DataFrame

另请参阅:

PredicateFilter

insert

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

insert data into the data source

参数:

valueList - valueList

tableName - tableName

返回:

success count

抛出:

IOException - IOException

update

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

Update data to data source

参数:

updateItems - updateItems

tableName - tableName

predicateEntities - predicateEntities

返回:

success count

抛出:

IOException - IOException

delete

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

delete data from data source

参数:

tableName - tableName

predicateEntities - predicateEntities

返回:

success count

抛出:

IOException - IOException