c# - Polly 未正确处理 OracleExceptions ORA-03113 和 ORA-03114

标签 c# oracle polly

我之前关于 Polly 和 Oracle Connectivity 的问题如下

async await throwing error for Polly code while connecting to Oracle DB

对此进行扩展，我尝试根据连接和 FTP 连接来处理多个 Oracle 异常。它能够正确处理 FTP 异常。但是对于Oracle来说，它无法处理0RA-03113和ORA-03114

这是我实现的代码..

static void Main()
    {
        var retryTimes = 100;
        var retryableOracleErrorCodes = new[] { "ORA-03113", "ORA-03114", "ORA-12543", "ORA-12170", "ORA-12154"  };

        RetryPolicy retryPolicyFTP = Policy
            .Handle<Xceed.Ftp.FtpInvalidStateException>()
            .WaitAndRetry(retryTimes, _ => TimeSpan.FromSeconds(10));

        RetryPolicy retryPolicyFTP1 = Policy
            .Handle<Xceed.Ftp.FtpIOException>()
            .WaitAndRetry(retryTimes, _ => TimeSpan.FromSeconds(10));

        RetryPolicy retryPolicyOracle = Policy
            .Handle<OracleException>(ex => retryableOracleErrorCodes.Any(errorCode => ex.Message.Contains(errorCode)))
            .RetryForever();

        retryPolicyFTP.Execute(() =>
        {
            retryPolicyFTP1.Execute(() =>
            {
                retryPolicyOracle.Execute(() =>
                {
                    ApplicationMain applicationMain = new ApplicationMain();
                    applicationMain.Start();
                });
            });
        });
    }

您能否阐明这一点...为什么它无法处理特定的 Oracle 异常...我的意思是，如果我断开程序和 Oracle DB 之间的连接，它应该保持沉默而不抛出该异常，并在连接时再次出现可用，它应该能够检索数据库记录..

为什么它没有变得沉默以及为什么它会中断...ORA-03113 和 ORA-03114。抛出的错误如下所示..

enter image description here

详细异常如下..

36722763    Source.FtpInternal1.Poll    Failed  2021-04-30 08:40:00 2021-04- 
30 08:40:04     Oracle.DataAccess.Client.OracleException ORA-03113: end-of- 
file on communication channel
Process ID: 149519
Session ID: 1655 Serial number: 65101    at 
Oracle.DataAccess.Client.OracleException.HandleErrorHelper(Int32 errCode, 
OracleConnection conn, IntPtr opsErrCtx, OpoSqlValCtx* pOpoSqlValCtx, Object 
src, String procedure, Boolean bCheck)
at Oracle.DataAccess.Client.OracleException.HandleError(Int32 errCode, 
OracleConnection conn, String procedure, IntPtr opsErrCtx, OpoSqlValCtx* 
pOpoSqlValCtx, Object src, Boolean bCheck)
at Oracle.DataAccess.Client.OracleCommand.ExecuteReader(Boolean requery, 
Boolean fillRequest, CommandBehavior behavior)
at Oracle.DataAccess.Client.OracleCommand.ExecuteReader()
at Data.MetaRecord.Fill(DataTable dataTable, RecordCommand recordCommand, 
Object[] parameterValues, FillResultType fillResultType) in 
C:\Data\MetaRecord.cs:line 1348
at Data.MetaRecord.FillWithComposites(RecordCommandCompositeCollection 
recordCommandComposites, RecordCommandComposite parentRecordCommandComposite, 
Object[] parameterValues, FillResultType fillResultType) in 
C:\Data\MetaRecord.cs:line 1537
at Data.MetaRecord.FillWithComposites(RecordCommandCompositeCollection 
recordCommandComposites, RecordCommandComposite parentRecordCommandComposite, 
Object[] parameterValues, FillResultType fillResultType) in 
C:\Data\MetaRecord.cs:line 1551
at Data.MetaRecord.FillWithComposites(RecordCommandCompositeCollection 
recordCommandComposites, RecordCommandComposite parentRecordCommandComposite, 
Object[] parameterValues, FillResultType fillResultType) in 
C:\Data\MetaRecord.cs:line 1551
at Data.MetaRecord.RetrieveByPrimaryKey(RecordRetrieveAttributes 
recordRetrieveAttributes, Object[] primaryKeyValues) in 
C:\Data\MetaRecord.cs:line 1830
at Data.MetaRecord.GetRecordByPrimaryKey(RecordGetAttributes 
recordGetAttributes, Object[] primaryKeyValues) in C:\Data\MetaRecord.cs:line 
873
at Data.MetaRecord.GetRecordByPrimaryKey(Object[] primaryKeyValues) in 
C:\Data\MetaRecord.cs:line 923
at Processors.ExecuteInfo.GetAndRegisterRecord(RecordType recordType, 
Object[] primaryKeyValues) in C:\Core\Processors\ExecuteInfo.cs:line 143
at Processors.InternalPoll.ProcessExecute(DataTransaction dataTransaction, 
ExecuteInfo executeInfo, ProcessInfo processInfo) in 
C:\Core\Processors\InternalPoll.cs:line 67
at Processors.Processor.Execute(ExecuteInfo executeInfo, ProcessInfo 
processInfo) in C:\Core\Processors\Processor.cs:line 184

