org.noear.solon.data.sql.impl

类 SimpleSqlQuerier

java.lang.Object

org.noear.solon.data.sql.impl.SimpleSqlQuerier

所有已实现的接口:

SqlQuerier

public class SimpleSqlQuerier
extends java.lang.Object
implements SqlQuerier

Sql 查询器简单实现

从以下版本开始:

3.0

构造器概要

构造器

构造器和说明
SimpleSqlQuerier(javax.sql.DataSource dataSource, java.lang.String sql)

方法概要

限定符和类型	方法和说明
protected org.noear.solon.data.sql.impl.StatementHolder	buildStatement(SqlCommand cmd, boolean returnKeys, boolean isStream) 开始命令处理
protected java.sql.Connection	getConnection() 获取连接（为转换提供重写机会）
SqlQuerier	params(java.util.Collection<java.lang.Object[]> argsList) 绑定参数（用于批处理）
<S> SqlQuerier	params(java.util.Collection<S> argsList, java.util.function.Supplier<StatementBinder<S>> binderSupplier) 绑定参数（用于批处理）
SqlQuerier	params(java.lang.Object... args) 绑定参数
<S> SqlQuerier	params(S args, StatementBinder<S> binder) 绑定参数
<T> T	queryRow(java.lang.Class<T> tClass) 查询并获取行
<T> T	queryRow(RowConverter<T> converter) 查询并获取行
protected <T> java.lang.Object	queryRowDo(RowConverter<T> converter)
<T> RowIterator<T>	queryRowIterator(int fetchSize, java.lang.Class<T> tClass) 查询并获取行遍历器（流式读取）
<T> RowIterator<T>	queryRowIterator(int fetchSize, RowConverter<T> converter) 查询并获取行遍历器（流式读取）
protected <T> RowIterator<T>	queryRowIteratorDo(int fetchSize, RowConverter<T> converter)
<T> java.util.List<T>	queryRowList(java.lang.Class<T> tClass) 查询并获取行列表
<T> java.util.List<T>	queryRowList(RowConverter<T> converter) 查询并获取行列表
protected <T> java.util.List<T>	queryRowListDo(RowConverter<T> converter)
<T> T	queryValue() 查询并获取值
<T> java.util.List<T>	queryValueList() 查询并获取值列表
int	update() 更新（插入、或更新、或删除）
int[]	updateBatch() 批量更新（插入、或更新、或删除）
protected int[]	updateBatchDo()
<T> java.util.List<T>	updateBatchReturnKeys() 批量更新并返回主键（插入、或更新、或删除）
protected <T> java.util.List<T>	updateBatchReturnKeysDo()
protected int	updateDo()
<T> T	updateReturnKey() 更新并返回主键
protected java.lang.Object	updateReturnKeyDo()

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

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

构造器详细资料

SimpleSqlQuerier

public SimpleSqlQuerier(javax.sql.DataSource dataSource,
                        java.lang.String sql)

方法详细资料

params

public SqlQuerier params(java.lang.Object... args)

从接口复制的说明: SqlQuerier

绑定参数

指定者:

params 在接口中 SqlQuerier

params

public <S> SqlQuerier params(S args,
                             StatementBinder<S> binder)

从接口复制的说明: SqlQuerier

绑定参数

指定者:

params 在接口中 SqlQuerier

params

public SqlQuerier params(java.util.Collection<java.lang.Object[]> argsList)

从接口复制的说明: SqlQuerier

绑定参数（用于批处理）

指定者:

params 在接口中 SqlQuerier

params

public <S> SqlQuerier params(java.util.Collection<S> argsList,
                             java.util.function.Supplier<StatementBinder<S>> binderSupplier)

从接口复制的说明: SqlQuerier

绑定参数（用于批处理）

指定者:

params 在接口中 SqlQuerier

queryValue

public <T> T queryValue()
                 throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取值

指定者:

queryValue 在接口中 SqlQuerier

返回:

值

抛出:

java.sql.SQLException

queryValueList

public <T> java.util.List<T> queryValueList()
                                     throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取值列表

指定者:

queryValueList 在接口中 SqlQuerier

返回:

值列表

抛出:

java.sql.SQLException

queryRow

public <T> T queryRow(java.lang.Class<T> tClass)
               throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取行

指定者:

queryRow 在接口中 SqlQuerier

