C#中如何执行数据库的批量查询？避免多次往返？-C#.Net教程-PHP中文网

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

小老鼠

发布： 2025-10-25 15:26:01

原创

312人浏览过

通过合并查询减少数据库往返，可使用存储过程、多语句SQL或表值参数。1. 存储过程封装多个查询，一次调用返回多结果集；2. 单条SQL含多个SELECT，分号分隔，用NextResult处理各集；3. 表值参数传入批量条件，避免循环查询；4. Dapper的QueryMultiple简化多结果集读取。核心是减少网络交互，提升性能。

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

在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或其他条件查询数据时，可以传入一张“表”作为参数，避免循环查询。

蓝心千询

蓝心千询是vivo推出的一个多功能AI智能助手

查看详情

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

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或表值参数减少网络往返次数，提升整体性能。

以上就是C#中如何执行数据库的批量查询？避免多次往返？的详细内容，更多请关注php中文网其它相关文章！