Class JdbcExecutor.Default

java.lang.Object

org.huiche.jdbc.JdbcExecutor.Default

All Implemented Interfaces:

JdbcExecutor

Enclosing interface:

JdbcExecutor

public static class JdbcExecutor.Default
extends Object
implements JdbcExecutor

JdbcClient默认实现

Author:

Maning

Nested Class Summary

Nested classes/interfaces inherited from interface JdbcExecutor

JdbcExecutor.Default

Method Summary

Modifier and Type	Method	Description
Configuration	configuration()	获取配置
<C extends Collection<T>, T> C	executeQuery(String sql, List<?> params, RowMapper<T> rowMapper, C collection)	执行查询集合
boolean	executeQueryExists(String sql, List<?> params)	执行查询是否存在
<T> T	executeQueryFirstRow(String sql, List<?> params, RowMapper<T> rowMapper)	执行查询集合
<T> Stream<T>	executeQueryStream(String sql, List<?> params, RowMapper<T> rowMapper, Integer limit)	执行查询stream
int	executeUpdate(String sql, List<?> params)	执行更新
int	executeUpdate(String sql, List<?> params, int keyCount, String keyColumn, Type keyType, Consumer<Object[]> keyConsumer)	执行更新并填充自增key(一般为主键)
SqlSpec	sql(String sql, List<?> params)	通过sql语句和参数获取sql操作对象
SqlSpec	sql(Statement statement)	通过dsl语句获取sql操作对象

Methods inherited from class Object

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

Methods inherited from interface JdbcExecutor

executeQueryStream, sql, sql

Method Details

configuration

public Configuration configuration()

Description copied from interface: JdbcExecutor

获取配置

Specified by:

configuration in interface JdbcExecutor

Returns:

配置

executeQuery

public <C extends Collection<T>, T> C executeQuery(String sql,
 List<?> params,
 RowMapper<T> rowMapper,
 C collection)

Description copied from interface: JdbcExecutor

执行查询集合

Specified by:

executeQuery in interface JdbcExecutor

Type Parameters:

C - 集合类型

T - 集合条目类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

collection - 集合

Returns:

查询结果

executeQueryExists

public boolean executeQueryExists(String sql,
 List<?> params)

Description copied from interface: JdbcExecutor

执行查询是否存在

Specified by:

executeQueryExists in interface JdbcExecutor

Parameters:

sql - sql语句

params - sql参数

Returns:

查询结果

executeQueryFirstRow

public <T> T executeQueryFirstRow(String sql,
 List<?> params,
 RowMapper<T> rowMapper)

Description copied from interface: JdbcExecutor

执行查询集合

Specified by:

executeQueryFirstRow in interface JdbcExecutor

Type Parameters:

T - 类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

Returns:

查询结果

executeQueryStream

public <T> Stream<T> executeQueryStream(String sql,
 List<?> params,
 RowMapper<T> rowMapper,
 Integer limit)

Description copied from interface: JdbcExecutor

执行查询stream

Specified by:

executeQueryStream in interface JdbcExecutor

Type Parameters:

T - 类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

limit - 限制条数

Returns:

stream

executeUpdate

public int executeUpdate(String sql,
 List<?> params)

Description copied from interface: JdbcExecutor

执行更新

Specified by:

executeUpdate in interface JdbcExecutor

Parameters:

sql - sql语句

params - sql参数

Returns:

变动条数|执行结果

executeUpdate

public int executeUpdate(String sql,
 List<?> params,
 int keyCount,
 String keyColumn,
 Type keyType,
 Consumer<Object[]> keyConsumer)

Description copied from interface: JdbcExecutor

执行更新并填充自增key(一般为主键)

Specified by:

executeUpdate in interface JdbcExecutor

Parameters:

sql - sql语句

params - sql参数

keyCount - 生成key的条数

keyColumn - 自增列,可能为空,仅部分数据库需要时传入

keyType - 自增属性类型

keyConsumer - 自增值消费者

Returns:

变动条数|执行结果

sql

public SqlSpec sql(String sql,
 List<?> params)

Description copied from interface: JdbcExecutor

通过sql语句和参数获取sql操作对象

Specified by:

sql in interface JdbcExecutor

Parameters:

sql - 带有?的sql语句

params - sql参数

Returns:

Sql操作

sql

public SqlSpec sql(Statement statement)

Description copied from interface: JdbcExecutor

通过dsl语句获取sql操作对象

Specified by:

sql in interface JdbcExecutor

Parameters:

statement - dsl语句

Returns:

Sql操作