「JDBCによる悲観ロックの落とし穴」の版間の差分

提供: tknotebook
移動: 案内検索
(select と uodate で異なる Statement オブジェクトを使う)
 
(1人の利用者による、間の15版が非表示)
2行: 2行:
 
[[メインページ]]>[[コンピュータの部屋#Java]]>[[Java Tips]]
 
[[メインページ]]>[[コンピュータの部屋#Java]]>[[Java Tips]]
  
 +
 +
==やばいJDBCの悲観ロックのコード==
  
 
あるあるですが、JDBCを使って悲観ロックでレコードを更新する場合、たまにこんなコードを見かけることがあります。
 
あるあるですが、JDBCを使って悲観ロックでレコードを更新する場合、たまにこんなコードを見かけることがあります。
 +
 +
 +
更新するテーブルの定義
 +
 +
CREATE TABLE ACCOUNT
 +
(
 +
    NAME varchar(12) PRIMARY KEY NOT NULL,
 +
    BALANCE int NOT NULL
 +
)
 +
 +
 +
更新するコード
 +
 +
Statement s = ・・・
  
 
  rsA = s.executeQuery("select name, balance from account where name='A' for update");
 
  rsA = s.executeQuery("select name, balance from account where name='A' for update");
19行: 35行:
 
実は Isolation level が READ COMMITED では、これは悲観ロックになっていないのです。
 
実は Isolation level が READ COMMITED では、これは悲観ロックになっていないのです。
  
 +
==このコードがまずいわけ==
  
コードでは、
+
上のコードでは、
 
#更新モードでカーソルを取得
 
#更新モードでカーソルを取得
 
#カーソルの行の値を取得し更新ロックをかける。
 
#カーソルの行の値を取得し更新ロックをかける。
27行: 44行:
 
となっていて問題なさそうに見えますが、問題点は'''更新ロックの寿命'''です。
 
となっていて問題なさそうに見えますが、問題点は'''更新ロックの寿命'''です。
  
多くのDBでは、行ロックの更新ロックは、Isolation Level が READ COMMITED の場合、カーソルの指す行のみがロックされ、
+
多くのDBでは、更新ロックは、Isolation Level が READ COMMITED の場合、カーソルの指す行のみがロックされ、
 
カーソルが別の行へ移ると元の行の更新ロックは解除されます。カーソルがクローズされれば当然更新ロックは残りません。
 
カーソルが別の行へ移ると元の行の更新ロックは解除されます。カーソルがクローズされれば当然更新ロックは残りません。
  
'''Statement オブジェクトは executeXXX を実行すると、カーソルをクローズするため'''、上記のコードではレコードが排他ロックするまでの
+
ところが、
わずかな隙間時間に、レコードのロックがない期間が存在するのです。これではうまく動きません。
+
'''Statement オブジェクトは executeXXX メソッドを実行すると、そのStatementを使って作られたカーソルをクローズするため'''、上記のコードでは
 +
'''executeUpdateメソッドでレコードを排他ロックするまでのわずかな隙間時間に、レコードのロックがない期間が存在するのです。'''
 +
これではうまく動きません。
  
対処方法は2つあります。
+
==対処方法==
  
'''1. Isolation Level を REPEATABLE READ 以上にする。'''
+
対処方法は4つ程あります。
  
'''2. 以下のように、カーソルを使って行を更新する。'''
+
=== Isolation Level を REPEATABLE READ 以上にする===
 +
 
 +
最も簡単ですが、同時性が少し悪くなります。
 +
多くのDBではREPEATABLE READ を使うと 更新ロックはトランザクションが終わるまで存続します。
 +
勿論DBの仕様をよく確かめてから使って下さい。
 +
 
 +
===カーソルを取得せず update account set balance=balance-100 where ... の一行でレコードを更新する===
 +
 
 +
更新の計算を Java で行なわず SQL で表現できるならこれを使うべきでしょう。
 +
 
 +
===select と update で異なる Statement オブジェクトを使う===
 +
 
 +
Statement sr = ・・・
 +
Statement su = ・・・
 +
 
 +
rsA = sr.executeQuery("select name, balance from account where name='A' for update");
 +
if (rsA.next()) {
 +
    balanceA = rsA.getInt("balance");
 +
    logger.debug("balanceA = " + balanceA);
 +
} else {
 +
    logger.error("balanceA の行がありません");
 +
}
 +
 +
su.executeUpdate(String.format("update account set balance=%d where name='A'", balanceA - 100));
 +
logger.debug("update A");
 +
 
 +
この方法は複数の行を同時にロックしたい時などでも便利です。
 +
 
 +
===カーソルを使って行を更新する。===
  
 
  rsA = s.executeQuery("select name, balance from account where name='A' for update");
 
  rsA = s.executeQuery("select name, balance from account where name='A' for update");
50行: 97行:
 
  }
 
  }
 
  conn.commit();
 
  conn.commit();
 +
 +
 +
JDBCを長く使っておられる方でも、いろいろ制約はあるものの、カーソルで更新ができることを知らない人が結構います。
 +
Updatable Cursor を活用しましょう。

2018年9月11日 (火) 06:26時点における最新版

メインページ>コンピュータの部屋#Java>Java Tips


やばいJDBCの悲観ロックのコード

あるあるですが、JDBCを使って悲観ロックでレコードを更新する場合、たまにこんなコードを見かけることがあります。


更新するテーブルの定義

CREATE TABLE ACCOUNT
(
   NAME varchar(12) PRIMARY KEY NOT NULL,
   BALANCE int NOT NULL
)


更新するコード

Statement s = ・・・
rsA = s.executeQuery("select name, balance from account where name='A' for update");
if (rsA.next()) {
    balanceA = rsA.getInt("balance");
    logger.debug("balanceA = " + balanceA);
} else {
    throw new Exception("行がありません");
}
s.executeUpdate(String.format("update account set balance=%d where name='A'", balanceA - 100));
logger.debug("update A");

conn.commit();

実は Isolation level が READ COMMITED では、これは悲観ロックになっていないのです。

このコードがまずいわけ

上のコードでは、

  1. 更新モードでカーソルを取得
  2. カーソルの行の値を取得し更新ロックをかける。
  3. 行の値を更新し排他ロックをかける。

となっていて問題なさそうに見えますが、問題点は更新ロックの寿命です。

多くのDBでは、更新ロックは、Isolation Level が READ COMMITED の場合、カーソルの指す行のみがロックされ、 カーソルが別の行へ移ると元の行の更新ロックは解除されます。カーソルがクローズされれば当然更新ロックは残りません。

ところが、 Statement オブジェクトは executeXXX メソッドを実行すると、そのStatementを使って作られたカーソルをクローズするため、上記のコードでは executeUpdateメソッドでレコードを排他ロックするまでのわずかな隙間時間に、レコードのロックがない期間が存在するのです。 これではうまく動きません。

対処方法

対処方法は4つ程あります。

Isolation Level を REPEATABLE READ 以上にする

最も簡単ですが、同時性が少し悪くなります。 多くのDBではREPEATABLE READ を使うと 更新ロックはトランザクションが終わるまで存続します。 勿論DBの仕様をよく確かめてから使って下さい。

カーソルを取得せず update account set balance=balance-100 where ... の一行でレコードを更新する

更新の計算を Java で行なわず SQL で表現できるならこれを使うべきでしょう。

select と update で異なる Statement オブジェクトを使う

Statement sr = ・・・
Statement su = ・・・
rsA = sr.executeQuery("select name, balance from account where name='A' for update");
if (rsA.next()) {
    balanceA = rsA.getInt("balance");
    logger.debug("balanceA = " + balanceA);
} else {
    logger.error("balanceA の行がありません");
}

su.executeUpdate(String.format("update account set balance=%d where name='A'", balanceA - 100));
logger.debug("update A");

この方法は複数の行を同時にロックしたい時などでも便利です。

カーソルを使って行を更新する。

rsA = s.executeQuery("select name, balance from account where name='A' for update");
if (rsA.next()) {
    balanceA = rsA.getInt("balance");
    logger.debug("balanceA = " + balanceA);
    rsA.updateInt("balance", balanceA - 100);
    rsA.updateRow();
    logger.debug("update A");
} else {
   throw new Exception("行がありません");
}
conn.commit();


JDBCを長く使っておられる方でも、いろいろ制約はあるものの、カーソルで更新ができることを知らない人が結構います。 Updatable Cursor を活用しましょう。