如何在C#调用的存储过程中向临时表插入大量行？

这个思路非常靠谱，毕竟当IN/NOT IN的列表太长时，不仅会有性能瓶颈，甚至可能触发SQL的参数数量限制。结合临时表+Azure Functions的方案完美解决了这个问题，我给你整理一套完整的可落地实现：

我们先写一个存储过程，它会读取你提前插入的临时表数据，返回业务表中不在排除ID列表里的记录：

CREATE PROCEDURE GetDataExcludingSpecifiedIDs
AS
BEGIN
    SET NOCOUNT ON;

    -- 处理空列表的边界情况：如果临时表没有数据，返回所有记录
    IF EXISTS (SELECT 1 FROM #TempExcludedIDs)
    BEGIN
        SELECT *
        FROM YourTargetTable -- 替换成你的业务表名称
        WHERE ID NOT IN (SELECT ID FROM #TempExcludedIDs);
    END
    ELSE
    BEGIN
        SELECT * FROM YourTargetTable;
    END
END

在C#函数里，我们需要完成建立数据库连接→创建临时表→批量插入排除ID→调用存储过程这几个步骤，用SqlBulkCopy来处理大量ID的插入效率最高：

using System.Data;
using System.Data.SqlClient;
using System.Collections.Generic;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;

public static class ExcludedIdsDataFetcher
{
    [FunctionName("ExcludedIdsDataFetcher")]
    public static void Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
    {
        // 这里替换成你的实际ID列表，比如从请求参数、配置或其他数据源获取
        var excludedIds = new List<int> { 101, 102, 203, 405, 506 };
        var sqlConnString = Environment.GetEnvironmentVariable("AzureSqlConnectionString");

        using (var conn = new SqlConnection(sqlConnString))
        {
            conn.Open();

            // 1. 创建会话级临时表（#开头的临时表仅当前连接可见，会话结束自动销毁）
            using (var createTableCmd = new SqlCommand("CREATE TABLE #TempExcludedIDs (ID INT);", conn))
            {
                createTableCmd.ExecuteNonQuery();
            }

            // 2. 批量插入ID到临时表，适合大量数据场景
            using (var bulkCopy = new SqlBulkCopy(conn))
            {
                bulkCopy.DestinationTableName = "#TempExcludedIDs";
                bulkCopy.ColumnMappings.Add("ID", "ID");

                // 将List转换为DataTable供SqlBulkCopy使用
                var idTable = new DataTable();
                idTable.Columns.Add("ID", typeof(int));
                foreach (var id in excludedIds)
                {
                    idTable.Rows.Add(id);
                }

                bulkCopy.WriteToServer(idTable);
            }

            // 3. 调用存储过程并处理结果
            using (var procCmd = new SqlCommand("GetDataExcludingSpecifiedIDs", conn))
            {
                procCmd.CommandType = CommandType.StoredProcedure;

                using (var reader = procCmd.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        // 示例：读取业务表的字段，根据你的实际表结构调整
                        var recordId = reader.GetInt32(reader.GetOrdinal("ID"));
                        var recordName = reader.GetString(reader.GetOrdinal("Name"));
                        log.LogInformation("获取到符合条件的记录：ID={RecordId}, Name={RecordName}", recordId, recordName);
                    }
                }
            }
        }
    }
}

• 临时表作用域：用#开头的临时表是会话级的，只有当前数据库连接能访问，连接关闭后自动删除，不用手动清理。
• 数据类型匹配：确保临时表的ID列类型和你的业务表ID列完全一致（比如都是INT、UNIQUEIDENTIFIER），避免隐式转换导致的性能问题或错误。
• 权限配置：确保Azure Functions使用的SQL账号拥有创建临时表、执行存储过程以及查询业务表的权限。
• 空列表处理：存储过程里加了IF EXISTS判断，避免当排除ID列表为空时，NOT IN (SELECT ...)返回空结果的问题。

内容的提问来源于stack exchange，提问作者RhomburVernius