com.heitaox.sql.executor.source

接口 RDBMSDataSource

所有超级接口:

DataSource

所有已知实现类:

StandardSqlDataSource

public interface RDBMSDataSource
extends DataSource

方法概要

限定符和类型	方法和说明
default int	delete(List<PredicateEntity<Object>> predicateEntities, String tableName) delete data from data source
joinery.DataFrame<Object>	executeQuery(String sql) the sql execution of the general relational database can directly use the execution engine of the database itself.
int	executeUpdate(String sql) call the relational database api to execute the update statement
default int	insert(List<Map<String,Object>> valueList, String tableName) convert the wrapped valueList to sql and execute executeQuery(String)
default joinery.DataFrame	queryAll(String tableNme, String tableAlias) The default call to StandardSqlDataSource#executeQuery(String) Perform a full table query.
default joinery.DataFrame	queryByPredicate(String tableName, String tableAlias, List<PredicateEntity<Object>> predicateEntities) Convert to sql with a where clause and execute according to the incoming assertion condition PredicateEntity Packaged assertion condition
default int	update(Map<String,Object> updateItems, List<PredicateEntity<Object>> predicateEntities, String tableName) Update data to data source

方法详细资料

executeQuery

joinery.DataFrame<Object> executeQuery(String sql)

the sql execution of the general relational database can directly use the execution engine of the database itself. This method needs to implement the execution logic of the calling database and convert it into a DataFrame. example:

参数:

sql - Sql to execute query

返回:

DataFrame

另请参阅:

StandardSqlDataSource.executeQuery(String)

executeUpdate

int executeUpdate(String sql)

call the relational database api to execute the update statement

参数:

sql - Sql to execute update

返回:

number of successful lines

另请参阅:

StandardSqlDataSource.executeUpdate(String)

queryAll

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

The default call to StandardSqlDataSource#executeQuery(String) Perform a full table query.

指定者:

queryAll 在接口中 DataSource

参数:

tableNme - tableName

tableAlias - tableAlias

返回:

DataFrame

另请参阅:

executeQuery(String), DataSource.queryAll(String, String)

queryByPredicate

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

Convert to sql with a where clause and execute according to the incoming assertion condition PredicateEntity Packaged assertion condition

指定者:

queryByPredicate 在接口中 DataSource

参数:

tableName - tableName

tableAlias - tableAlias

predicateEntities - predicateEntities： Set of conditions

返回:

DataFrame

另请参阅:

executeQuery(String), DataSource.queryByPredicate(String, String, List)

insert

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

convert the wrapped valueList to sql and execute executeQuery(String)

指定者:

insert 在接口中 DataSource

参数:

valueList - valueList of map

tableName - tableName

返回:

number of successful lines

update

default 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

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

从接口复制的说明: DataSource

delete data from data source

指定者:

delete 在接口中 DataSource

参数:

predicateEntities - predicateEntities

tableName - tableName

返回:

success count