Interface JdbcExecutor

All Known Implementing Classes:

JdbcExecutor.Default

public interface JdbcExecutor

jdbc执行器

Author:

Maning

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	JdbcExecutor.Default	JdbcClient默认实现

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)	执行查询集合
default <T> Stream<T>	executeQueryStream(String sql, List<?> params, RowMapper<T> rowMapper)	执行查询stream
<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(一般为主键)
static JdbcExecutor	of(ConfigurationBuilder configurationBuilder)	创建jdbc执行器
default SqlSpec	sql(String sql)	通过sql语句获取sql操作对象
default SqlSpec	sql(String sql, Object... params)	通过sql语句和参数获取sql操作对象
SqlSpec	sql(String sql, List<?> params)	通过sql语句和参数获取sql操作对象
SqlSpec	sql(Statement statement)	通过dsl语句获取sql操作对象

Method Details

of

static JdbcExecutor of(ConfigurationBuilder configurationBuilder)

创建jdbc执行器

Parameters:

configurationBuilder - 配置

Returns:

jdbc执行器

configuration

Configuration configuration()

获取配置

Returns:

配置

executeQuery

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

执行查询集合

Type Parameters:

C - 集合类型

T - 集合条目类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

collection - 集合

Returns:

查询结果

executeQueryExists

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

执行查询是否存在

Parameters:

sql - sql语句

params - sql参数

Returns:

查询结果

executeQueryFirstRow

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

执行查询集合

Type Parameters:

T - 类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

Returns:

查询结果

executeQueryStream

default <T> Stream<T> executeQueryStream(String sql,
 List<?> params,
 RowMapper<T> rowMapper)

执行查询stream

Type Parameters:

T - 类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

Returns:

stream

executeQueryStream

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

执行查询stream

Type Parameters:

T - 类型

Parameters:

sql - sql语句

params - sql参数

rowMapper - 行转换器

limit - 限制条数

Returns:

stream

executeUpdate

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

执行更新

Parameters:

sql - sql语句

params - sql参数

Returns:

变动条数|执行结果

executeUpdate

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

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

Parameters:

sql - sql语句

params - sql参数

keyCount - 生成key的条数

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

keyType - 自增属性类型

keyConsumer - 自增值消费者

Returns:

变动条数|执行结果

sql

default SqlSpec sql(String sql)

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

Parameters:

sql - 无参数sql语句

Returns:

Sql操作

sql

default SqlSpec sql(String sql,
 Object... params)

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

Parameters:

sql - 带有?的sql语句

params - sql参数

Returns:

Sql操作

sql

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

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

Parameters:

sql - 带有?的sql语句

params - sql参数

Returns:

Sql操作

sql

SqlSpec sql(Statement statement)

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

Parameters:

statement - dsl语句

Returns:

Sql操作