SpringBoot トランザクションの詳細な紹介

重要な概念

自動コミット モード

mysql データベースの場合、デフォルトでは、データベースは自動コミット モードです。各ステートメントは個別のトランザクション内にあり、ステートメントが実行されると、実行が成功するとトランザクションは暗黙的にコミットされ、実行が失敗すると暗黙的にロールバックされます。通常のトランザクション管理では、関連する一連の操作が 1 つのトランザクション内に存在するため、データベースの自動投入モードをオフにする必要があります。表示方法は次のとおりです。

コマンドが自動的に投入されるかどうかを確認します (オン)自動送信がオンであることを意味し、値は 1、OFF は自動送信をオフにすることを意味し、値は 0):

show variables like 'autocommit';

自動送信をオフにした後、ユーザーは常にトランザクション状態になります。現在のトランザクションは、コミットまたはロールバック ステートメントが実行されるまで終了しません。新しいトランザクションを再度開始してください。

DataSource connection = masterDataSource.getConnection();
connection.setAutoCommit(false);

トランザクション分離レベル

分離レベルとは、複数の同時トランザクション間の分離の程度を指します。 TransactionDefinition インターフェイスでは、分離レベルを表す 5 つの定数が定義されています:

1、TransactionDefinition.ISOLATION_DEFAULT: これはデフォルト値であり、基礎となるデータベースのデフォルト分離レベルが使用されることを示します。ほとんどのデータベースでは、この値は通常 TransactionDefinition.ISOLATION_READ_COMMITTED です。

2, TransactionDefinition.ISOLATION_READ_UNCOMMITTED: この分離レベルは、トランザクションが別のトランザクションによって変更されたがまだコミットされていないデータを読み取ることができることを示します。このレベルでは、ダーティ読み取り、反復不能読み取り、およびファントム読み取りが防止されないため、この分離レベルが使用されることはほとんどありません。たとえば、PostgreSQL には実際にはこのレベルがありません。

3、TransactionDefinition.ISOLATION_READ_COMMITTED: この分離レベルは、トランザクションが別のトランザクションによって送信されたデータのみを読み取ることができることを示します。このレベルはダーティ リードを防止し、ほとんどの場合に推奨される値です。

4, TransactionDefinition.ISOLATION_REPEATABLE_READ: この分離レベルは、トランザクションがプロセス全体を通じてクエリを複数回繰り返し実行でき、毎回返されるレコードが同じであることを示します。このレベルは、ダーティ読み取りと非反復読み取りを防止します。

5, TransactionDefinition.ISOLATION_SERIALIZABLE: すべてのトランザクションは 1 つずつ順番に実行されるため、トランザクション間の干渉の可能性はありません。反復不可能な読み取り、およびファントム読み取り。しかし、これはプログラムのパフォーマンスに重大な影響を与えます。通常、このレベルは使用されません。

トランザクション伝播動作

いわゆるトランザクション伝播動作とは、現在のトランザクションを開始する前にトランザクション コンテキストがすでに存在する場合、トランザクション コンテキストを指定するためのオプションがいくつかあることを意味します。トランザクションメソッドの実行動作。 TransactionDefinition 定義には、伝播動作を示す次の定数が含まれています:

1, TransactionDefinition.PROPAGATION_REQUIRED: トランザクションが現在存在する場合は、トランザクションに参加します。現在トランザクションが存在しない場合は、トランザクションを作成します。取引。これはデフォルト値です。

2, TransactionDefinition.PROPAGATION_REQUIRES_NEW: 新しいトランザクションを作成します。現在トランザクションが存在する場合は、現在のトランザクションを一時停止します。

3, TransactionDefinition.PROPAGATION_SUPPORTS: 現在トランザクションがある場合はトランザクションに参加し、現在トランザクションがない場合は非トランザクションで実行を継続します。

4, TransactionDefinition.PROPAGATION_NOT_SUPPORTED: 非トランザクション モードで実行します。現在トランザクションが存在する場合、現在のトランザクションは一時停止されます。

5, TransactionDefinition.PROPAGATION_NEVER: 非トランザクション モードで実行します。トランザクションが現在存在する場合は、例外がスローされます。

6, TransactionDefinition.PROPAGATION_MANDATORY: 現在トランザクションがある場合はトランザクションに参加し、現在トランザクションがない場合は例外をスローします。

7, TransactionDefinition.PROPAGATION_NESTED: トランザクションが現在存在する場合は、現在のトランザクションのネストされたトランザクションとして実行するトランザクションを作成します。現在トランザクションが存在しない場合、この値は次と同等です。 TransactionDefinition.PROPAGATION_REQUIRED。

セーフポイント (セーブポイント)

まず、セーブポイントはロールバック用であることを知っておく必要があります。セーブポイントの数に制限はありません。セーブポイントと仮想マシン内スナップショットは似ており、セーブポイントはトランザクション内のポイントです。トランザクションの一部をキャンセルするために使用されます。トランザクションが終了すると、トランザクションで定義されたすべてのセーブポイントが自動的に削除されます。

ロールバック実行時にセーブポイントを指定することで、指定した時点までロールバックすることができます。

トランザクションをロールバックするためのいくつかの重要な操作

1. セーブポイントを a に設定します

2. セーブポイント a をキャンセルした後、トランザクションは ## にロールバックします

# 3. すべてのトランザクションのロールバックをキャンセルします

注: このロールバック トランザクションはコミット前に使用する必要があります;

public class UserRepository {
 
	
	private DataSource masterDataSource;
	private Connection connection = null;
	@Autowired
	public void setMasterDataSource(DataSource masterDataSource) {
		this.masterDataSource = masterDataSource;
	}
 
 
	@Transactional
	public boolean save(User user) {
		try {
			connection = masterDataSource.getConnection();
			connection.setAutoCommit(false);
			//设置保护点
			Savepoint saveUser = connection.setSavepoint("saveUser");
			PreparedStatement prepareStatement = connection.prepareStatement("insert into user(id,name,age) values(?,?,?)");
			prepareStatement.setLong(1, user.getId());
			prepareStatement.setString(2, user.getName());
			prepareStatement.setInt(3, user.getAge());
			prepareStatement.execute();
		
			try {
				update(user);
			} catch (Exception e) {
				System.out.println("出错了。。"+e);
				//回滚至保护点
				connection.rollback(saveUser);
			}
			connection.commit();
			
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				connection.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return true;
	}
	
	public boolean update(User user) {
		System.out.println("save user:"+user);
		
		try {
			PreparedStatement prepareStatement = connection.prepareStatement("update user set name = ? ,age = ? where id = ?)");
			prepareStatement.setLong(3, user.getId());
			prepareStatement.setString(1, "王大拿");
			prepareStatement.setInt(2, 100/0);
			prepareStatement.execute();
			
			connection.commit();
			
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return true;
	}
}

上記の内容、ありがとうございます!

Mysql 関連のその他の質問については、PHP 中国語 Web サイトを参照してください:

Mysql ビデオ チュートリアル

以上がSpringBoot トランザクションの詳細な紹介の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。