がんふぃーるど室長の不定期ブログ ただいま助手と悪戦苦闘中！

BEGIN
  --MERGE実行
  MERGE INTO MergeTable Target
  USING (SELECT :key1 Key1, :col1 Col1, :col2 Col2, :optLock OptLock
    FROM DUAL) InputSrc
  ON (Target.Key1 = InputSrc.Key1)
  WHEN MATCHED THEN
    UPDATE SET
      Col1 = InputSrc.Col1
      , Col2 = InputSrc.Col2
    WHERE Target.OptLock = InputSrc.OptLock
  WHEN NOT MATCHED THEN
    INSERT (Key1, Col1, Col2, OptLock)
      VALUES (InputSrc.Key1, InputSrc.Col1, InputSrc.Col2, systimestamp);

  --件数チェック（楽観ロックに引っかかった場合は0）
  IF SQL%ROWCOUNT = 0 THEN
    RAISE_APPLICATION_ERROR(-20801, '楽観的過ぎて更新できませんでした＞＜');
  END IF;
END;

const string sql
= @"BEGIN
  --MERGE実行
  MERGE INTO MergeTable Target
  USING (SELECT :key1 Key1, :col1 Col1, :col2 Col2, :optLock OptLock
    FROM DUAL) InputSrc
  ON (Target.Key1 = InputSrc.Key1)
  WHEN MATCHED THEN
    UPDATE SET
      Col1 = InputSrc.Col1
      , Col2 = InputSrc.Col2
    WHERE Target.OptLock = InputSrc.OptLock
  WHEN NOT MATCHED THEN
    INSERT (Key1, Col1, Col2, OptLock)
      VALUES (InputSrc.Key1, InputSrc.Col1, InputSrc.Col2, systimestamp);

  --件数チェック（楽観ロックに引っかかった場合は0）
  IF SQL%ROWCOUNT = 0 THEN
    RAISE_APPLICATION_ERROR(-20801, 'ERR-001:楽観的過ぎて更新できませんでした＞＜');
  END IF;
END;";

private void ExecuteMergeSql()
{
    OracleConnection conn = new OracleConnection("user id=xxx;password=yyy;data source=zzz");
    try
    {
        conn.Open();
        OracleCommand command = conn.CreateCommand();
        command.BindByName = true;
        command.CommandText = sql.Replace("\r", ""); //CRLFをLFだけに修正
        command.Parameters.Add(new OracleParameter("key1", 4));
        command.Parameters.Add(new OracleParameter("col1", "aaa"));
        command.Parameters.Add(new OracleParameter("col2", "bbb"));
        command.Parameters.Add(new OracleParameter("optLock", DateTime.Now));

        command.ExecuteNonQuery();
    }
    catch (OracleException oex)
    {
        if (oex.Number == 20801)
        {
            // ここで楽観ロックエラーを処理
        }
        else
        {
            throw;
        }
    }
    finally 
    {
        conn.Close();
    }
}

コメント