org.noear.solon.data.sqlink.base.session

类 DefaultSqlSession

java.lang.Object

org.noear.solon.data.sqlink.base.session.DefaultSqlSession

所有已实现的接口:

SqlSession

public class DefaultSqlSession
extends java.lang.Object
implements SqlSession

从以下版本开始:

3.0

嵌套类概要

从接口继承的嵌套类/接口 org.noear.solon.data.sqlink.base.session.SqlSession

SqlSession.Function<T,R>

字段概要

字段

限定符和类型	字段和说明
protected SqLinkConfig	config
protected DataSourceManager	dataSourceManager
protected TransactionManager	transactionManager

构造器概要

构造器

构造器和说明
DefaultSqlSession(SqLinkConfig config, DataSourceManager dataSourceManager, TransactionManager transactionManager)

方法概要

限定符和类型	方法和说明
long	executeDelete(java.lang.String sql, java.util.Collection<SqlValue> sqlValues) 执行删除，并返回影响行数
protected long	executeInsert(java.sql.Connection connection, java.lang.String sql, java.util.Collection<SqlValue> sqlValues, int length)
long	executeInsert(java.lang.String sql, java.util.Collection<SqlValue> sqlValues, int length) 执行插入，并返回影响行数
<R> R	executeQuery(SqlSession.Function<java.sql.ResultSet,R> func, java.lang.String sql, java.util.Collection<SqlValue> sqlValues) 执行查询，并返回结果
protected long	executeUpdate(java.sql.Connection connection, java.lang.String sql, java.util.Collection<SqlValue> sqlValues)
long	executeUpdate(java.lang.String sql, java.util.Collection<SqlValue> sqlValues) 执行更新，并返回影响行数
protected void	setObjects(java.sql.PreparedStatement preparedStatement, java.util.Collection<SqlValue> sqlValues)
protected boolean	setObjects(java.sql.PreparedStatement preparedStatement, java.util.Collection<SqlValue> sqlValues, int length)

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

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

字段详细资料

config

protected final SqLinkConfig config

dataSourceManager

protected final DataSourceManager dataSourceManager

transactionManager

protected final TransactionManager transactionManager

构造器详细资料

DefaultSqlSession

public DefaultSqlSession(SqLinkConfig config,
                         DataSourceManager dataSourceManager,
                         TransactionManager transactionManager)

方法详细资料

executeQuery

public <R> R executeQuery(SqlSession.Function<java.sql.ResultSet,R> func,
                          java.lang.String sql,
                          java.util.Collection<SqlValue> sqlValues)

从接口复制的说明: SqlSession

执行查询，并返回结果

指定者:

executeQuery 在接口中 SqlSession

参数:

func - 对ResultSet进行操作并且返回结果

sql - sql语句

sqlValues - 参数

executeInsert

public long executeInsert(java.lang.String sql,
                          java.util.Collection<SqlValue> sqlValues,
                          int length)

从接口复制的说明: SqlSession

执行插入，并返回影响行数

指定者:

executeInsert 在接口中 SqlSession

参数:

sql - sql语句

sqlValues - 参数

length - 批量下每轮的长度

executeDelete

public long executeDelete(java.lang.String sql,
                          java.util.Collection<SqlValue> sqlValues)

从接口复制的说明: SqlSession

执行删除，并返回影响行数

指定者:

executeDelete 在接口中 SqlSession

参数:

sql - sql语句

sqlValues - 参数

executeUpdate

public long executeUpdate(java.lang.String sql,
                          java.util.Collection<SqlValue> sqlValues)

从接口复制的说明: SqlSession

执行更新，并返回影响行数

指定者:

executeUpdate 在接口中 SqlSession

参数:

sql - sql语句

sqlValues - 参数

executeInsert

protected long executeInsert(java.sql.Connection connection,
                             java.lang.String sql,
                             java.util.Collection<SqlValue> sqlValues,
                             int length)

executeUpdate

protected long executeUpdate(java.sql.Connection connection,
                             java.lang.String sql,
                             java.util.Collection<SqlValue> sqlValues)

setObjects

protected void setObjects(java.sql.PreparedStatement preparedStatement,
                          java.util.Collection<SqlValue> sqlValues)
                   throws java.sql.SQLException

抛出:

java.sql.SQLException

setObjects

protected boolean setObjects(java.sql.PreparedStatement preparedStatement,
                             java.util.Collection<SqlValue> sqlValues,
                             int length)
                      throws java.sql.SQLException,
                             java.lang.reflect.InvocationTargetException,
                             java.lang.IllegalAccessException

抛出:

java.sql.SQLException

java.lang.reflect.InvocationTargetException

java.lang.IllegalAccessException