デッドロックとタイムアウト

【パターン１】
同じスレッドで、２つのConnectionオブジェクトによりデッドロックを起こそうとすると、タイムアウトのエラーになる。

KFPA11770-I ROW [ HOGE_T RDDATA10 ] currently in use,resource　…

【パターン２】
別のスレッドで、２つのConnectionオブジェクトによりデッドロックを起こそうとすると、デッドロックのエラーになる。

KFPA11911-E Deadlock occurred on ROW [ HOGE_T RDDATA10 ] resource …

DBサーバからしたら、２つのコネクションからデッドロックのSQLが要求されただけなのに、どうやってエラーを判別しょんじゃろ？
クライアント側のスレッドが同じかどうか判る仕組みなんじゃろか？
例えばクライアントID（スレッドIDが含まれる？）みたいなのが、JDBC経由でやり取りしょんじゃねーかと思ってみたり。

【パターン１】
同じスレッドで、２つのConnectionオブジェクトによりデッドロックを起こそうとするプログラム

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class DeadlockTest1 {
    
    private String URL = "jdbc:hitachi:hirdb://DB=HiRDB,DBID=22200,DBHOST=xxx.xxx.xxx.xxx";    

    public static void main(String[] args) {
        new DeadlockTest1().test();
    }
    
    public void test() {
        
        Connection con1 = null;
        Connection con2 = null;
        
        try {
            
            Class.forName("JP.co.Hitachi.soft.HiRDB.JDBC.HiRDBDriver");
            PreparedStatement pstmt1 = null;
            PreparedStatement pstmt2 = null;
            String sql = null;
            int res = -1;
        
            // コネクション１を取得
            con1 = DriverManager.getConnection(URL, "HOGE", "HOGE");
            con1.setAutoCommit(false);
            
            // コネクション２を取得
            con2 = DriverManager.getConnection(URL, "HOGE", "HOGE");
            con2.setAutoCommit(false);

            // コネクション１でレコード１をUPDATE
            sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='A' AND COL_B='1'";
            pstmt1 = con1.prepareStatement(sql);
            res = pstmt1.executeUpdate();

            // コネクション２でレコード２をUPDATE
            sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='B' AND COL_B='2'";
            pstmt2 = con2.prepareStatement(sql);
            res = pstmt2.executeUpdate();

            // コネクション１でレコード２をUPDATE【ここでデッドロック（実際はタイムアウト）】
            sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='B' AND COL_B='2'";
            pstmt1 = con1.prepareStatement(sql);
            res = pstmt1.executeUpdate();
            
            // コネクション１をコミット
            con1.commit();                
            con1.close();

            // コネクション２でレコード１をUPDATE
            sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='A' AND COL_B='1'";
            pstmt2 = con2.prepareStatement(sql);
            res = pstmt2.executeUpdate();
            
            // コネクション２をコミット
            con2.commit();                
            con2.close();

        } catch (Throwable t) {
            t.printStackTrace();
        } finally {
            try {
                if((con1 != null) && (con1.isClosed() == false)) {
                    con1.close();
                }
                if((con2 != null) && (con2.isClosed() == false)) {
                    con2.close();
                }
            } catch(Throwable t) {
                t.printStackTrace();
            }
        }

    }
    
}

【パターン２】
別のスレッドで、２つのConnectionオブジェクトによりデッドロックを起こそうとするプログラム

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class DeadlockTest2 extends Thread implements Runnable {
    
    private String URL = "jdbc:hitachi:hirdb://DB=HiRDB,DBID=22200,DBHOST=xxx.xxx.xxx.xxx";    
    
    public DeadlockTest2() {
    }
    
    public static void main(String[] args) {
        new DeadlockTest2().test();
    }
    
    private void test() {
        try {
            Class.forName("JP.co.Hitachi.soft.HiRDB.JDBC.HiRDBDriver");
            new Test1().start();
            new Test2().start();
        } catch (Throwable t) {
            t.printStackTrace();
        }
    }
    
    private class Test1 extends Thread implements Runnable {
        
        public void run() {
            
            Connection con = null;

            try {
                
                // スレッド１のコネクションを取得
                con = DriverManager.getConnection(URL, "HOGE", "HOGE");
                con.setAutoCommit(false);
                
                PreparedStatement pstmt = null;
                String sql = null;
                int res = -1;
                
                // スレッド１でレコード１をUPDATE
                sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='A' AND COL_B='1'";
                pstmt = con.prepareStatement(sql);
                res = pstmt.executeUpdate();
                
                Thread.sleep(100);

                // スレッド１でレコード２をUPDATE【ここでデッドロック】
                sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='B' AND COL_B='2'";
                pstmt = con.prepareStatement(sql);
                res = pstmt.executeUpdate();

                con.commit();                
                con.close();

            } catch (Throwable t) {
                t.printStackTrace();
            } finally {
               try {
                    if((con != null) && (con.isClosed() == false)) {
                        con.close();
                    }
                } catch(Throwable t) {
                    t.printStackTrace();
                }
            }
            
        }
        
    }
    
    private class Test2 extends Thread implements Runnable {
        
        public void run() {
             
            Connection con = null;
           
            try {
                
                // スレッド２のコネクションを取得
                con = DriverManager.getConnection(URL, "HOGE", "HOGE");
                con.setAutoCommit(false);
                
                PreparedStatement pstmt = null;
                String sql = null;
                int res = -1;

                // スレッド２でレコード２をUPDATE
                sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='B' AND COL_B='2'";
                pstmt = con.prepareStatement(sql);
                res = pstmt.executeUpdate();
                
                Thread.sleep(100);
                
                // スレッド２でレコード１をUPDATE
                sql = "UPDATE HOGE_T SET COL_C='X' WHERE COL_A='A' AND COL_B='1'";
                pstmt = con.prepareStatement(sql);
                res = pstmt.executeUpdate();

                con.commit();                
                con.close();
                
            } catch (Throwable t) {
                t.printStackTrace();
            } finally {
               try {
                    if((con != null) && (con.isClosed() == false)) {
                        con.close();
                    }
                } catch(Throwable t) {
                    t.printStackTrace();
                }
            }
            
        }
        
    }
    
}