0

我可以让它工作，但我觉得我做得不好。

第一次运行时，它按预期工作，并在“thisField”包含“doesntExist”的位置插入新行

但是，如果我随后运行它，我会收到一个运行时错误，我无法插入重复键，因为它违反了主键“thisField”。


static void Main(string[] args)
{           
    using(var sqlConn = new SqlConnection(connString) )
    {
        sqlConn.Open();
        var dt = new DataTable();

        var sqlda = new SqlDataAdapter("SELECT * FROM table WHERE thisField ='doesntExist'", sqlConn);
        sqlda.Fill(dt);

        DataRow dr = dt.NewRow();

        dr["thisField"] = "doesntExist"; //Primary key

        dt.Rows.Add(dr);

        //dt.AcceptChanges(); //I thought this may fix the problem. It didn't.

        var sqlTrans = sqlConn.BeginTransaction();

        try
        {
            sqlda.SelectCommand = new SqlCommand("SELECT * FROM table WITH (HOLDLOCK, ROWLOCK) WHERE thisField = 'doesntExist'", sqlConn, sqlTrans);

            SqlCommandBuilder sqlCb = new SqlCommandBuilder(sqlda);

            sqlda.InsertCommand = sqlCb.GetInsertCommand();
            sqlda.InsertCommand.Transaction = sqlTrans;

            sqlda.DeleteCommand = sqlCb.GetDeleteCommand();
            sqlda.DeleteCommand.Transaction = sqlTrans;

            sqlda.UpdateCommand = sqlCb.GetUpdateCommand();
            sqlda.UpdateCommand.Transaction = sqlTrans;

            sqlda.Update(dt);

            sqlTrans.Commit();
        }
        catch (Exception)
        {
            //...
        }
    }
}

即使我可以通过移动 AcceptChanges 的反复试验或在 Begin/EndEdit 中封装更改来实现这一点，然后我开始遇到“并发冲突”，它不会更新更改，而是告诉我它失败了更新 1 个受影响行中的 0 个。

有什么疯狂的明显我想念的吗？

4

1 回答 1

1

我能够通过在填充数据表后手动删除行来解决我的问题。我无法使用dt.Clear()，因为尝试插入具有重复主键的记录仍会导致异常。


sqladapter.Fill(dt);

foreach( DataRow d in dt.Rows )
    d.Delete();

DataRow dr = dt.NewRow();

dr.BeginEdit();
//update dr
dr.EndEdit();

dt.Rows.Add(dr);

以上将成功地让我插入一个新行，并更新一个预先存在的行。删除 foreach 会生成“无法在对象中插入重复键”，所以我觉得我至少找到了解决方案；虽然，我觉得好像这不是解决方案。

希望这可以帮助某人。

于 2010-05-17T19:16:41.333 回答