主页 / 问题 / 910905
Accepted
J. Doe
Asked:2020-11-24 20:23:02 +0000 UTC2020-11-24 20:23:02 +0000 UTC

如何检查与数据库的连接是否成功？

  • 772

有必要通过连接字符串连接到某个服务器。为此，我使用以下代码。

using MongoDB.Driver;

// ...

static MongoClient client;

public static bool Connect(string connectionString)
{
    client = new MongoClient(connectionString);
    return client != null;
}

问题是：通过将变量client与进行比较来检查连接成功是否正确null？连接时是否需要考虑其他细微差别？

c#

2 个回答

  1. Best Answer

    如此处所述，您需要：

    public static Task<bool> CheckConnectionAsync(string connectionString, string dbName)
{
    var client = new MongoClient(connectionString);
    var database = client.GetDatabase(dbName);

    return database.RunCommandAsync((Command<BsonDocument>)"{ping:1}");
}
    • 2

  2. 方法的同步版本：

        private static Boolean MongoDbConnection(String connectionString, String dbName)
    {
        var client = new MongoClient(connectionString);

        for (int k = 0; k < 6; k++)
        {
            client.GetDatabase(dbName);
            var server = client.Cluster
                               .Description
                               .Servers
                               .FirstOrDefault();
            if (server != null &&
               server.HeartbeatException == null &&
               server.State == ServerState.Connected)
            {
                break;
            }
            Thread.Sleep(300);
        }
        return false;
    }

    该方法的异步版本：

        private static async Task<Boolean> MongoDbConnectionAsync(String connectionString, String dbName)
    {
        return await Task.Run(() =>
        {
            var client = new MongoClient(connectionString);

            for (int k = 0; k < 6; k++)
            {
                client.GetDatabase(dbName);
                var server = client.Cluster
                                   .Description
                                   .Servers
                                   .FirstOrDefault();
                if (server != null &&
                   server.HeartbeatException == null &&
                   server.State == ServerState.Connected)
                {
                    break;
                }
                Thread.Sleep(300);
            }
            return false;
        });
    }
    • -1

相关问题