我之前帮不少开发者解决过类似的跨库批量数据提取问题，IN语句的长度限制（SQL Server默认对IN子句的参数数量有隐性限制，一般超过3000就容易报错）确实是个头疼的坎。下面给你梳理几种可行方案，其中表值参数（TVP）+ SqlBulkCopy是最快的实现方式，完全适配你的场景。

一、最快方案：表值参数（TVP）+ SqlBulkCopy #

这个方案不需要跨服务器权限，能一次性传递所有4000个ID，避免IN的限制，而且数据传输和插入效率拉满。

步骤1：在远程SQL Server创建用户定义表类型 #

先在远程库执行这个SQL，创建一个用来接收ID列表的表类型（要和Customer表的ID字段类型完全匹配，比如你的ID是字符串类型，就用对应长度的NVARCHAR）：

CREATE TYPE [dbo].[CustomerIdList] AS TABLE(
    [Id] NVARCHAR(50) NOT NULL -- 替换成你实际的ID类型和长度
)

步骤2：.NET端实现数据提取 #

用C#代码创建ID列表对应的DataTable，通过表值参数传递给远程SQL，查询后用SqlBulkCopy批量插入本地数据库：

// 1. 准备要查询的4000个ID列表
List<string> targetCustomerIds = GetYourCustomerIdList(); // 替换成你的ID列表获取逻辑

// 2. 创建匹配表类型的DataTable
DataTable idTable = new DataTable();
idTable.Columns.Add("Id", typeof(string)); // 类型要和远程表类型一致
foreach (var id in targetCustomerIds)
{
    idTable.Rows.Add(id);
}

// 3. 从远程库查询数据
DataTable resultData = new DataTable();
using (SqlConnection remoteConn = new SqlConnection("你的远程SQL连接字符串"))
{
    remoteConn.Open();
    string query = @"
        SELECT c.ID, c.Name, c.Phone, c.Occupation, c.Gender
        FROM Customer c
        INNER JOIN @CustomerIds ids ON c.ID = ids.Id
    ";
    using (SqlCommand cmd = new SqlCommand(query, remoteConn))
    {
        // 添加表值参数
        SqlParameter tvpParam = cmd.Parameters.AddWithValue("@CustomerIds", idTable);
        tvpParam.SqlDbType = SqlDbType.Structured;
        tvpParam.TypeName = "dbo.CustomerIdList"; // 对应远程创建的表类型名称

        // 填充结果DataTable
        using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
        {
            adapter.Fill(resultData);
        }
    }
}

// 4. 批量插入本地SQL数据库
using (SqlConnection localConn = new SqlConnection("你的本地SQL连接字符串"))
{
    localConn.Open();
    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(localConn))
    {
        bulkCopy.DestinationTableName = "本地Customer表名称";
        // 映射字段（如果字段名完全一致可以省略，否则需要手动映射）
        bulkCopy.ColumnMappings.Add("ID", "ID");
        bulkCopy.ColumnMappings.Add("Name", "Name");
        bulkCopy.ColumnMappings.Add("Phone", "Phone");
        bulkCopy.ColumnMappings.Add("Occupation", "Occupation");
        bulkCopy.ColumnMappings.Add("Gender", "Gender");
        
        bulkCopy.WriteToServer(resultData);
    }
}

方案优势 #

• 一次性传递所有ID，避免多次请求远程服务器
• 绕过IN语句的长度限制，支持任意数量的ID（只要内存足够）
• SqlBulkCopy是本地插入最快的方式，比逐条Insert快几个数量级

二、其他可行方案 #

如果无法在远程库创建表类型（比如没有权限），可以考虑以下备选：

1. 分批IN查询 #

把4000个ID分成若干批次（比如每2000个一批，或者更保守的每1000个一批），循环执行IN查询，然后合并结果：

List<string> targetIds = GetYourCustomerIdList();
DataTable resultData = new DataTable();
int batchSize = 1000;

for (int i = 0; i < targetIds.Count; i += batchSize)
{
    var batchIds = targetIds.Skip(i).Take(batchSize).ToList();
    // 注意：如果ID是用户输入的，一定要用参数化查询避免SQL注入，此处为示例简化拼接
    string idList = string.Join("','", batchIds);
    string query = $"SELECT * FROM Customer WHERE ID IN ('{idList}')";
    
    // 执行查询并将结果合并到resultData
    using (SqlConnection conn = new SqlConnection("远程连接字符串"))
    {
        conn.Open();
        using (SqlCommand cmd = new SqlCommand(query, conn))
        {
            using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
            {
                DataTable batchData = new DataTable();
                adapter.Fill(batchData);
                resultData.Merge(batchData);
            }
        }
    }
}

// 后续用SqlBulkCopy插入本地库（同上）

重要提醒：如果ID包含用户输入内容，绝对不能直接拼接字符串，要改用参数化查询（比如为每个ID创建一个SQL参数）。

2. 本地临时表+跨库查询（如果允许跨服务器访问） #

如果本地SQL Server可以访问远程库（需要配置链接服务器或者使用OPENROWSET），可以先把4000个ID插入本地临时表，然后通过跨库关联查询：

-- 本地SQL执行的查询
SELECT c.*
FROM OPENROWSET('SQLNCLI', '远程连接字符串'; '用户名'; '密码', 'SELECT * FROM Customer') c
INNER JOIN #LocalIdList l ON c.ID = l.Id

这个方案需要本地服务器有访问远程库的权限，并且可能需要开启Ad Hoc Distributed Queries，安全性需要提前评估。

3. 远程临时表批量上传（如果有远程库权限） #

如果能在远程库创建临时表，可以先用SqlBulkCopy把ID列表上传到远程的会话级临时表，然后关联查询：

// 1. 上传ID到远程临时表
using (SqlConnection remoteConn = new SqlConnection("远程连接字符串"))
{
    remoteConn.Open();
    // 创建远程临时表
    remoteConn.ExecuteNonQuery("CREATE TABLE #TempCustomerIds (Id NVARCHAR(50) NOT NULL)");
    
    // 批量插入ID到临时表
    using (SqlBulkCopy bulkCopy = new SqlBulkCopy(remoteConn))
    {
        bulkCopy.DestinationTableName = "#TempCustomerIds";
        bulkCopy.WriteToServer(idTable); // idTable是之前创建的ID列表DataTable
    }
    
    // 2. 查询关联数据
    string query = "SELECT c.* FROM Customer c INNER JOIN #TempCustomerIds t ON c.ID = t.Id";
    // 执行查询并获取结果（逻辑同之前的DataTable填充）
}

注意：临时表是会话级的，必须在同一个连接里完成创建、插入、查询操作。

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