如何检查数据库可用性

本文关键字：数据库 可用性 检查 何检查 | 更新日期: 2023-09-27 18:10:25

我有以下代码来测试DB连接，它定期运行以测试DB可用性:

private bool CheckDbConn()
{
   SqlConnection conn = null;
   bool result = true;
   try
   {
       conn = DBConnection.getNewCon();
       ConnectionState conState = conn.State;
       if (conState == ConnectionState.Closed || conState == ConnectionState.Broken)
       {
          logger.Warn(LogTopicEnum.Agent, "Connection failed in DB connection test on CheckDBConnection");
          return false;
       }             
   }
   catch (Exception ex)
   {
      logger.Warn(LogTopicEnum.Agent, "Error in DB connection test on CheckDBConnection", ex);
      return false; // any error is considered as db connection error for now
   }
   finally
   {
      try
      {
         if (conn != null)
         {
            conn.Close();
         }
      }
      catch (Exception ex)
      {
         logger.Warn(LogTopicEnum.Agent, "Error closing connection on CheckDBConnection", ex);
         result = false;
      }
   }
   return result;
}

: 

static public SqlConnection getNewCon()
{
    SqlConnection newCon = new SqlConnection();
    newCon.ConnectionString = DBConnection.ConnectionString; // m_con.ConnectionString;
    newCon.Open();
    return newCon;
}

我的问题是:这会像预期的那样工作吗?

具体来说，我关心的是ConnectionState的测试。是否有可能状态将是:连接(因为Open()是同步的)?

在这种情况下我该怎么做?

如何检查数据库可用性

你可以这样试试。

    public bool IsServerConnected()
    {
        using (var l_oConnection = new SqlConnection(DBConnection.ConnectionString))
        {
            try
            {
                l_oConnection.Open();
                return true;
            }
            catch (SqlException)
            {
                return false;
            }
        }
    }

当SqlConnection无法连接到服务器时，将抛出SqlException。

public static class SqlExtensions
{
    public static bool IsAvailable(this SqlConnection connection)
    {
        try
        {
            connection.Open();
            connection.Close();
        }
        catch(SqlException)
        {
            return false;
        }
        return true;
    }
}

用法:

using(SqlConnection connection = GetConnection())
{
    if(connection.IsAvailable())
    {
        // Success
    }
}

您的代码看起来不错，但是您确实需要使用IDisposable模式，并且还需要一些命名约定:

private bool CheckDbConnection(string connectionString)
{
    try
    {
        using(var connection = new SqlConnection(connectionString))
        {
            connection.Open();
            return true;
        }
    }
    catch (Exception ex)
    {
        logger.Warn(LogTopicEnum.Agent, "Error in DB connection test on CheckDBConnection", ex);
        return false; // any error is considered as db connection error for now
    }
}

和connection.Close()不应该抛出。只要使用using块，你就可以了。

不需要测试Close状态，因为您刚刚打开了它。
关于Broken状态的更多信息:

Broken与数据源的连接断开。这是可能发生的只有在连接打开之后。处于这种状态的连接可能会关闭，然后重新开放。(这个值是为将来保留的产品版本。)

不需要测试

如果您在多线程上下文中并且您的连接实例是共享的，则Connecting状态可能会被捕获。但这不是你的情况。

此代码在调用时不会阻塞UI。

public static class DatabaseExtensions
{
    public static async Task<bool> IsConnectionViable(this string connectionStr)
    {
        await using var sqlConn = new SqlConnection(connectionStr);
        return await sqlConn.IsConnectionViable();
    }
    public static async Task<bool> IsConnectionViable(this SqlConnection connection)
    {
        var isConnected = false;
        try
        {
            await connection.OpenAsync();
            isConnected = (connection.State == ConnectionState.Open);
        }
        catch (Exception)
        {
            // ignored
        }
        return isConnected;
    }
}

实际上，在visual studio中，连接类有sonnectionstate属性。

当连接状态发生变化时，触发connections statechange事件。

你可能想看看这篇文章。

https://msdn.microsoft.com/en-us/library/aa326268 (v = vs.71) . aspx

我正在使用@Ramesh Durai的解决方案，但发现至少在我的设置(应用程序启动后定期调用/测试;使用。net 3.5和Sql Server 2012数据库)，在使数据库脱机后第一次调用IsConnected()返回true。然而，它在下面的ExecuteScalar()行抛出了预期的异常:

public bool IsConnected() {
    using (var conn = new SqlConnection(DBConnection.ConnectionString)) {
        using (var cmd = New SqlCommand("SELECT 1", conn)) {
            try {
                conn.Open();
                cmd.ExecuteScalar();
                return true;
            } catch (SqlException) {
                return false;
            }
        }
    }
}

此代码用于Mysql。

public class Program
{
string connection = "SERVER=localhost; user id=root; password=; database=dbname";
private void Form1_Load(object sender, System.EventArgs e)
{
checkifconnected();
}
private void checkifconnected()
{
MySqlConnection connect = new MySqlConnection(connection);
try{
connect.Open();
MessageBox.Show("Database connected");
}
catch
{
MessageBox.Show("you are not connected to database");
}
}
public static void Main()
{
}
}
相关文章：