这是我准备的最终代码，但它仍然没有抛出 OracleException 消息

var retryTimes = 100;
var retryableOracleErrorCodes = new[] { "ORA-03113", "ORA-03114", "ORA-12543", "ORA-12170", "ORA-12154" };

RetryPolicy retryPolicyFTP = Policy
    .Handle<Xceed.Ftp.FtpInvalidStateException>().Or<Xceed.Ftp.FtpIOException>()
    .WaitAndRetry(retryTimes, _ => TimeSpan.FromSeconds(10));

RetryPolicy retryPolicyOracle = Policy
    .Handle<OracleException>(ex => retryableOracleErrorCodes
                                    .Any(errorCode => ex.ToString().Contains(errorCode)))
    .RetryForever();

Policy.Wrap(retryPolicyFTP, retryPolicyOracle).Execute(() =>
{
    try
    {
         ApplicationMain applicationMain = new ApplicationMain();
         applicationMain.Start();
    }
    catch (OracleException oraEx)
    {
         MessageBox.Show(oraEx.Message.ToString());
    }
});

添加 .Or<Exception>() 后收到以下消息最终代码

Oracle.DataAccess.Client.OracleException ORA-03114: not connected to ORACLE    at Oracle.DataAccess.Client.OracleException.HandleErrorHelper(Int32 errCode, OracleConnection conn, IntPtr opsErrCtx, OpoSqlValCtx* pOpoSqlValCtx, Object src, String procedure, Boolean bCheck)
   at Oracle.DataAccess.Client.OracleException.HandleError(Int32 errCode, OracleConnection conn, String procedure, IntPtr opsErrCtx, OpoSqlValCtx* pOpoSqlValCtx, Object src)
   at Oracle.DataAccess.Client.OracleCommand.ExecuteNonQuery()
   at Data.OraclePackageCommand.ExecuteNonQuery(OracleTransaction transaction) in C:\Core\Data\OraclePackageCommand.cs:line 74
   at Data.OraclePackageCommand.ExecuteNonQuery() in C:\Core\Data\OraclePackageCommand.cs:line 63
   at Data.OraclePackage.ExecuteServerHeartbeat(Int32 serverId, Int32 heartbeatInterval, DateTime processTime, Int32& processingStatusId, DateTime& lastHeartbeatTime, DateTime& nextHeartbeatTime, Int32& availableProcessCount, Boolean& recordModificationExists) in C:\Core\Data\OraclePackage.cs:line 2385
   at Processors.ServerInfo.Heartbeat(DateTime processTime, ServerProcessingStatus& heartbeatProcessingStatus, Int32& availableProcessCount, Boolean& recordModificationExists) in C:\Core\Processors\ServerInfo.cs:line 252
   at Processors.ServerManager.ThreadStart() in C:\Core\Processors\ServerManager.cs:line 337

最佳答案

TL;DR:我认为你的问题的根本原因是吞噬异常。

try
{
     ApplicationMain applicationMain = new ApplicationMain();
     applicationMain.Start();
}
catch (OracleException oraEx)
{
     MessageBox.Show(oraEx.Message.ToString());
}

当 OracleException被抛出然后显示在 UI 上
但随后该方法结束并且不会触发任何策略。

为了能够重现您的问题，我更改了以下内容:

  • 我已将第 3 方异常(exception)替换为内置异常(exception)
    • FtpInvalidStateException >> NotSupportedException
    • OracleException >> ArgumentException
  • 我为每个 onRetry 定义了两个代表触发策略时打印异常消息
  • 我已将最大重试次数和重试之间的等待时间更改为更小
  • 我已将要修饰的代码片段提取到一个单独的函数中，名为 FaultyMethod
  • 最后我制作了FaultyMethod真的有问题:)

主要包含策略声明和使用

static readonly string[] retryableErrorCodes = 
    new[] { "ORA-03113", "ORA-03114", "ORA-12543", "ORA-12170", "ORA-12154" };
