LAST_INSERT_IDの動作について

本記事では、OceanBaseデータベースにおけるLAST_INSERT_ID()関数の動作と、MySQLとの違いについて説明します。

LAST_INSERT_ID()関数は、直近のINSERT操作で生成された自動インクリメントID値を取得するために使用されます。OceanBaseデータベースでは、この関数の動作がMySQLといくつか異なり、主に以下の2点に表れています：

• セッションレベルのLAST_INSERT_ID：LAST_INSERT_ID()関数によって読み取りおよび変更されます。
• プロトコルレベルのLAST_INSERT_ID：MySQLプロトコルのOKパケットで返される値

MySQLの動作

セッションレベルのLAST_INSERT_ID

セッション上のLAST_INSERT_IDはLAST_INSERT_ID(args)関数を使用して読み取りおよび変更できます。

-- セッション上のLAST_INSERT_IDを読み取る
SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
|                0 |
+------------------+

-- 関数を使用してセッション上のLAST_INSERT_IDを変更する
SELECT LAST_INSERT_ID(10);
+--------------------+
| LAST_INSERT_ID(10) |
+--------------------+
|                 10 |
+--------------------+

プロトコルレベルのLAST_INSERT_ID

MySQLプロトコルのOKパケット内のLAST_INSERT_IDです。DMLステートメントがセッション上のLAST_INSERT_IDを変更する場合、DML実行後にクライアントに返されるOKパケット内のLAST_INSERT_IDは、セッション上のLAST_INSERT_IDと等しくなります。そうでない場合、クライアントに返されるLAST_INSERT_IDは、DMLステートメントによって書き込まれた最後の行のデータに対応するAUTO_INCREMENT列の値となります。

OceanBaseデータベースとMySQLの互換性

完全互換の動作

OceanBaseデータベースは、以下の点でMySQLと完全に互換しています。

• セッションレベルでの LAST_INSERT_ID の読み取りと変更：LAST_INSERT_ID() 関数を使用して、セッション上の値を読み取りおよび変更します。
• 関数式による LAST_INSERT_ID 値の設定：LAST_INSERT_ID(expr) 関数を使用して値を設定します。
• プロトコルレベルのOKパケット形式：クライアントへの応答パケット形式がMySQLと一致しています。
• REPLACEステートメント：最初のINSERT行または上書きされた自動インクリメント列の値を返します。
• INSERT ... ON DUPLICATE KEY UPDATE：すべての場合において、競合がない場合は最初のINSERT行の自動インクリメント列の値を返し、部分的な競合がある場合も最初のINSERT行の自動インクリメント列の値を返します。すべて競合する場合は、元の値を維持します。
• 複数行の挿入：最初のINSERT行の自動インクリメント列の値を返します。
• IGNOREステートメント：主キー競合によりデータが書き込まれなかった場合、LAST_INSERT_ID は変更されません。

動作の違い

OceanBaseデータベースとMySQLの主な違いは以下の点です：

INSERTステートメントで自動インクリメント列を手動指定する場合

MySQLの動作：

• 自動インクリメント列を手動指定：LAST_INSERT_IDは変更されません。

OceanBaseデータベースの動作：

• 自動インクリメント列を手動指定：最初のINSERTの自動インクリメント列の値を返します。

-- テストテーブルを作成
CREATE TABLE `t1` (
  `c1` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
  `c2` INT DEFAULT NULL,
  PRIMARY KEY (`c1`),
  UNIQUE KEY `c2` (`c2`)
);

-- 例1：LAST_INSERT_ID関数を使用して値を変更する（MySQLとOceanBaseの動作は一致する）
UPDATE t2 SET c1 = LAST_INSERT_ID(100) + c1 WHERE c2 = 1;
SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
|              100 |
+------------------+

-- 例2：INSERTステートメント（MySQLとOceanBaseの動作は一致する）
INSERT INTO t1(c2) VALUES (1);
SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
|                1 |
+------------------+

-- 例3：REPLACEステートメント（MySQLとOceanBaseの動作は一致する）
REPLACE INTO t1(c2) VALUES (2);
SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
|                2 |
+------------------+

-- 例4：複数行挿入（MySQLとOceanBaseはどちらも最初の行のIDを返す）
INSERT INTO t1(c2) VALUES (3), (4);
SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
|                3 |
+------------------+

詳細比較表

互換性計画