public class SqlConnRunner extends DialectRunner
caseInsensitive| Constructor and Description |
|---|
SqlConnRunner(Dialect dialect)
构造
|
SqlConnRunner(String driverClassName)
构造
|
| Modifier and Type | Method and Description |
|---|---|
long |
count(Connection conn,
CharSequence selectSql)
获取查询结果总数，生成类似于 SELECT count(1) from (sql)
|
static SqlConnRunner |
create(DataSource ds)
实例化一个新的SQL运行对象
|
static SqlConnRunner |
create(Dialect dialect)
实例化一个新的SQL运行对象
|
static SqlConnRunner |
create(String driverClassName)
实例化一个新的SQL运行对象
|
<T> T |
find(Connection conn,
Collection<String> fields,
Entity where,
RsHandler<T> rsh)
查询
此方法不会关闭Connection |
List<Entity> |
find(Connection conn,
Entity where)
查询数据列表，返回字段在where参数中定义
|
<T> T |
find(Connection conn,
Entity where,
RsHandler<T> rsh,
String... fields)
查询，返回指定字段列表
此方法不会关闭Connection |
List<Entity> |
findAll(Connection conn,
Entity where)
查询数据列表，返回所有字段
|
List<Entity> |
findAll(Connection conn,
String tableName)
查询数据列表，返回所有字段
|
List<Entity> |
findBy(Connection conn,
String tableName,
String field,
Object value)
根据某个字段名条件查询数据列表，返回所有字段
|
List<Entity> |
findIn(Connection conn,
String tableName,
String field,
Object... values)
根据某个字段名条件查询数据列表，返回所有字段
|
List<Entity> |
findLike(Connection conn,
String tableName,
String field,
String value,
Condition.LikeType likeType)
根据某个字段名条件查询数据列表，返回所有字段
|
int[] |
insert(Connection conn,
Collection<Entity> records)
批量插入数据
需要注意的是，批量插入每一条数据结构必须一致。批量插入数据时会获取第一条数据的字段结构，之后的数据会按照这个格式插入。 也就是说假如第一条数据只有2个字段，后边数据多于这两个字段的部分将被抛弃。 此方法不会关闭Connection |
int |
insert(Connection conn,
Entity record)
插入数据
此方法不会关闭Connection |
Long |
insertForGeneratedKey(Connection conn,
Entity record)
插入数据
此方法不会关闭Connection |
List<Object> |
insertForGeneratedKeys(Connection conn,
Entity record)
插入数据
此方法不会关闭Connection |
int |
insertOrUpdate(Connection conn,
Entity record,
String... keys)
插入或更新数据
此方法不会关闭Connection |
PageResult<Entity> |
page(Connection conn,
Collection<String> fields,
Entity where,
int page,
int numPerPage)
分页查询
此方法不会关闭Connection |
<T> T |
page(Connection conn,
Collection<String> fields,
Entity where,
int pageNumber,
int numPerPage,
RsHandler<T> rsh)
分页查询
此方法不会关闭Connection |
PageResult<Entity> |
page(Connection conn,
Collection<String> fields,
Entity where,
Page page)
分页查询
此方法不会关闭Connection |
<T> T |
page(Connection conn,
Collection<String> fields,
Entity where,
Page page,
RsHandler<T> handler)
分页查询
此方法不会关闭Connection |
PageResult<Entity> |
page(Connection conn,
Entity where,
Page page)
分页全字段查询
此方法不会关闭Connection |
PageResult<Entity> |
page(Connection conn,
SqlBuilder sqlBuilder,
Page page)
分页查询
此方法不会关闭Connection |
count, del, find, getDialect, insert, insert, page, page, setCaseInsensitive, setDialect, setWrapper, setWrapper, updatepublic SqlConnRunner(Dialect dialect)
dialect - 方言public SqlConnRunner(String driverClassName)
driverClassName - 驱动类名，，用于识别方言public static SqlConnRunner create(Dialect dialect)
dialect - 方言public static SqlConnRunner create(DataSource ds)
ds - 数据源public static SqlConnRunner create(String driverClassName)
driverClassName - 驱动类名public int insertOrUpdate(Connection conn, Entity record, String... keys) throws SQLException
conn - 数据库连接record - 记录keys - 需要检查唯一性的字段SQLException - SQL执行异常public int[] insert(Connection conn, Collection<Entity> records) throws SQLException
conn - 数据库连接records - 记录列表，记录KV必须严格一致SQLException - SQL执行异常public int insert(Connection conn, Entity record) throws SQLException
conn - 数据库连接record - 记录SQLException - SQL执行异常public List<Object> insertForGeneratedKeys(Connection conn, Entity record) throws SQLException
conn - 数据库连接record - 记录SQLException - SQL执行异常public Long insertForGeneratedKey(Connection conn, Entity record) throws SQLException
conn - 数据库连接record - 记录SQLException - SQL执行异常public <T> T find(Connection conn, Collection<String> fields, Entity where, RsHandler<T> rsh) throws SQLException
T - 结果对象类型conn - 数据库连接对象fields - 返回的字段列表，null则返回所有字段where - 条件实体类（包含表名）rsh - 结果集处理对象SQLException - SQL执行异常public <T> T find(Connection conn, Entity where, RsHandler<T> rsh, String... fields) throws SQLException
T - 结果对象类型conn - 数据库连接对象where - 条件实体类（包含表名）rsh - 结果集处理对象fields - 字段列表，可变长参数如果无值表示查询全部字段SQLException - SQL执行异常public List<Entity> find(Connection conn, Entity where) throws SQLException
conn - 数据库连接对象where - 条件实体类（包含表名）SQLException - SQL执行异常public List<Entity> findAll(Connection conn, Entity where) throws SQLException
conn - 数据库连接对象where - 条件实体类（包含表名）SQLException - SQL执行异常public List<Entity> findAll(Connection conn, String tableName) throws SQLException
conn - 数据库连接对象tableName - 表名SQLException - SQL执行异常public List<Entity> findBy(Connection conn, String tableName, String field, Object value) throws SQLException
conn - 数据库连接对象tableName - 表名field - 字段名value - 字段值SQLException - SQL执行异常public List<Entity> findLike(Connection conn, String tableName, String field, String value, Condition.LikeType likeType) throws SQLException
conn - 数据库连接对象tableName - 表名field - 字段名value - 字段值likeType - Condition.LikeTypeSQLException - SQL执行异常public List<Entity> findIn(Connection conn, String tableName, String field, Object... values) throws SQLException
conn - 数据库连接对象tableName - 表名field - 字段名values - 字段值列表SQLException - SQL执行异常public long count(Connection conn, CharSequence selectSql) throws SQLException
conn - 数据库连接对象selectSql - 查询语句SQLException - SQL异常public <T> T page(Connection conn, Collection<String> fields, Entity where, int pageNumber, int numPerPage, RsHandler<T> rsh) throws SQLException
T - 结果对象类型conn - 数据库连接对象fields - 返回的字段列表，null则返回所有字段where - 条件实体类（包含表名）pageNumber - 页码numPerPage - 每页条目数rsh - 结果集处理对象SQLException - SQL执行异常public PageResult<Entity> page(Connection conn, SqlBuilder sqlBuilder, Page page) throws SQLException
conn - 数据库连接对象sqlBuilder - SQL构建器，可以使用SqlBuilder.of(CharSequence) 包装普通SQLpage - 分页对象SQLException - SQL执行异常public PageResult<Entity> page(Connection conn, Collection<String> fields, Entity where, int page, int numPerPage) throws SQLException
conn - 数据库连接对象fields - 返回的字段列表，null则返回所有字段where - 条件实体类（包含表名）page - 页码numPerPage - 每页条目数SQLException - SQL执行异常public PageResult<Entity> page(Connection conn, Entity where, Page page) throws SQLException
conn - 数据库连接对象where - 条件实体类（包含表名）page - 分页对象SQLException - SQL执行异常public PageResult<Entity> page(Connection conn, Collection<String> fields, Entity where, Page page) throws SQLException
conn - 数据库连接对象fields - 返回的字段列表，null则返回所有字段where - 条件实体类（包含表名）page - 分页对象SQLException - SQL执行异常public <T> T page(Connection conn, Collection<String> fields, Entity where, Page page, RsHandler<T> handler) throws SQLException
T - 结果类型，取决于 RsHandler 的处理逻辑conn - 数据库连接对象fields - 返回的字段列表，null则返回所有字段where - 条件实体类（包含表名）page - 分页对象handler - 结果集处理器SQLException - SQL执行异常Copyright © 2021. All rights reserved.