C#+Dapper操作Oracle19c：如何优化批量art_id查询性能？

你的问题根源是10000次数据库请求带来的巨大网络开销和SQL解析成本——每次单条查询都要经历连接复用、SQL解析、执行、结果返回的流程，累加起来速度自然极慢。结合Dapper和Oracle 19c，有两种高效的优化方式：

方案一：分批次批量查询（兼容所有场景） #

Oracle的IN子句默认最多支持1000个元素，我们可以把10000个art_id分成10个左右的批次，每个批次执行一次查询，最后把结果映射回原列表：

步骤1：提取所有art_id并分批次 #

var artIds = list.Select(item => item.art_id).ToList();
var batchSize = 999; // 留1个余量避免边界问题
var batches = artIds
    .Select((id, idx) => new { Id = id, BatchIdx = idx / batchSize })
    .GroupBy(x => x.BatchIdx)
    .Select(g => g.Select(x => x.Id).ToList())
    .ToList();

步骤2：批量查询并缓存结果 #

var valueMap = new Dictionary<int, YourValueType>(); // 替换成实际的art_id类型和someValue类型

using (var conn = new OracleConnection("你的数据库连接字符串"))
{
    conn.Open();
    foreach (var batch in batches)
    {
        var sql = @"SELECT p.art_id, p.target_column AS someValue 
                    FROM your_table p 
                    WHERE p.art_id IN @ArtIds";
        
        // Dapper会自动处理IN子句的参数化，避免SQL注入
        var batchResults = conn.Query<(int art_id, YourValueType someValue)>(sql, new { ArtIds = batch });
        foreach (var res in batchResults)
        {
            valueMap[res.art_id] = res.someValue;
        }
    }
}

步骤3：映射回原列表 #

foreach (var item in list)
{
    if (valueMap.TryGetValue(item.art_id, out var value))
    {
        item.someValue = value;
    }
    else
    {
        // 处理art_id不存在的情况，比如设默认值
        item.someValue = default;
    }
}

方案二：使用Oracle集合类型（性能最优） #

如果允许使用Oracle的内置集合类型（比如SYS.ODCINUMBERLIST，适用于数字类型的art_id），可以直接把art_id数组作为参数传递，通过TABLE()函数转为临时表关联查询，只需要一次数据库请求：

var artIds = list.Select(item => item.art_id).ToArray();
var valueMap = new Dictionary<int, YourValueType>();

using (var conn = new OracleConnection("你的数据库连接字符串"))
{
    conn.Open();
    var sql = @"SELECT p.art_id, p.target_column AS someValue 
                FROM your_table p 
                INNER JOIN TABLE(:ArtIds) ids ON p.art_id = ids.COLUMN_VALUE";
    
    // 使用Dapper的OracleDynamicParameters处理数组参数
    var parameters = new OracleDynamicParameters();
    parameters.Add("ArtIds", artIds, OracleDbType.Int32, ParameterDirection.Input, artIds.Length);
    
    var results = conn.Query<(int art_id, YourValueType someValue)>(sql, parameters);
    valueMap = results.ToDictionary(r => r.art_id, r => r.someValue);
}

// 映射回原列表
foreach (var item in list)
{
    item.someValue = valueMap.TryGetValue(item.art_id, out var v) ? v : default;
}

关键注意事项 #

• 确保art_id列有索引：没有索引的话，批量查询依然会全表扫描，速度快不起来
• 始终用参数化查询：避免SQL注入，同时让Oracle复用查询计划
• 处理边界情况：比如部分art_id在数据库中不存在的场景，避免空引用异常

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