org.dromara.hutool.db

Class Session

java.lang.Object

org.dromara.hutool.db.DefaultConnectionHolder

org.dromara.hutool.db.AbstractDb<Session>

org.dromara.hutool.db.Session

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, ConnectionHolder

public class Session
extends AbstractDb<Session>
implements Closeable

数据库SQL执行会话
会话通过共用Connection而可以实现JDBC事务
一个会话只维护一个连接，推荐在执行完后关闭Session，避免重用
本对象并不是线程安全的，多个线程共用一个Session将会导致不可预知的问题

Author:

loolly

See Also:

Serialized Form

Field Summary

Fields inherited from class org.dromara.hutool.db.AbstractDb

caseInsensitive, dbConfig, isSupportTransaction, runner

Fields inherited from class org.dromara.hutool.db.DefaultConnectionHolder

ds

Constructor Summary

Constructors

Constructor and Description
Session(DataSource ds) 构造，从DataSource中识别方言
Session(DataSource ds, Dialect dialect) 构造

Method Summary

Modifier and Type	Method and Description
void	beginTransaction() 开始事务
void	close()
void	commit() 提交事务
static Session	of() 创建默认数据源会话
static Session	of(DataSource ds) 创建会话
static Session	of(String group) 创建会话
void	quietRollback() 静默回滚事务 回滚事务
void	quietRollback(Savepoint savepoint) 静默回滚到某个保存点，保存点的设置请使用setSavepoint方法
void	rollback() 回滚事务
void	rollback(Savepoint savepoint) 回滚到某个保存点，保存点的设置请使用setSavepoint方法
Savepoint	setSavepoint() 设置保存点
Savepoint	setSavepoint(String name) 设置保存点
void	setTransactionIsolation(int level) 设置事务的隔离级别 Connection.TRANSACTION_NONE 驱动不支持事务 Connection.TRANSACTION_READ_UNCOMMITTED 允许脏读、不可重复读和幻读 Connection.TRANSACTION_READ_COMMITTED 禁止脏读，但允许不可重复读和幻读 Connection.TRANSACTION_REPEATABLE_READ 禁止脏读和不可重复读，单运行幻读 Connection.TRANSACTION_SERIALIZABLE 禁止脏读、不可重复读和幻读
void	tx(SerConsumer<Session> func) 在事务中执行操作，通过实现SerConsumer接口的call方法执行多条SQL语句从而完成事务

Methods inherited from class org.dromara.hutool.db.AbstractDb

checkTransactionSupported, count, count, count, del, del, disableWrapper, execute, executeBatch, executeBatch, executeBatch, executeForGeneratedKey, find, find, find, find, find, find, findAll, findAll, findAll, findBy, findBy, findLike, get, get, getRunner, insert, insert, insertForGeneratedKey, insertForGeneratedKeys, insertOrUpdate, page, page, page, page, page, page, page, page, pageForBeanList, pageForBeanResult, pageForEntityList, query, query, query, query, query, query, queryNumber, queryOne, queryString, setCaseInsensitive, setRunner, setWrapper, setWrapper, update, upsert

Methods inherited from class org.dromara.hutool.db.DefaultConnectionHolder

closeConnection, getConnection, getDs

Methods inherited from class java.lang.Object

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

Constructor Detail

Session

public Session(DataSource ds)

构造，从DataSource中识别方言

Parameters:

ds - 数据源

Session

public Session(DataSource ds,
               Dialect dialect)

构造

Parameters:

ds - 数据源

dialect - 方言

Method Detail

of

public static Session of()

创建默认数据源会话

Returns:

Session

Since:

3.2.3

of

public static Session of(String group)

创建会话

Parameters:

group - 分组

Returns:

Session

Since:

4.0.11

of

public static Session of(DataSource ds)

创建会话

Parameters:

ds - 数据源

Returns:

Session

beginTransaction

public void beginTransaction()
                      throws DbException

开始事务

Throws:

DbException - SQL执行异常

commit

public void commit()
            throws DbException

提交事务

Throws:

DbException - SQL执行异常

rollback

public void rollback()
              throws DbException

回滚事务

Throws:

DbException - SQL执行异常

quietRollback

public void quietRollback()

静默回滚事务
回滚事务

rollback

public void rollback(Savepoint savepoint)
              throws DbException

回滚到某个保存点，保存点的设置请使用setSavepoint方法

Parameters:

savepoint - 保存点

Throws:

DbException - SQL执行异常

quietRollback

public void quietRollback(Savepoint savepoint)

静默回滚到某个保存点，保存点的设置请使用setSavepoint方法

Parameters:

savepoint - 保存点

setSavepoint

public Savepoint setSavepoint()
                       throws DbException

设置保存点

Returns:

保存点对象

Throws:

DbException - SQL执行异常

setSavepoint

public Savepoint setSavepoint(String name)
                       throws SQLException

设置保存点

Parameters:

name - 保存点的名称

Returns:

保存点对象

Throws:

SQLException - SQL执行异常

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws DbException

设置事务的隔离级别
Connection.TRANSACTION_NONE 驱动不支持事务
Connection.TRANSACTION_READ_UNCOMMITTED 允许脏读、不可重复读和幻读
Connection.TRANSACTION_READ_COMMITTED 禁止脏读，但允许不可重复读和幻读
Connection.TRANSACTION_REPEATABLE_READ 禁止脏读和不可重复读，单运行幻读
Connection.TRANSACTION_SERIALIZABLE 禁止脏读、不可重复读和幻读

Parameters:

level - 隔离级别

Throws:

DbException - SQL执行异常

tx

public void tx(SerConsumer<Session> func)
        throws DbException

在事务中执行操作，通过实现SerConsumer接口的call方法执行多条SQL语句从而完成事务

Parameters:

func - 函数抽象，在函数中执行多个SQL操作，多个操作会被合并为同一事务

Throws:

DbException - SQL异常

Since:

3.2.3

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable