ASP.NET C # MySQL-Abfrageausführung wird nach einem Fehler wiederholt

Gibt es ein ASP.NET-Paket / DLL, mit dem die Ausführung von MySQL-Abfragen bei einem Fehler wiederholt werden kann?

Ich habe über Transient Fault Handling gelesen und bin sogar auf ein Dapper-Problem gestoßen, das ein Beispiel zeigt, aber aus meiner Forschung funktioniert das nur mit SqlServer und / oder Azure.

Mein Tech-Stack ist wie folgt:

• .NET 4.5.2
• Dapper 1.50.2.0
• MySQL 5.6 (mit Amazon Aurora)

Letztendlich versuche ich, ein sporadisches Fehlerproblem zu lösen , und ich glaube, dass die Implementierung einer Wiederholungslogik helfen würde, das Problem zu beheben.

Ich habe versucht, Code von diesem Dapper-Problem zu implementieren, aber da ich MySql.Data verwende , um eine Verbindung zu meiner MySql-Datenbank herzustellen, funktioniert es nicht mit den verschiedenen Methoden, die für SqlServer-Verbindungen spezifisch sind.

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using Dapper;
using Microsoft.Practices.EnterpriseLibrary.TransientFaultHandling;

namespace TransientDapper
{
    public static class TransientDapperExtensions
    {
        private static readonly RetryManager SqlRetryManager = GetDefaultRetryManager();
        private static readonly RetryPolicy SqlCommandRetryPolicy = SqlRetryManager.GetDefaultSqlCommandRetryPolicy();
        private static readonly RetryPolicy SqlConnectionRetryPolicy =
            SqlRetryManager.GetDefaultSqlConnectionRetryPolicy();

        private static RetryManager GetDefaultRetryManager()
        {
            const int retryCount = 4;
            const int minBackoffDelayMilliseconds = 2000;
            const int maxBackoffDelayMilliseconds = 8000;
            const int deltaBackoffMilliseconds = 2000;

            var exponentialBackoffStrategy =
                new ExponentialBackoff(
                    "exponentialBackoffStrategy",
                    retryCount,
                    TimeSpan.FromMilliseconds(minBackoffDelayMilliseconds),
                    TimeSpan.FromMilliseconds(maxBackoffDelayMilliseconds),
                    TimeSpan.FromMilliseconds(deltaBackoffMilliseconds)
                    );

            var manager = new RetryManager(
                new List<RetryStrategy>
                {
                    exponentialBackoffStrategy
                },
                exponentialBackoffStrategy.Name
                );

            return manager;
        }

        public static void OpenWithRetry(this SqlConnection cnn)
        {
            cnn.OpenWithRetry(SqlConnectionRetryPolicy);
        }

        public static IEnumerable<T> QueryWithRetry<T>(
            this SqlConnection cnn, string sql, object param = null, IDbTransaction transaction = null,
            bool buffered = true, int? commandTimeout = null, CommandType? commandType = null
            )
        {
            return SqlCommandRetryPolicy.ExecuteAction(
                () => cnn.Query<T>(sql, param, transaction, buffered, commandTimeout, commandType)
                );
        }
    }
}