循环运行 SQL 查询数千次

Question

我已经阅读了几十篇帖子，其中很多都可以追溯到几年前，但无法想出一种现代、安全和可靠的方法来将数千条记录中的特殊值作为单个查询进行更新。

我遍历表中的所有记录，根据一些特殊逻辑确定一个 DateTime 值，然后运行这个简单的查询来更新该值……超过 3500 次。那是很多次的线路。

UPDATE ScheduleTickets
    SET ScheduledStartUTC = @ScheduledStartUTC
    WHERE ScheduleId = @ScheduleId AND PatchSessionId = @PatchSessionId

我已经看到 cmets 通过保存和使用 DataTable 来不浪费内存。我见过使用 StringBuilder 动态创建更新查询的解决方案，但感觉不安全/肮脏。当然，整个过程不到一分钟，但一定有更好的方法。

所以，在弄清楚 DateTime 值之后，我调用...

UpdateScheduleTicketStart(ScheduleId, PatchSessionId, scheduledDateTime);

看起来像这样...

private static void UpdateScheduleTicketStart(long scheduleId, long patchSessionId, DateTime scheduledStartUTC)
{
    using (SqlConnection c = ConnectVRS())
    {
        SqlCommand cmd = new SqlCommand(@"
            UPDATE ScheduleTickets
                SET ScheduledStartUTC = @ScheduledStartUTC
                WHERE ScheduleId = @ScheduleId AND PatchSessionId = @PatchSessionId
            ", c);
        cmd.Parameters.Add("@ScheduleId", SqlDbType.BigInt).Value = scheduleId;
        cmd.Parameters.Add("@PatchSessionId", SqlDbType.BigInt).Value = patchSessionId;
        cmd.Parameters.Add("@ScheduledStartUTC", SqlDbType.VarChar).Value = scheduledStartUTC;
        cmd.ExecuteNonQuery();
    }
}

如何在一次调用中将所有值传递给 SQL Server，或者如何创建单个 SQL 查询以一举完成更新？

Answer 1

很多人建议使用 TableValueParameter，我同意这将是一个好方法。以下是您如何做到这一点的示例：

首先在 SQL Server 中创建 TVP 和存储过程

CREATE TYPE [dbo].[SchdeuleTicketsType] As Table
(
    ScheduledStartUTC DATETIME NOT NULL
  , ScheduleId        INT      NOT NULL
  , PatchSessionId    INT      NOT NULL
)


CREATE PROCEDURE [dbo].[usp_UpdateTickets]
(
   @ScheduleUpdates As [dbo].[SchdeuleTicketsType] Readonly
)
   AS
   Begin
        UPDATE t1
        SET t1.ScheduledStartUTC = t2.ScheduledStartUTC
        FROM ScheduleTickets AS t1
            INNER JOIN @ScheduleUpdates AS t2
        ON t1.ScheduleId = t2.ScheduleId AND
           t1.PatchSessionId  = t2.PatchSessionId 
   End
)

下一步修改您的代码以填充表并将其作为参数传递给存储过程：

    private void Populate()
    {
        DataTable dataTable = new DataTable("SchdeuleTicketUpdates");

        //we create column names as per the type in DB 
        dataTable.Columns.Add("ScheduledStartUTC", typeof(DateTime));
        dataTable.Columns.Add("ScheduleId", typeof(Int32));
        dataTable.Columns.Add("PatchSessionId", typeof(Int32));

        //write you loop to populate here

        //call the stored proc
        using (var conn = new SqlConnection(connString))
        {
            var command = new SqlCommand("[usp_UpdateTickets]");
            command.CommandType = CommandType.StoredProcedure;

            var parameter = new SqlParameter();
            //The parameter for the SP must be of SqlDbType.Structured 
            parameter.ParameterName = "@ScheduleUpdates";
            parameter.SqlDbType = System.Data.SqlDbType.Structured;
            parameter.Value = dataTable;
            command.Parameters.Add(parameter);
            command.ExecuteNonQuery();

        }
    }

Answer 2

如果值在另一个表中，请使用join：

UPDATE st
    SET ScheduledStartUTC = ot.ScheduledStartUTC
    FROM ScheduleTickets st JOIN
         OtherTable ot
         ON st.ScheduleId = ot.ScheduleId AND st.PatchSessionId = ot.PatchSessionId;

你不指定特殊的逻辑，但你可以用 SQL 来表达它。