const int retryTimes = 3;

static void Main()
{
    RetryPolicy retryForNotSupported = Policy
        .Handle<NotSupportedException>()
        .WaitAndRetry(
            retryTimes,
            _ => TimeSpan.FromSeconds(1),
            (ex, ts) => Console.WriteLine(ex.Message));

    RetryPolicy retryForArgument = Policy
        .Handle<ArgumentException>(ex =>
            retryableErrorCodes.Any(errorCode => ex.Message.Contains(errorCode)))
        .RetryForever(ex => Console.WriteLine(ex.Message));

    try
    {
        Policy.Wrap(retryForNotSupported, retryForArgument).Execute(FaultyMethod);
    } catch (Exception ex)
    {
        Console.WriteLine(ex);
        Environment.Exit(-1);
    }
    Console.WriteLine("Finished");
}

待装饰函数

static int errorCount = -1;
static void FaultyMethod()
{
    try
    {
        if (++errorCount >= retryableErrorCodes.Length)
            throw new NotSupportedException();
        throw new ArgumentException($"{retryableErrorCodes[errorCount]}");
    }
    catch (ArgumentException ex)
    {
        Console.WriteLine(ex.Message);
    }
}

如果您运行此应用程序，您将看到以下内容:

ORA-03113
Finished
  1. ArgumentException抛出消息 ORA-03113
  2. 异常在 FaultyMethod 内被捕获它的消息被打印出来
  3. 未触发任何重试策略
  4. Policy 没有抛出异常的Execute这就是打印 Finished 的原因

现在让我们更改代码以抛出 NotSupportedException相反

static void FaultyMethod()
{
    try
    {
        if(++errorCount <= retryTimes)
            throw new NotSupportedException();
        
        //if (++errorCount >= retryableErrorCodes.Length) 
        //    throw new ArgumentException($"{retryableErrorCodes[errorCount]}");
    }
    catch (ArgumentException ex)
    {
        Console.WriteLine(ex.Message);
    }
}

那么输出将是:

Specified method is not supported.
Specified method is not supported.
Specified method is not supported.
System.NotSupportedException: Specified method is not supported.
...
  1. FaultyMethod抛出NotSupportedException
  2. 它的 catch block 没有捕获此异常
  3. 内部重试策略从其角度检查是否是已处理的异常
  4. 不，不是这就是为什么它将问题升级到外部政策
  5. 外部重试策略从其角度检查是否是已处理的异常
  6. 是的，是的这就是为什么它会等待 1 秒然后再启动新的重试
  7. 这个完全相同的序列(从 1 到 6)再重复 2 次
  8. 当外部策略达到其重试计数阈值时，它将抛出原始异常 NotSupportedException
  9. Main的 try-catch 会捕获它并打印出来然后退出

因此，如果您从 FaultyMethod 中删除 try-catch 

static void FaultyMethod()
{
    if (++errorCount >= retryableErrorCodes.Length)
        throw new NotSupportedException();
    throw new ArgumentException($"{retryableErrorCodes[errorCount]}");
}

那么输出将如下所示:

ORA-03113
ORA-03114
ORA-12543
ORA-12170
ORA-12154
Specified method is not supported.
Specified method is not supported.
Specified method is not supported.
System.NotSupportedException: Specified method is not supported.
  • 全部 ArgumentException由内部策略处理，不超过其重试次数(无限)
  • 全部 NotSupportedException在超过重试次数 (3) 之前由外部策略处理

关于c# - Polly 未正确处理 OracleExceptions ORA-03113 和 ORA-03114，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/67330054/

上一篇：react-native - 解决办法博览会 react native 网页启动画面

下一篇：ruby-on-rails - rails : Cache API request with Typhoeus

相关文章：

mysql - SQL 计数与 SELECT 子句中的另一个表

c# - 波莉 - 'Cannot access a closed Stream'

c# - 无法将类型 'Polly.CircuitBreaker.AsyncCircuitBreaker' 隐式转换为 'Polly.Policy'

c# - httpclient工厂连线可以重复使用吗

c# - 使用 [XmlAttribute] 进行 xml 反序列化时的空值

c# - 对路径 '(Temp Folder)' 的访问被拒绝。将项目或类文件添加到我的 Visual Studio 解决方案时发生

sql - TYPE 可以声明为 ref cursor rowtype

sql - 相当于 SQL Server INSERTED 和 DELETED 表的 Oracle

c# - 如何隐藏折线图中数据点的标签

c# - 将 VS 代码片段与 Resharper 结合使用

©2024 IT工具网  联系我们