10

我正在编码以读取 xml 文件以更新数据库。我得到大约 500 个 xml 文件，我想尽快处理它们。

所有数据库操作都是使用存储过程完成的。

每个 xml 文件都调用了大约 35 个不同的存储过程。

最初我写了这样的代码

var cmd = new SqlCommand("EXEC UpdateTeamStats("+teamId+","+points+")");
cmd.CommandType = CommandType.Text;

但经过一些最佳实践后，我将其更改为

var cmd = new SqlCommand("UpdateTeamStats");
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("teamId", 21);
cmd.Parameters.Add("points", 2);

由于从程序中调用了大量的存储过程，我意识到我必须减少调用次数才能进行优化。

所以我想把这35个存储过程全部收集起来，一口气执行。

存储过程因参数不同而不同，在我上面所做的参数更改后，我不知道如何将它们一起收集和执行。

我正在考虑调用一个巨大的存储过程，并在该存储过程中调用另一个 35 ，但我不太擅长 SQL，这会导致不必要的复杂性。

是否可以完全在 C# 中执行此操作？

或者是否有其他更好的方法来排队存储过程并快速运行它们

4

4 回答 4

1

imo 最好的解决方案是编写一个存储过程，其中传入一个表值参数，其中包含每个 xml 文件的所有参数的列表。然后在这个存储过程中，为表值参数中的每条记录调用所有其他存储过程。

如果这不行，那么您可以使用文本类型的 SqlCommand 而不是存储过程，并在执行时构建命令并执行它。您可以像现在一样使用参数，也可以只编写动态 sql。

于 2012-04-25T09:39:13.687 回答
1

请从以下位置下载 Microsoft 应用程序数据块

http://www.microsoft.com/download/en/details.aspx?id=435

很好，但是我该如何使用它呢？

这个包装类的使用非常简单。 

DAC DC = new DAC();
DC.StoredProcedure = "nProc_InsertOrder";
DC.Params.Add("@OrderId", SqlDbType.VarChar, "Order1" );
DC.Params.Add("@CustomerName", SqlDbType.VarChar, "test");
DAC.Commands.Add(DC);

DC = new DAC();
DC.StoredProcedure = "nProc_InsertOrderLineItems";
DC.Params.Add("@OrderId", SqlDbType.VarChar, "Order1" );
DC.Params.Add("@OrderLineId", SqlDbType.VarChar, "A1");
DAC.Commands.Add(DC);

DC = new DAC();
DC.StoredProcedure = "nProc_InsertOrderLineItems";
DC.Params.Add("@OrderId", SqlDbType.VarChar, "Order1" );
DC.Params.Add("@OrderLineId", SqlDbType.VarChar, "A2");
DAC.Commands.Add(DC);

DC = new DAC();
DC.StoredProcedure = "nProc_CreateBill";
DC.Params.Add("@BillDate", SqlDbType.DateTime, DateTime.Now);
DC.Params.Add("@BillId", SqlDbType.VarChar, "Bill1");
DAC.Commands.Add(DC);
DAC.ExecuteBatch();

如果订单插入失败，则不应创建账单。同样，如果订单项失败，则不应创建订单。我们通过 ADO.Net 只需几行代码即可实现这一目标。

在此示例中，直到我们调用 ExecuteBatch，我们实际上并没有插入记录，而是准备对象以进行批量更新。

于 2012-04-24T13:25:14.377 回答
0

您可以CommandQueue通过命令模式创建一个 , 并在命令上创建一个委托，该委托映射到您对存储过程的调用的任何要求；从外观上看，类似于：

public class CommandQueue
{
    private Connection _connexion = new Connection(); // Set this up somehow.

    // Other methods to handle the concurrency/ calling/ transaction etc.

    public Func<string, Dictionary<string, int>, bool> CallStoredProcedure = (procedureName, parameterValueMap) =>
    {
      cmd.Connection = GetConnexion();
      var cmd = new SqlCommand(procedureName);
      cmd.CommandType = CommandType.StoredProcedure;

      foreach (var parameterValueMapping in parameterValueMap)
      {
        cmd.Parameters.Add(parameterValueMapping.Key, parameterValueMapping.Value);
      }

      var success = cmd.ExecuteNonQuery();

      return success;
    }

    private Connection GetConnexion()
    {
      return _connexion;
    }
}

然后，设置CommandQueue, 以便您拥有一个线程池，您可以从中调用新线程上的委托，以便它们并行运行。

实际上，查看SQLCommand类，您可以对其进行异步调用。Cancel()因此，您应该能够异步调用每个存储过程，在每个完成时设置一个委托并将其全部包装在事务中，以便您可以在需要时通过调用每个命令来回滚它们。我可能仍会使用 aCommandQueue来将其抽象出来，因为我建议您稍后可能会更改它！

我想我仍然会用 a 上的委托封装存储过程调用CommandQueue，这样可以抽象出存储过程的细节，并使其他人更容易理解这个过程，也更容易维护。如果您添加新的存储过程，或更改名称或其他内容，它会容易得多。您可以设置一个包含所有委托的静态列表，或者一个包含必要存储过程详细信息的静态列表，并使用委托仅传递参数。

于 2012-04-19T10:08:45.813 回答
0

就我个人而言，根据我使用ADO.NET的经验，我认为无论使用单个. SqlConnection

这具有利用 .NET 惊人的连接池的好处，使您能够单独工作/自定义/与每个命令交互并使用共享连接（将连接代理的数量减少到微不足道的数量）。

我还想强调using这里的条款的重要性，这些条款有助于正确处理各种资源。

例如：

using (var conn = new SqlConnection("connection string"))
{
    using (var cmd = new SqlCommand())
    {
        cmd.Connection = conn;
        cmd.CommandType = CommandType.StoredProcedure;

        //ready to query 
        conn.Open();

        cmd.CommandText = "UpdateTeamStats";
        var teamIdParam = new SqlParameter("teamId", 21);
        var pointsParam = new SqlParameter("points", 2);

        cmd.Parameters.Add(teamIdParam);
        cmd.Parameters.Add(pointsParam);

        cmd.ExecuteNonQuery(); //OR if you're async cmd.ExecuteNonQueryAsync();

        //the rest of your executions

        conn.Close();
    }
}

如果我很热心，您可以使用一个库，例如我的DbConnect，它将上述内容简化为：

using (var db = new DbConnect("connection string"))
{
    db.SetSqlCommand("UpdateTeamStats");
    db.AddParameter("teamId", 21);
    db.AddParameter("points", 2);

    db.ExecuteNonQuery().Wait(); //OR if youre async await db.ExecuteNonQuery();

    db.ClearParameters();
    db.SetSqlCommand("some other proc");

    //rest of executions
}
于 2017-07-05T13:46:30.243 回答