Dapper 结合 Polly 可实现数据库操作的弹性重试，需精准识别瞬态异常（如 SQL 错误码 -2、40613 等）、封装扩展方法统一应用策略，并规避非幂等操作重复执行等风险。
用 Dapper 执行数据库操作时，网络抖动、连接超时或 SQL Server 临时不可用都可能导致查询失败。Polly 是一个成熟的 .NET 弹性库，配合 Dapper 可以轻松实现重试、熔断等策略——关键不是“能不能”，而是“怎么配得稳、不误伤、不掩盖问题”。
1. 安装必要 NuGet 包
确保项目中已引用：
- Dapper（>= 2.0.123）
-
Polly（>= 8.4.0，推荐用
Polly.Core，轻量且支持 .NET 6+） - Microsoft.Data.SqlClient（>= 5.1.0，支持连接弹性内置重试，但仅限连接建立阶段；Dapper 的命令执行仍需手动加 Polly）
2. 定义重试策略（聚焦常见数据库异常）
不要对所有异常重试。只针对可恢复的瞬态错误，比如：
- SQL Server 错误码：–2（连接超时）、40613（数据库已暂停）、40197/40501（服务繁忙）
- 网络异常：
SqlException中的InnerException是Win32Exception或TimeoutException - 连接被意外关闭（
InvalidOperationException提示 “The connection was closed”）
示例策略（最多重试 3 次，指数退避）：
var retryPolicy = Policy .Handle(ex => ex.Number is -2 or 40613 or 40197 or 40501 || ex.InnerException is TimeoutException or Win32Exception) .Or (ex => ex.Message.Contains("closed", StringComparison.OrdinalIgnoreCase)) .WaitAndRetryAsync( retryCount: 3, sleepDurationProvider: attempt => TimeSpan.FromMilliseconds(Math.Pow(2, attempt) * 100), onRetry: (outcome, timespan, retryCount, context) => Log.Warning("DB command failed (attempt {RetryCount}), retrying in {Delay}ms", retryCount, timespan.TotalMilliseconds) );
3. 将 Polly 注入 Dapper 执行流程（推荐封装扩展方法）
避免每个 QueryAsync 或 ExecuteAsync 都写重复策略调用。封装一个带重试的 Dapper 扩展：
public static class DapperRetryExtensions
{
public static async Task> QueryWithRetryAsync(
this IDbConnection connection,
string sql,
object? param = null,
IDbTransaction? transaction = null,
int? commandTimeout = null,
CancellationToken cancellationToken = default) where T : class
{
return await retryPolicy.ExecuteAsync(async ct =>
{
return await connection.QueryAsync(sql, param, transaction, commandTimeout, ct);
}, cancellationToken);
}
// 同理可封装 ExecuteWithRetryAsync、QuerySingleWithRetryAsync 等
}
使用时就像原生 Dapper 一样自然：
using var conn = new SqlConnection(connectionString); var users = await conn.QueryWithRetryAsync("SELECT * FROM Users WHERE Active = 1");
4. 注意事项与避坑点
重试不是万能解药，几个关键细节必须处理好：
-
非幂等操作慎用重试：比如
INSERT INTO Orders直接重试可能造成重复下单。解决方案：加唯一约束 + 捕获冲突异常（如 SQL Server 的错误码 2627），或改用带业务幂等键的存储过程 -
事务内重试要整体重试：不要只重试某一条语句。把整个事务逻辑包进
ExecuteAsync，并在重试前确保连接重新打开、事务重新开启 -
别忽略日志上下文：在
onRetry中记录 SQL 片段（脱敏）、参数哈希、当前连接字符串 Hash，方便排查是哪个查询在反复失败 -
连接字符串本身要启用基础连接重试：在连接字符串里加上
Connect Timeout=30;Connection Timeout=30;Connection Reset=false;，并确认SqlConnection的OpenAsync已由底层驱动自动重试（SQL Server 2019+ 默认开启）
基本上就这些。Dapper 轻量，Polly 灵活，两者结合不复杂但容易忽略边界场景。真正让重试“弹”起来的，不是策略多炫，而是对错误类型的精准识别和对业务语义的尊重。
