需要帮助如果记录存在更新其他插入

Question

需要在 c# 中进行编程的最佳方法。我正在尝试执行 if record exists update 语句 else insert 语句，更新代码但仍然有插入/更新到数据库的问题。从此代码执行后，数据库中没有任何显示：

        String updCmdTxt = "UPDATE..";
        String insertCmdTxt = "INSERT ..";
        using (var scope = new TransactionScope())
        {
            using (var con = new OracleConnection(strConnection))
            {
                bool isDuplicate = false;
                var insertcmd = new OracleCommand(insertCmdTxt, con);
                try
                {


                    con.Open();
                          ......add params

                    insertcmd.ExecuteNonQuery();

                    con.Close();
                    Response.Redirect("test.aspx?Id=" + labelRID.Text);
                }
                catch (OracleException x)
                {
                    isDuplicate = true; //determine if the exception is about duplicates.
                    if (!isDuplicate)
                    {
                        throw;
                    }
                }
                finally
                {
                    insertcmd?.Dispose();
                }
                if (isDuplicate)
                {
                    using (var updcmd = new OracleCommand(updCmdTxt, con))

                        {

                       ....
                      updcmd.ExecuteNonQuery();


                    }
                }
                scope.Complete();
                Response.Redirect("test.aspx?Id=" + labelRID.Text);

            }
        }
    }

有没有更好的编程方法？如果有，怎么做？

Answer 1

如果不了解所有细节（例如重复概率、每秒请求数等），很难给出建议。我使用了一些常用技术来实现这一点：

• 一个封装“upsert”工作流的存储过程。见Oracle: how to UPSERT

• 在客户端（您的情况）上实现 upsert 逻辑，但为了保证一致性，您需要启动事务并在执行操作后关闭它。

如果表中存在的行更有可能，在插入之前使用更新以避免频繁的异常。否则，您可以通过在更新前使用插入来优化工作流程。

悲观解

String updCmdTxt = "UPDATE ....";
String insertCmdTxt = "INSERT ....";
using (var scope = new TransactionScope())
{ 
   using (var con = new OracleConnection(conStr)){
      int rows;
      using (var updcmd = new OracleCommand(updCmdTxt, con)){
         //Set parameters ...
         rows = updcmd.ExecuteNonQuery();
      }
      //If update command did not affect any rows, insert
      if (rows == 0) {
         using (var insertcmd = new OracleCommand(insertCmdTxt, con)){
            // Set parameters...
            insertcmd.ExecuteNonQuery();
         }
      }
      scope.Complete();
   }
}

乐观解决方案

String updCmdTxt = "UPDATE ....";
String insertCmdTxt = "INSERT ....";
using (var scope = new TransactionScope())
{
    using (var con = new OracleConnection(conStr))
    {
        bool isDuplicate = false;
        var insertcmd = new OracleCommand(insertCmdTxt, con);
        try
        {
            // Set parameters...
            insertcmd.ExecuteNonQuery();
        }
        catch (OracleException x)
        {
            isDuplicate = ...; //determine if the exception is about duplicates.
            if (!isDuplicate)
            {
                throw;
            }
        }
        finally
        {
            insertcmd?.Dispose();
        }
        if (isDuplicate)
        {
            using (var updcmd = new OracleCommand(updCmdTxt, con))
            {
                //Set parameters ...
                updcmd.ExecuteNonQuery();
            }
        }
        scope.Complete();
    }
}

Answer 2

使用 MERGE 语句，它结合了 INSERT 和 UPDATE 语句的功能。例如：

MERGE INTO CONTRACT_INFO c
  USING (SELECT 12345 FROM DUAL AS RID) d
    ON (d.RID = c.RID)
  WHEN MATCHED THEN
    UPDATE
      SET CONTRACT_INFO_FIELD_1 = something,
          CONTRACT_INFO_FIELD_2 = something_else
  WHEN NOT MATCHED THEN
    INSERT (RID, CONTRACT_INFO_FIELD_1, CONTRACT_INFO_FIELD_2)
    VALUES (d.RID, something, something_else);

祝你好运。