com.xiaoleilu.hutool.db

类 AbstractSqlRunner

java.lang.Object

com.xiaoleilu.hutool.db.AbstractSqlRunner

直接已知子类:

Session, SqlRunner

public abstract class AbstractSqlRunner
extends Object

抽象SQL执行类
通过给定的数据源执行给定SQL或者给定数据源和方言，执行相应的CRUD操作
提供抽象方法getConnection和closeConnection，用于自定义数据库连接的打开和关闭

作者:

Luxiaolei

字段概要

字段

限定符和类型	字段和说明
protected SqlConnRunner	runner

构造器概要

构造器

构造器和说明
AbstractSqlRunner()

方法概要

方法

限定符和类型	方法和说明
abstract void	closeConnection(Connection conn) 关闭连接 自定义关闭连接有利于自定义回收连接机制，或者不关闭
int	count(Entity where) 结果的条目数
int	del(Entity where) 删除数据
int	del(String tableName, String field, Object value) 删除数据
int	execute(String sql, Object... params) 执行非查询语句 语句包括 插入、更新、删除
int[]	executeBatch(String sql, Object[]... paramsBatch) 批量执行非查询语句
Long	executeForGeneratedKey(String sql, Object... params) 执行非查询语句 语句包括 插入、更新、删除
<T> T	find(Collection<String> fields, Entity where, RsHandler<T> rsh) 查询
<T> T	find(Entity where, RsHandler<T> rsh) 查询，返回所有字段
List<Entity>	findAll(Entity where) 查询数据列表，返回所有字段
List<Entity>	findAll(String tableName) 查询数据列表，返回所有字段
List<Entity>	findBy(String tableName, String field, Object value) 根据某个字段名条件查询数据列表，返回所有字段
List<Entity>	findLike(String tableName, String field, String value, Condition.LikeType likeType) 根据某个字段名条件查询数据列表，返回所有字段
abstract Connection	getConnection() 获得链接。
SqlConnRunner	getRunner()
int[]	insert(Collection<Entity> records) 批量插入数据
int	insert(Entity record) 插入数据
Long	insertForGeneratedKey(Entity record) 插入数据
List<Object>	insertForGeneratedKeys(Entity record) 插入数据
PageResult<Entity>	page(Collection<String> fields, Entity where, int page, int numPerPage) 分页查询
<T> T	page(Collection<String> fields, Entity where, int page, int numPerPage, RsHandler<T> rsh) 分页查询
PageResult<Entity>	page(Collection<String> fields, Entity where, Page page) 分页查询
<T> T	page(Collection<String> fields, Entity where, Page page, RsHandler<T> rsh) 分页查询
PageResult<Entity>	page(Entity where, Page page) 分页查询
<T> T	query(String sql, RsHandler<T> rsh, Object... params) 查询
void	setRunner(SqlConnRunner runner)
int	update(Entity record, Entity where) 更新数据

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

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

字段详细资料

runner

protected SqlConnRunner runner

构造器详细资料

AbstractSqlRunner

public AbstractSqlRunner()

方法详细资料

getConnection

public abstract Connection getConnection()
                                  throws SQLException

获得链接。根据实现不同，可以自定义获取连接的方式

返回:

Connection

抛出:

SQLException

closeConnection

public abstract void closeConnection(Connection conn)

关闭连接
自定义关闭连接有利于自定义回收连接机制，或者不关闭

参数:

conn - 连接 Connection

query

public <T> T query(String sql,
          RsHandler<T> rsh,
          Object... params)
        throws SQLException

查询

参数:

sql - 查询语句

rsh - 结果集处理对象

params - 参数

返回:

结果对象

抛出:

SQLException

execute

public int execute(String sql,
          Object... params)
            throws SQLException

执行非查询语句
语句包括 插入、更新、删除

参数:

sql - SQL

params - 参数

返回:

影响行数

抛出:

SQLException

executeForGeneratedKey

public Long executeForGeneratedKey(String sql,
                          Object... params)
                            throws SQLException

执行非查询语句
语句包括 插入、更新、删除

参数:

sql - SQL

params - 参数

返回:

主键

抛出:

SQLException

executeBatch

public int[] executeBatch(String sql,
                 Object[]... paramsBatch)
                   throws SQLException

批量执行非查询语句

参数:

sql - SQL

paramsBatch - 批量的参数

返回:

每个SQL执行影响的行数

抛出:

SQLException

insert

public int insert(Entity record)
           throws SQLException

插入数据

参数:

record - 记录

返回:

插入行数

抛出:

SQLException

insert

