package com.hacker.jdbc.transactional;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.hacker.jdbc.Connecter;

public class ThreadMain {
	public static void main(String args[]) {
		//t1執行緒
		Thread t1 = new Thread(() ->{
			Connection con = Connecter.getConnecion();		//connection連線的程式碼就不提供了注意不要使用單例
			conn.setAutoCommit(false); // 預設不提交事務 方便看到阻塞結果
			try {
				System.out.println("t1執行緒試圖開啟行級鎖");
				String sql = "select * from users where id = ? LOCK IN SHARE MODE";// 排他鎖測試換FOR UPDATE
				PreparedStatement pst = con.prepareStatement(sql）;
				pst.setInt(1, 1);
				ResultSet rs = pst.executeQuery();
				if(rs.next()){
					System.out.println("t1 :" + rs.getString(2)); //根據你自己定義的表獲取結果
				}
				try {
					System.out.println("t1開始等待3s");	//等待
					synchronized (con) {
						con.wait(3000);
					}
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				System.out.println("t1執行緒完成行級鎖");
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		});
		//用於測試在t1獲得鎖的情況下嘗試 獲取被鎖或修改被鎖行
		Thread t2 = new Thread(() -> {
			Connection con = Connecter.getConnecion();
			try {
				System.out.println("執行緒t2開始試圖獲取被鎖行");
//				String sql = "update users set password = ? where username = 1 ";
				String sql = "select * from users where username = ? LOCK IN SHARE MODE";
				PreparedStatement pst = con.prepareStatement(sql);
//				pst.setString(2, "4566");
				pst.setInt(1, 1);
//				System.out.println(pst.executeUpdate());
				ResultSet rs = pst.executeQuery();
				if(rs.next()){
					System.out.println("t2 :" + rs.getString(2));
				}
				con.commit();
				System.out.println("t2執行緒完成，獲取到被鎖行");
//				con.rollback();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		});
		t1.start();
		t2.start();
		
	}
}