有没有办法让数据库连接保持打开并准备好在运行时使用？我们的 WCF 服务应该以这种方式保持连接。现在我们的代码看起来类似于这段代码：
// This is the class of objects that has connections within.
[DataContract]
public class SomeObj
{
[DataMember]
public string Name { get; set; }
public OracleConnection Conn { get; set; }
}
// Dictionary of SomeObjs
private static Dictionary<string, SomeObj> myObjs = new Dictionary<string, SomeObj>();
当服务启动时，它还会从自己的配置文件中连接所有数据库，其中包含连接字符串。但正如您所知，连接可能会损坏且无法使用，甚至最终无法访问。所以为了消除这个问题，我们有一个特殊的计时器来检查配置中的所有连接：
// Setup timer method. Timer will fire every minute.
static private void CreateTimer()
{
Timer Timer1 = new System.Timers.Timer();
Timer1.Enabled = true;
Timer1.Interval = 60000;
Timer1.Elapsed += new System.Timers.ElapsedEventHandler(Timer1_Elapsed);
}
static private void Timer1_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
{
Parallel.ForEach(Program.config.Root.Elements("databases"), el =>
{
try
{
Program.OpenConnection(el.Attribute("name").Value);
}
catch (Exception exc)
{
Console.WriteLine(DateTime.Now.ToString() + " " + exc);
}
});
// This is old way we checks connections consistently
//foreach (XElement element in Program.config.Root.Elements("databases"))
//{
// try
// {
// AServ.OpenConnection(el.Attribute("name").Value);
// }
// catch (Exception exc)
// {
// Console.WriteLine(DateTime.Now.ToString() + " " + exc);
// }
//}
}
public static bool OpenConnection(string name)
{
// if connections exactly doesn't exists
if (!myObjs.ContainsKey(name))
{
XElement el = (from t in config.Root.Elements("databases")
where t.Attribute("name").Value == name
select t).FirstOrDefault();
if (el == null)
{
lock (myObjs)
{
myObjs.Remove(name);
}
return false;
}
lock (myObjs)
{
myObjs.Add(name, new SomeObj { Conn = new OracleConnection { ConnectionString = el.Attribute("connectionString").Value } }, Name = el.Attribute("name").Value);
}
}
// if connection broken
if ((myObjs[name].Conn.State != ConnectionState.Open || !myObjs[name].Conn.Ping()) && myObjs.ContainsKey(name))
{
try
{
// Trying to get it alive
lock (myObjs)
{
myObjs[name].Conn.Close();
myObjs[name].Conn.Open();
}
}
catch (Exception e)
{
if (!myObjs.ContainsKey(name))
return false;
lock (myObjs)
{
myObjs.Remove(name);
}
return false;
}
Console.WriteLine(DateTime.Now.ToString() + " " + myObjs[name].Conn.ConnectionString);
}
return true;
}
伙计们，你应该知道的另一件事是我们如何在方法本身中使用保持连接：
private static int GetParameterValue(string name, int id)
{
// if we don't get parameter value at the moment because broken connection
if (!OpenConnection(name))
return -1;
// assuming connection is OK and getting the parameter value
string parameterQuery = @"select GetInfo(:id) from dual";
OracleCommand parameterCommand = new OracleCommand(parameterQuery, myObjs[name].Conn);
parameterCommand.Parameters.Add("id", id);
return Convert.ToInt32(parameterCommand.ExecuteScalar());
}
问题是有时第一个计时器检查无法及时完成，第二个计时器检查在第一个计时器运行时开始。它给出了一些奇怪的堆内存泄漏错误（我认为是这样）。另一个问题是，即使我们将单例设计模式开发为只有一次检查时间，检查可能会挂起，而另一个检查永远不会被触发（因为对于某些数据库来说，打开连接需要很长的时间。我不知道为什么会这样，但我们尝试添加Connection timeout=30;，但老实说，我不记得是否给出了正确的结果。当然不是。）。
然后这个服务及时运行它会占用与运行一样多的内存。我用这段代码尝试了很多操作，甚至有一次在代码中的某处遇到死锁（几乎 100% 的 CPU 负载）。
是的，我知道本机 ADO .NET 池，但我们不能使用它，因为我们有大量的遗留代码库，可以按照上面说明的方式工作，并且应该以某种方式改进现有的检查逻辑。
那么请告诉我您的想法，我们如何才能在不进行池化的情况下及时建立连接？我需要一些可以使用尽可能少的内存的方法（现有代码在运行时占用尽可能多的内存），并且可以通过小的代码更改快速工作。
非常感谢任何帮助！真的希望对你的帮助stackoverflow社区！
我考虑使用特殊的线程来检查最后的循环连接Thread.Sleep(60000)。但我不确定。
ADO .NET 提供者是Devart dotConnect for Oracle。数据库是 Oracle 9-11（取决于服务器），C# .NET Framework 4。