public int[] insert(Collection<Entity> records)
             throws SQLException

批量插入数据

参数:

records - 记录列表

返回:

插入行数

抛出:

SQLException

insertForGeneratedKeys

public List<Object> insertForGeneratedKeys(Entity record)
                                    throws SQLException

插入数据

参数:

record - 记录

返回:

主键列表

抛出:

SQLException

insertForGeneratedKey

public Long insertForGeneratedKey(Entity record)
                           throws SQLException

插入数据

参数:

record - 记录

返回:

主键

抛出:

SQLException

del

public int del(String tableName,
      String field,
      Object value)
        throws SQLException

删除数据

参数:

tableName - 表名

field - 字段名，最好是主键

value - 值，值可以是列表或数组，被当作IN查询处理

返回:

删除行数

抛出:

SQLException

del

public int del(Entity where)
        throws SQLException

删除数据

参数:

where - 条件

返回:

影响行数

抛出:

SQLException

update

public int update(Entity record,
         Entity where)
           throws SQLException

更新数据

参数:

record - 记录

返回:

影响行数

抛出:

SQLException

find

public <T> T find(Collection<String> fields,
         Entity where,
         RsHandler<T> rsh)
       throws SQLException

查询

参数:

fields - 返回的字段列表，null则返回所有字段

where - 条件实体类（包含表名）

rsh - 结果集处理对象

返回:

结果对象

抛出:

SQLException

find

public <T> T find(Entity where,
         RsHandler<T> rsh)
       throws SQLException

查询，返回所有字段

参数:

where - 条件实体类（包含表名）

rsh - 结果集处理对象

返回:

结果对象

抛出:

SQLException

findAll

public List<Entity> findAll(Entity where)
                     throws SQLException

查询数据列表，返回所有字段

参数:

where - 条件实体类（包含表名）

返回:

数据对象列表

抛出:

SQLException

findAll

public List<Entity> findAll(String tableName)
                     throws SQLException

查询数据列表，返回所有字段

参数:

tableName - 表名

返回:

数据对象列表

抛出:

SQLException

findBy

public List<Entity> findBy(String tableName,
                  String field,
                  Object value)
                    throws SQLException

根据某个字段名条件查询数据列表，返回所有字段

参数:

tableName - 表名

field - 字段名

value - 字段值

返回:

数据对象列表

抛出:

SQLException

findLike

public List<Entity> findLike(String tableName,
                    String field,
                    String value,
                    Condition.LikeType likeType)
                      throws SQLException

根据某个字段名条件查询数据列表，返回所有字段

参数:

tableName - 表名

field - 字段名

value - 字段值

likeType - Condition.LikeType

返回:

数据对象列表

抛出:

SQLException

count

public int count(Entity where)
          throws SQLException

结果的条目数

参数:

where - 查询条件

返回:

复合条件的结果数

抛出:

SQLException

page

public <T> T page(Collection<String> fields,
         Entity where,
         int page,
         int numPerPage,
         RsHandler<T> rsh)
       throws SQLException

分页查询

参数:

fields - 返回的字段列表，null则返回所有字段

where - 条件实体类（包含表名）

page - 页码

numPerPage - 每页条目数

rsh - 结果集处理对象

返回:

结果对象

抛出:

SQLException

page

public <T> T page(Collection<String> fields,
         Entity where,
         Page page,
         RsHandler<T> rsh)
       throws SQLException

分页查询

参数:

fields - 返回的字段列表，null则返回所有字段

where - 条件实体类（包含表名）

page - 分页对象

rsh - 结果集处理对象

返回:

结果对象

抛出:

SQLException

page

public PageResult<Entity> page(Collection<String> fields,
                      Entity where,
                      int page,
                      int numPerPage)
                        throws SQLException

分页查询

参数:

fields - 返回的字段列表，null则返回所有字段

where - 条件实体类（包含表名）

page - 页码

numPerPage - 每页条目数

返回:

结果对象

抛出:

SQLException

page

public PageResult<Entity> page(Collection<String> fields,
                      Entity where,
                      Page page)
                        throws SQLException

分页查询

参数:

fields - 返回的字段列表，null则返回所有字段

where - 条件实体类（包含表名）

page - 页码

返回:

结果对象

抛出:

SQLException

page

public PageResult<Entity> page(Entity where,
                      Page page)
                        throws SQLException

分页查询

参数:

where - 条件实体类（包含表名）

page - 页码

返回:

分页结果集

抛出:

SQLException

getRunner

public SqlConnRunner getRunner()

setRunner

public void setRunner(SqlConnRunner runner)