com.heitaox.sql.executor

类 SQLExecutor

java.lang.Object

com.heitaox.sql.executor.SQLExecutor

public class SQLExecutor
extends Object

sql执行器

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	SQLExecutor.SQLExecutorBuilder

字段概要

字段

限定符和类型	字段和说明
static SQLExecutor.SQLExecutorBuilder	sqlExecutorBuilder

构造器概要

构造器

构造器和说明
SQLExecutor(SQLExecutor.SQLExecutorBuilder builder)

方法概要

限定符和类型	方法和说明
boolean	cache(String tableName, joinery.DataFrame df)
void	enableCache()
int	executeDelete(String sql) delete sql only support delete from table where ,not support drop table
int	executeInsert(String sql) insert sql 如果不是关系型数据库必须包含列名称 insert into tableName (column1,column2) values(v1,v2); 不支持insert into tableName (v1,v2);的形式
joinery.DataFrame	executeQuery(String sql)
<T> List<T>	executeQuery(String sql, Class<T> resultClass)
int	executeUpdate(String sql) 如果不是关系型数据库为数据源 将有以下限制： 1、update sql中将仅支持set column = value格式， 不支持value是个表达式的形式例如 column = value + 1 2、update sql 中的where子句不支持or 括号 all any
boolean	filterBeforeJoin()
boolean	filterFirst()
static void	registFunc(String funcName, Class funcClass)
boolean	removeCache(String tableName)

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

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

字段详细资料

sqlExecutorBuilder

public static final SQLExecutor.SQLExecutorBuilder sqlExecutorBuilder

构造器详细资料

SQLExecutor

public SQLExecutor(SQLExecutor.SQLExecutorBuilder builder)

方法详细资料

cache

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

enableCache

public void enableCache()

removeCache

public boolean removeCache(String tableName)

filterBeforeJoin

public boolean filterBeforeJoin()

filterFirst

public boolean filterFirst()

registFunc

public static void registFunc(String funcName,
                              Class funcClass)

executeQuery

public joinery.DataFrame executeQuery(String sql)

executeQuery

public <T> List<T> executeQuery(String sql,
                                Class<T> resultClass)
                         throws Exception

抛出:

Exception

executeInsert

public int executeInsert(String sql)
                  throws IOException,
                         SQLException

insert sql 如果不是关系型数据库必须包含列名称 insert into tableName (column1,column2) values(v1,v2); 不支持insert into tableName (v1,v2);的形式

参数:

sql - insert sql

返回:

success count

抛出:

IOException - IOException

SQLException - SQLException

executeUpdate

public int executeUpdate(String sql)
                  throws IOException,
                         SQLException

如果不是关系型数据库为数据源 将有以下限制： 1、update sql中将仅支持set column = value格式， 不支持value是个表达式的形式例如 column = value + 1 2、update sql 中的where子句不支持or 括号 all any

参数:

sql - 执行的sql

返回:

success count

抛出:

IOException - IOException

SQLException - SQLException

executeDelete

public int executeDelete(String sql)
                  throws IOException,
                         SQLException

delete sql only support delete from table where ,not support drop table

参数:

sql - delete sql

返回:

delete success count

抛出:

IOException - IOException

SQLException - SQLException