加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

c# – ExecuteNonQuery要求命令进行事务处理

发布时间:2020-12-15 18:17:45 所属栏目:百科 来源:网络整理
导读:我尝试执行以下代码时收到此错误消息. ExecuteNonQuery requires the command to have a transaction when the connection assigned to the command is in a pending local transaction 任何人都可以建议问题出在哪里?我想问题的根源是我尝试执行存储过程的
我尝试执行以下代码时收到此错误消息.
ExecuteNonQuery requires the command to have a transaction when the connection assigned to the command is in a pending local transaction

任何人都可以建议问题出在哪里?我想问题的根源是我尝试执行存储过程的部分.

存储过程在执行时创建自己的事务

using (SqlConnection conn = new SqlConnection(connStr))
            {
                conn.Open();

                SqlCommand command = conn.CreateCommand();
                SqlTransaction transaction;

                // Start a local transaction.
                transaction = conn.BeginTransaction("createOrder");

                // Must assign both transaction object and connection
                // to Command object for a pending local transaction
                command.Connection = conn;
                command.Transaction = transaction;

                try
                {
                    command.CommandText = "INSERT INTO rand_resupply_order (study_id,centre_id,date_created,created_by) " +
                        "VALUES (@study_id,@centre_id,@date_created,@created_by) SET @order_id = SCOPE_IDENTITY()";

                    command.Parameters.Add("@study_id",SqlDbType.Int).Value = study_id;
                    command.Parameters.Add("@centre_id",SqlDbType.Int).Value = centre_id;
                    command.Parameters.Add("@date_created",SqlDbType.DateTime).Value = DateTime.Now;
                    command.Parameters.Add("@created_by",SqlDbType.VarChar).Value = username;

                    SqlParameter order_id = new SqlParameter("@order_id",SqlDbType.Int);
                    //study_name.Value = 
                    order_id.Direction = ParameterDirection.Output;
                    command.Parameters.Add(order_id);

                    command.ExecuteNonQuery();
                    command.Parameters.Clear();

                    //loop resupply list 
                    for (int i = 0; i < resupplyList.Count(); i++)
                    {
                        try
                        {
                            SqlCommand cmd = new SqlCommand("CreateOrder",conn);
                            cmd.CommandType = CommandType.StoredProcedure;

                            cmd.Parameters.Add("@study_id",SqlDbType.Int).Value = study_id;
                            cmd.Parameters.Add("@centre_id",SqlDbType.Int).Value = centre_id;
                            cmd.Parameters.Add("@created_by",SqlDbType.VarChar).Value = username;
                            cmd.Parameters.Add("@quantity",SqlDbType.VarChar).Value = resupplyList[i].Quantity;
                            cmd.Parameters.Add("@centre_id",SqlDbType.Int).Value = centre_id;
                            cmd.Parameters.Add("@depot_id",SqlDbType.VarChar).Value = depot_id;
                            cmd.Parameters.Add("@treatment_code",SqlDbType.Int).Value = centre_id;
                            cmd.Parameters.Add("@order_id",SqlDbType.Int).Value = (int)order_id.Value;
                            cmd.ExecuteNonQuery();
                        }
                        catch (SqlException ex)
                        {
                            transaction.Rollback();
                            ExceptionUtility.LogException(ex,"error");
                            throw ex;
                        }
                        catch (Exception ex)
                        {
                            transaction.Rollback();
                            ExceptionUtility.LogException(ex,"error");
                            throw ex;
                        }
                        finally
                        {
                            conn.Close();
                            conn.Dispose();
                        }

                    }

                    return (int)order_id.Value;

                }
                catch (Exception ex)
                {
                    transaction.Rollback();
                    ExceptionUtility.LogException(ex,"error");
                    throw ex;
                }
                finally
                {
                    // Attempt to commit the transaction.
                    transaction.Commit();

                    conn.Close();
                    conn.Dispose();
                    command.Dispose();
                }

解决方法

使用事务时,你应该在任何地方使用它.
cmd.Transaction = transaction;

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读