我通过 Oracle 的官方 .NET 托管驱动程序(Nuget 包)使用 Oracle。
我的应用程序从一开始就使用与数据库相同的连接,并且从多个位置使用它来执行查询。
在某些情况下,可能会出现连接“打嗝”而导致异常。问题是我不知道发生这种情况时重试执行查询的最佳策略是什么。
有没有通用的方法来解决这种情况?
我同意哈比卜的评论。
oracle .NET 包使用连接池。 即使您打开多个连接,它也会相应地管理它们,这样您就不必保持打开状态。
这意味着您的代码可以简化为这样的伪代码:
using(OracleConnection conn = MakeConnection())
{
//do stuff with connection
//not necessary, but I always manually close connection. Doesn't hurt.
conn.Close();
}
如果您即使在这么小的执行中也不确定连接问题,您可以将其包装在 try-catch 块中,如下所示:
try
{
using(OracleConnection conn = MakeConnection())
{
//do stuff with connection
//not necessary, but I always manually close connection. Doesn't hurt.
conn.Close();
}
}
catch(OracleException ex)
{
//handle exception.
}
OracleException 看起来是 .NET oracle 包的主要异常。 请注意,您可能还想更具体地捕捉其他内容。
在进行查询时,动态实例化连接会更容易。我认为简单的 try/catch 不会对您有帮助,因为即使您在 catch 块中重新初始化连接,您也必须以某种方式重新执行查询。
我不建议这样做,但您可以使用 Retry 类,在捕获异常时重新初始化连接....
public class Retry
{
public static void Do(Action action, TimeSpan retryInterval, int retryCount = 3)
{
Do<object>(() =>
{
action();
return null;
},
retryInterval, retryCount);
}
public static T Do<T>(Func<T> action, TimeSpan retryInterval, int retryCount = 3)
{
var exceptions = new List<Exception>();
for (int retry = 0; retry < retryCount; retry++)
{
try
{
if (retry > 0)
Thread.Sleep(retryInterval);
return action();
}
catch (ConnectionException ex)
{
// ***Handle the reconnection in here***
exceptions.Add(ex);
}
}
throw new AggregateException(exceptions);
}
}
然后您可以像这样调用您的查询
Retry.Do(() => MyQueryMethod, TimeSpan.FromSeconds(5));
我很久以前就从 SO 获得了此重试代码的基础,不记得该线程,但它不是我的原始代码。不过,我在某些事情上用过它很多次。