ExecuteScalar()与SqlTransaction

Question

我试图使用sqltransaction和executescalar对数据库进行两个插入，以返回第一个insert的输出ID。

这是代码：

try
    {
      using (SqlConnection conn = new SqlConnection("ConnectionString"))
         {
           conn.Open();

           SqlTransaction safetransaction = conn.BeginTransaction();

           foreach (var dado in NFSe)
              {

                SqlCommand cmd_NFSe = new SqlCommand("SqlCommand", conn, safetransaction);


                var newID = cmd_NFSe.ExecuteScalar();

                foreach (var serv in Servico)
                   {

                     string ID = newID.Tostring(); 

                     SqlCommand cmd_NFSeServ = new SqlCommand("SqlCommand", conn, safetransaction);


                     cmd_NFSeServ.ExecuteNonQuery();
                   }                                

               }
          }
     }

 catch (SqlException ex)
     {
        MessageBox.Show(ex.ToString());
     }

但这不管用。没有任何东西被插入到数据库中，我没有得到任何错误或异常，只是什么都没有发生。

如果我使用相同的代码，但没有sqltransaction，那么一切都很好。

有什么想法吗？

Answer 1

你错过了很多事情

1. 实施交易
2. 回滚事务

事务将在任何错误时回滚，或者如果未首先提交而被释放，则回滚事务。

试试看：

try
    {
      using (SqlConnection conn = new SqlConnection("ConnectionString"))
         {
           conn.Open();

           SqlTransaction safetransaction = conn.BeginTransaction();

           foreach (var dado in NFSe)
              {

                SqlCommand cmd_NFSe = new 
                SqlCommand("SqlCommand", conn, safetransaction);
                cmd_NFSe.Connection = connection;
                cmd_NFSe.Transaction = transaction;

                var newID = cmd_NFSe.ExecuteScalar();

                foreach (var serv in Servico)
                   {

                     string ID = newID.Tostring(); 

                     SqlCommand cmd_NFSeServ = new 
                     SqlCommand("SqlCommand", conn, safetransaction);


                     cmd_NFSeServ.ExecuteNonQuery();
                     cmd_NFSe.Commit();
                   }                                

               }
          }
     }

 catch (SqlException ex)
     {

        cmd_NFSe.Rollback();
        MessageBox.Show(ex.ToString());
     }

Answer 2

我希望您展示一些SQL，这样我们就可以看到您在做什么，但是我必须假设您有一个身份列，您将从其中获得新的id。我喜欢避免多次访问服务器，这样您就可以清楚地知道，通过将多个SQL语句与";“分隔开来，您可以在一个调用中组合多个SQL语句。该单次调用中的所有语句都是事务性的，因此您的总体代码将更小，而且访问服务器的次数也会减少，速度也会更快。IE：

INSERT INTO MyTable (MyField) VALUES ('Test1'); Select SCOPE_IDENTITY(); INSERT INTO MyTable (MyField) VALUES ('Test2'); Select SCOPE_IDENTITY()

现在，将其与DataAdapter.Fill一起使用，您将得到一个带有2个表的DataSet，每个表都有用于插入的新ID。

哦，关于您最初的问题，您需要提交您的事务：safetransaction.Commit();