com.xiaoleilu.hutool.db
类 SqlRunner

java.lang.Object
  com.xiaoleilu.hutool.db.SqlRunner

public class SqlRunner
extends Object

SQL执行类

作者：

Luxiaolei

构造方法摘要

SqlRunner(DataSource ds)

方法摘要

Long	execute(Connection conn, String sql, Object... params) 执行非查询语句 发查询语句包括 插入、更新、删除 此方法不会关闭Connection
Long	execute(String sql, Object... params) 执行非查询语句 发查询语句包括 插入、更新、删除
int[]	executeBatch(Connection conn, String sql, Object[]... paramsBatch) 批量执行非查询语句 发查询语句包括 插入、更新、删除 此方法不会关闭Connection
int[]	executeBatch(String sql, Object[]... paramsBatch) 批量执行非查询语句
Long	insert(Connection conn, String tableName, boolean isReplace, Entity record) 插入数据
Long	insert(String tableName, boolean isReplace, Entity record) 插入数据
int[]	insertBatch(Connection conn, String tableName, boolean isReplace, Entity... records) 批量插入数据
int[]	insertBatch(String tableName, boolean isReplace, Entity... records) 批量插入数据
<T> T	query(Connection conn, String sql, RsHandler<T> rsh, Object... params) 查询 发查询语句包括 插入、更新、删除 此方法不会关闭Connection
<T> T	query(String sql, RsHandler<T> rsh, Object... params) 查询

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

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

构造方法详细信息

SqlRunner

public SqlRunner(DataSource ds)

方法详细信息

query

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

查询

参数：

sql - 查询语句

rsh - 结果集处理对象

params - 参数

返回：

结果对象

抛出：

SQLException

query

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

查询
发查询语句包括 插入、更新、删除
此方法不会关闭Connection

参数：

conn - 数据库连接对象

sql - 查询语句

rsh - 结果集处理对象

params - 参数

返回：

结果对象

抛出：

SQLException

execute

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

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

参数：

sql - SQL

params - 参数

返回：

主键

抛出：

SQLException

execute

public Long execute(Connection conn,
                    String sql,
                    Object... params)
             throws SQLException

执行非查询语句
发查询语句包括 插入、更新、删除
此方法不会关闭Connection

参数：

conn - 数据库连接对象

sql - SQL

params - 参数

返回：

主键

抛出：

SQLException

executeBatch

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

批量执行非查询语句

参数：

sql - SQL

paramsBatch - 批量的参数

返回：

每个SQL执行影响的行数

抛出：

SQLException

executeBatch

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

批量执行非查询语句
发查询语句包括 插入、更新、删除
此方法不会关闭Connection

参数：

conn - 数据库连接对象

sql - SQL

paramsBatch - 批量的参数

返回：

每个SQL执行影响的行数

抛出：

SQLException

insert

public Long insert(Connection conn,
                   String tableName,
                   boolean isReplace,
                   Entity record)
            throws SQLException

插入数据

参数：

conn - 数据库连接

tableName - 表名

isReplace - 是否替换（会调用SQL的replace into方法）

record - 记录

返回：

主键

抛出：

SQLException

insert

public Long insert(String tableName,
                   boolean isReplace,
                   Entity record)
            throws SQLException

插入数据

参数：

tableName - 表名

isReplace - 是否替换（会调用SQL的replace into方法）

record - 记录

返回：

主键

抛出：

SQLException

insertBatch

public int[] insertBatch(Connection conn,
                         String tableName,
                         boolean isReplace,
                         Entity... records)
                  throws SQLException

批量插入数据

参数：

conn - 数据库连接

tableName - 表名

isReplace - 是否替换（会调用SQL的replace into方法）

records - 记录

返回：

行数

抛出：

SQLException

insertBatch

public int[] insertBatch(String tableName,
                         boolean isReplace,
                         Entity... records)
                  throws SQLException

批量插入数据

参数：

tableName - 表名

isReplace - 是否替换（会调用SQL的replace into方法）

records - 记录

返回：

行数

抛出：

SQLException