MySQLにおける動的挿入・更新処理の実装方法

データベース操作において、特定のレコードが存在する場合は更新し、存在しない場合は挿入するという処理は多くのアプリケーションで必要とされます。この記事では、MySQLでこの「UPSERT」と呼ばれる操作を効果的に実現するいくつかの方法を解説します。

アプローチ1：事前確認方式

最も基本的な方法として、まずレコードの存在を確認し、その結果に基づいて処理を分岐させる方法があります。

ステップ1：レコードの存在確認

SELECT COUNT(*) AS record_count 
FROM users 
WHERE user_id = 12345 AND is_active = 1;

ステップ2：条件に基づく処理分岐

アプリケーション側で取得したrecord_countの値に応じて、以下のいずれかのクエリを実行します。

更新クエリ（レコードが存在する場合）

UPDATE user_profiles 
SET last_login = NOW(), login_count = login_count + 1 
WHERE user_id = 12345;

挿入クエリ（レコードが存在しない場合）

INSERT INTO user_profiles 
(user_id, user_name, registration_date, last_login, login_count) 
VALUES (12345, 'テストユーザー', CURDATE(), NOW(), 1);

アプローチ2：INSERT ON DUPLICATE KEY UPDATE構文

MySQLには、この処理を単一のクエリで実現する便利な構文が用意されています。

INSERT INTO product_inventory 
(product_id, stock_quantity, last_updated) 
VALUES (789, 100, NOW()) 
ON DUPLICATE KEY UPDATE 
stock_quantity = VALUES(stock_quantity), 
last_updated = NOW();

この方法では、product_idが主キーまたは一意インデックスとして定義されている場合、同じproduct_idを持つレコードが存在すればUPDATEが、存在しなければINSERTが実行されます。

アプローチ3：REPLACEステートメントの使用

別の方法として、REPLACEステートメントを使用する方法もあります。

REPLACE INTO customer_addresses 
(customer_id, address_type, postal_code, prefecture, city) 
VALUES (456, 'shipping', '100-0001', '東京都', '千代田区');

注意点として、REPLACEは既存レコードを削除してから新しいレコリを挿入するため、AUTO_INCREMENT値が増加したり、トリガーが複数回実行されたりする可能性があります。

パフォーマンス考慮事項

• トランザクション内でこれらの操作を実行することを推奨します
• 高トラフィック環境では、INSERT ON DUPLICATE KEY UPDATEが一般的に最も効率的です
• インデックスを適切に設定することが重要です

実装例：PHPでの動的処理

function upsertUserData(PDO $pdo, int $userId, array $userData): bool {
    try {
        // トランザクション開始
        $pdo->beginTransaction();
        
        // 方法1：INSERT ON DUPLICATE KEY UPDATEを使用
        $sql = "INSERT INTO user_data 
                (user_id, name, email, preferences, updated_at) 
                VALUES (:user_id, :name, :email, :preferences, NOW()) 
                ON DUPLICATE KEY UPDATE 
                name = VALUES(name), 
                email = VALUES(email), 
                preferences = VALUES(preferences), 
                updated_at = NOW()";
                
        $stmt = $pdo->prepare($sql);
        $stmt->execute([
            ':user_id' => $userId,
            ':name' => $userData['name'],
            ':email' => $userData['email'],
            ':preferences' => json_encode($userData['preferences'])
        ]);
        
        // トランザクションコミット
        $pdo->commit();
        return true;
        
    } catch (PDOException $e) {
        // エラーが発生した場合はロールバック
        $pdo->rollBack();
        error_log("UPSERTエラー: " . $e->getMessage());
        return false;
    }
}

上記の関数は、ユーザーデータを効率的に挿入または更新するための実装例です。トランザクションを使用することでデータの一貫性を保ちながら、エラーハンドリングも適切に行っています。