参数:

tClass - Map.class or T.class

返回:

值

抛出:

java.sql.SQLException

queryRow

public <T> T queryRow(RowConverter<T> converter)
               throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取行

指定者:

queryRow 在接口中 SqlQuerier

返回:

值

抛出:

java.sql.SQLException

queryRowDo

protected <T> java.lang.Object queryRowDo(RowConverter<T> converter)
                                   throws java.sql.SQLException

抛出:

java.sql.SQLException

queryRowList

public <T> java.util.List<T> queryRowList(java.lang.Class<T> tClass)
                                   throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取行列表

指定者:

queryRowList 在接口中 SqlQuerier

参数:

tClass - Map.class or T.class

返回:

值列表

抛出:

java.sql.SQLException

queryRowList

public <T> java.util.List<T> queryRowList(RowConverter<T> converter)
                                   throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取行列表

指定者:

queryRowList 在接口中 SqlQuerier

返回:

值列表

抛出:

java.sql.SQLException

queryRowListDo

protected <T> java.util.List<T> queryRowListDo(RowConverter<T> converter)
                                        throws java.sql.SQLException

抛出:

java.sql.SQLException

queryRowIterator

public <T> RowIterator<T> queryRowIterator(int fetchSize,
                                           java.lang.Class<T> tClass)
                                    throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取行遍历器（流式读取）

指定者:

queryRowIterator 在接口中 SqlQuerier

tClass - Map.class or T.class

返回:

行遍历器

抛出:

java.sql.SQLException

queryRowIterator

public <T> RowIterator<T> queryRowIterator(int fetchSize,
                                           RowConverter<T> converter)
                                    throws java.sql.SQLException

从接口复制的说明: SqlQuerier

查询并获取行遍历器（流式读取）

指定者:

queryRowIterator 在接口中 SqlQuerier

返回:

行遍历器

抛出:

java.sql.SQLException

queryRowIteratorDo

protected <T> RowIterator<T> queryRowIteratorDo(int fetchSize,
                                                RowConverter<T> converter)
                                         throws java.sql.SQLException

抛出:

java.sql.SQLException

update

public int update()
           throws java.sql.SQLException

从接口复制的说明: SqlQuerier

更新（插入、或更新、或删除）

指定者:

update 在接口中 SqlQuerier

返回:

受影响行数

抛出:

java.sql.SQLException

updateDo

protected int updateDo()
                throws java.sql.SQLException

抛出:

java.sql.SQLException

updateReturnKey

public <T> T updateReturnKey()
                      throws java.sql.SQLException

从接口复制的说明: SqlQuerier

更新并返回主键

指定者:

updateReturnKey 在接口中 SqlQuerier

返回:

主键

抛出:

java.sql.SQLException

updateReturnKeyDo

protected java.lang.Object updateReturnKeyDo()
                                      throws java.sql.SQLException

抛出:

java.sql.SQLException

updateBatch

public int[] updateBatch()
                  throws java.sql.SQLException

从接口复制的说明: SqlQuerier

批量更新（插入、或更新、或删除）

指定者:

updateBatch 在接口中 SqlQuerier

返回:

受影响行数组

抛出:

java.sql.SQLException

updateBatchDo

protected int[] updateBatchDo()
                       throws java.sql.SQLException

抛出:

java.sql.SQLException

updateBatchReturnKeys

public <T> java.util.List<T> updateBatchReturnKeys()
                                            throws java.sql.SQLException

从接口复制的说明: SqlQuerier

批量更新并返回主键（插入、或更新、或删除）

指定者:

updateBatchReturnKeys 在接口中 SqlQuerier

返回:

受影响行数组

抛出:

java.sql.SQLException

updateBatchReturnKeysDo

protected <T> java.util.List<T> updateBatchReturnKeysDo()
                                                 throws java.sql.SQLException

抛出:

java.sql.SQLException

buildStatement

protected org.noear.solon.data.sql.impl.StatementHolder buildStatement(SqlCommand cmd,
                                                                       boolean returnKeys,
                                                                       boolean isStream)
                                                                throws java.sql.SQLException

开始命令处理

抛出:

java.sql.SQLException

getConnection

protected java.sql.Connection getConnection()
                                     throws java.sql.SQLException

获取连接（为转换提供重写机会）

抛出:

java.sql.SQLException