C#中如何执行数据库的批量查询？避免多次往返？

来源：这里教程网时间：2026-02-21 17:28:49 作者：

在C#中执行数据库批量查询并减少与数据库的多次往返，关键在于合并查询请求、使用高效的数据访问方式以及合理利用数据库特性。以下是几种实用方法：

1. 使用存储过程合并多个查询

将多个查询逻辑封装在数据库的存储过程中，一次调用返回多个结果集。

例如，在SQL Server中创建一个存储过程：

CREATE PROCEDURE GetMultipleData
AS
BEGIN
    SELECT * FROM Users;
    SELECT * FROM Orders;
    SELECT * FROM Products;
END

C#代码中调用：

using (var conn = new SqlConnection(connectionString))
{
    using (var cmd = new SqlCommand("GetMultipleData", conn))
    {
        cmd.CommandType = CommandType.StoredProcedure;
        conn.Open();
        using (var reader = cmd.ExecuteReader())
        {
            // 处理第一个结果集
            while (reader.Read()) { /* 读取 Users */ }
            reader.NextResult();
<pre class='brush:php;toolbar:false;'>        // 处理第二个结果集
        while (reader.Read()) { /* 读取 Orders */ }
        reader.NextResult();
        // 处理第三个结果集
        while (reader.Read()) { /* 读取 Products */ }
    }
}

}

2. 在单条SQL中使用多个SELECT语句

如果不需要存储过程，可以直接在一条命令中写多个查询，用分号分隔。

示例：

string sql = @"
    SELECT * FROM Users WHERE Status = 1;
    SELECT * FROM Orders WHERE CreatedDate > '2023-01-01';
    SELECT * FROM Products WHERE Stock > 0;
";
using (var cmd = new SqlCommand(sql, conn))
{
    using (var reader = cmd.ExecuteReader())
    {
        do
        {
            while (reader.Read())
            {
                // 按结果集分别处理
            }
        } while (reader.NextResult());
    }
}

3. 使用Table-Valued Parameters进行条件批量查询

当你需要根据一批ID或其他条件查询数据时，可以传入一张“表”作为参数，避免循环查询。

先在数据库定义用户类型：

CREATE TYPE IdList AS TABLE (Id INT);

然后编写查询语句：

SELECT * FROM Users WHERE Id IN (SELECT Id FROM @IdTable)

C#中传入DataTable：

var idTable = new DataTable();
idTable.Columns.Add("Id", typeof(int));
foreach (var id in ids) idTable.Rows.Add(id);
<p>using (var cmd = new SqlCommand("SELECT * FROM Users WHERE Id IN (SELECT Id FROM @IdTable)", conn))
{
var param = cmd.Parameters.AddWithValue("@IdTable", idTable);
param.SqlDbType = SqlDbType.Structured;
param.TypeName = "IdList";</p><pre class='brush:php;toolbar:false;'>using (var reader = cmd.ExecuteReader()) { /* 处理结果 */ }

}

4. 使用Dapper等ORM简化多结果集处理

Dapper支持一次性读取多个结果集，语法更简洁。

using (var connection = new SqlConnection(connectionString))
{
    using (var multi = connection.QueryMultiple("GetMultipleData", commandType: CommandType.StoredProcedure))
    {
        var users = multi.Read<User>().ToList();
        var orders = multi.Read<Order>().ToList();
        var products = multi.Read<Product>().ToList();
    }
}

基本上就这些。核心思路是：尽量让数据库一次完成所有查询任务，通过存储过程、多语句SQL或表值参数减少网络往返次数，提升整体性能。