c# - 使用 SqlBulkCopy 查询
问题描述
我有一个参数化查询,出于演示目的,我们假设它是
SELECT Id, Name
FROM People
WHERE Age >= @Age
假设这可能是数百万条记录,我想将这些记录批量加载到 table 中Population (Id, Name)
。
通过遵循我看到的大多数示例,SqlBulkCopy
我将使用第一个查询来获取数据表,然后我可以将该数据表批量加载到Population
但我不需要读取查询,将其放入内存中只是为了再次写入。本质上,我希望将查询批量加载到表中,而不必在 C# 中读取查询,所有 IO 都应该发生在数据库中。
我该怎么做?这是我的尝试:
using (var conn = new SqlConnection(SomeConnectionString))
using (var cmd = conn.CreateCommand())
{
conn.Open();
cmd.CommandText = "SELECT Id, Name FROM People WHERE Age >= @Age";
cmd.Parameters.AddWithValue("@Age", 10);
using (var reader = cmd.ExecuteReader())
using (SqlBulkCopy bulkcopy = new SqlBulkCopy(SomeConnectionString))
{
bulkcopy.DestinationTableName = "[Population]";
bulkcopy.WriteToServer(reader);
bulkcopy.Close();
}
}
我不确定是否ExecuteReader
只是设置一个指针开始读取或实际将查询读入内存。
在有人建议执行查询之前
INSERT INTO Population
SELECT Id, Name
FROM People
WHERE Age >= @Age
知道我要批量加载的查询将作为变量(带有参数)进入,因为我不知道查询将是什么,只是我希望它能够很好地映射并且我希望它批量加载。
解决方案
根据评论:
如果没有 MARS,除了使用 DataTable 并将其用于 SqlBulkCopy 之外别无他法,因为当数据读取器仍处于打开状态时,您无法使用相同的连接进行批量复制。您必须关闭第一个连接才能稍后与 SqlBulkCopy 一起使用。
推荐阅读
- reactjs - 用于 redux-saga 中错误处理的打字稿
- python - 具有自定义键/比较功能的 Pandas groupby max
- flutter - 由于类型,无法生成 toJson 代码
- json - Powershell - 比特桶
- java - java.lang.VerifyError:验证程序被拒绝。拒绝调用,预期 36 个参数寄存器,方法签名有 37 个或更多
- grammar - 语法和语义错误之间的歧义
- leaflet - 使用 laravel mix 出现两次传单标记
- visual-studio-code - 将 git bash 添加到 VSCode 中的默认 shell 列表
- mongodb - 无法在 docker 容器中为 mongodb 日志设置卷
- php - symfony:分页+排序功能