1

我试过研究这个话题，但它没有意义。我有一些代码尝试执行 UPDATE 查询，然后循环执行另一组 INSERT 查询。第二个查询错误，因为我省略了参数（目前这是故意引发错误）。UPDATE 仍然被提交，即使它不应该......

这是代码....

using (MySqlConnection con = existingCon.Clone())
{
con.Open();

MySqlParameter paramTimeStamp;
MySqlParameter paramFileNo;
MySqlParameter paramDescription;
MySqlParameter paramComment;
MySqlParameter paramUserInfo;
MySqlParameter paramPaymentType;
MySqlParameter paramSeriesLink;
MySqlParameter paramOriginalSubmitDate;

using (MySqlTransaction transact = con.BeginTransaction())
{
    try
    {
        using (
            MySqlCommand cmd =
                new MySqlCommand(
                    "UPDATE Payments "
                        + "SET strStatus = 'processing-preupload' "
                        + "WHERE strStatus = 'processing-prepost';",
                    con))
        {
            cmd.Transaction = transact;
            cmd.ExecuteNonQuery();
        }
    }
    catch (Exception e)
    {
        transact.Rollback();
        throw;
    }

    foreach (Payment payment in payments)
    {
        try
        {
            using (
                MySqlCommand cmd =
                    new MySqlCommand(
                        "INSERT INTO Activity "
                            + "(dtmTimeStamp, strFileNumber, strDescription, strComment, "
                                + "strUserInfo, strPaymentType, dtmSeriesLink, dtmOriginalSubmitDate) "
                            + "VALUES (@paramTimeStamp, @paramFileNo, @paramDescription, @paramComment, "
                                + "@paramUserInfo, @paramPaymentType, @paramSeriesLink, @paramOriginalSubmitDate);",
                        con))
            {
                paramTimeStamp = new MySqlParameter("@paramTimeStamp", DateTime.Now);
                paramFileNo = new MySqlParameter("@paramFileNo", payment.strFileNumber);
                paramDescription = new MySqlParameter("@paramDescription", description);
                paramComment = new MySqlParameter("@paramComment", comment);
                paramUserInfo = new MySqlParameter("@paramUserInfo", userInfo);
                paramPaymentType = new MySqlParameter("@paramPaymentType", PAYMENT_TYPE);
                paramSeriesLink = new MySqlParameter(
                    "@paramSeriesLink",
                    payment.strSeriesLink_corrected);
                paramOriginalSubmitDate = new MySqlParameter(
                    "@paramOriginalSubmitDate",
                    payment.strSubmitDate_corrected);

                cmd.Transaction = transact;
                cmd.ExecuteNonQuery();
            }
        }
        catch (Exception e)
        {
            transact.Rollback();
            throw;
        }
    }

    transact.Commit();
}
}

想法？

4

2 回答 2

2

两个想法；第一：

在 MySQL 中，只有 InnoDB 和 BDB (BerkeleyDB) 表格式支持事务。其他标准存储引擎忽略事务并且不能回滚数据修改。

那么...您使用的是什么表格格式？

其次：您可以尝试使用接受 a 的重载IsolationLevel，只是为了明确 - 但我怀疑表格格式是这里的真正问题。

于 2013-05-02T14:06:02.387 回答
0

也许这可以帮助某人。

一些旧版本的连接器（我认为是 6.4.4 左右）在查询错误后自动回滚事务。最新版本（6.9.6）似乎不是这种情况。

“有趣的事情，虽然。它似乎在某个时候起作用，但又停止了”让我想知道。

于 2015-03-28T10:39:44.820 回答