我们在 Azure Sql 连接和命令上应用了 Microsoft 的企业库瞬态故障处理块。
例如,
using(var sqlConnection = new ReliableSqlConnection(_connectionString, _connectionRetry, _commandRetry)
{
var command = sqlConnection.CreateCommand();
command.CommandText = "...";
sqlConnection.Open();
using(var reader = sqlConnection.ExecuteCommand<SqlDataReader>(command))
{
...
}
}
它适用于例如command.ExecuteReader()
,这是没有重试策略的原始调用。但是如果代码使用DataSet
and怎么办SqlDataAdapter
:
using(var sqlConnection = new ReliableSqlConnection(_connectionString, _connectionRetry, _commandRetry)
{
var command = sqlConnection.CreateCommand();
command.CommandText = "...";
sqlConnection.Open();
// how to convert below codes to right way?
var adapter = new SqlDataAdapter(command);
var dataSet = new DataSet();
adapter.Fill(dataSet);
// handle dataSet
...
}
我们主要在处理一些遗留代码以添加一些重试策略。