即使没有互联网，npgsqlconnection.open也打开远程连接

Question

这是我在这里的第一个问题。

因此，我使用了使用NPGSQL库连接到远程数据库的应用程序。 我有一种连接到数据库的方法，执行查询，最后关闭连接。它可以正常工作，但问题是，如果程序正在运行但未调用该方法时，我会断开WiFi以模拟无法连接到服务器的连接，然后运行该方法，连接方法仍然可以打开连接。这会导致查询被卡住。我似乎找不到一种方法来检查是否可以连接到服务器，因为即使我断开了Internet，npgsqlconnection.open（）方法仍然可以打开它。

对不起我的英语

 public static NpgsqlConnection ConnectRemote()
    {
        try
        {
            remoteConnection = new NpgsqlConnection("Server = " + remoteData.server + "; " +
                                              "Port = " + remoteData.port + "; " +
                                              "User Id = " + remoteData.user + "; " +
                                              "Password = " + remoteData.password + "; " +
                                              "Database = " + remoteData.dataBase + "; ");
            remoteConnection.Open();
        }
        catch (NpgsqlException ex)
        {
            throw;
        }
        catch (Exception ex)
        {
            remoteConnection.Close();
            remoteConnection = null;
        }
        return remoteConnection;
    }
public static bool CheckRemote()
    {
            if (remoteConnection != null)
            {
                if (remoteConnection.FullState.Equals(ConnectionState.Open))
                    return true;
                return false;
            }
            return false;
    }
public bool AddNewProduct(Product product)
    {
        try
        {
            DBManager.ConnectLocal();
            DBManager.ConnectRemote();
            object[] parameters;
            if (DBManager.CheckRemote())
            {
                if (!DBManager.isSyncronized)
                {
                    DBManager.Syncronize();
                }
                parameters = new object[8];
                parameters[0] = 1;
                parameters[1] = product.id;
                parameters[2] = product.description;
                parameters[3] = (decimal)product.salePrice;
                parameters[4] = (decimal)product.cost;
                parameters[5] = product.minStock;
                parameters[6] = product.providerName;
                parameters[7] = product.category;
                DBManager.RunFunction(DBManager.remoteConnection, DBProcedures.createProduct, parameters);
            }
            else
            {
                string sql = "select * from createproduct(1, " + product.id + ", '" + product.description + "', " + (decimal)product.salePrice + ", " 
                    + (decimal)product.cost + ", " + product.minStock + ", '" + product.providerName + "', '" + product.category + "'); ";
                parameters = new object[1];
                parameters[0] = sql;
                DBManager.RunFunction(DBManager.localConnection, "addsync", parameters);
                DBManager.isSyncronized = false;
            }
            parameters = new object[6];
            parameters[0] = product.description;
            parameters[1] = (decimal)product.salePrice;
            parameters[2] = (decimal)product.cost;
            parameters[3] = product.minStock;
            parameters[4] = product.providerName;
            parameters[5] = product.category;
            DataTable result = DBManager.RunFunction(DBManager.localConnection, DBProcedures.createProduct, parameters);
            DBManager.DisconnectLocal();
            DBManager.DisconnectRemote();
            return true;
        }
        catch (Npgsql.NpgsqlException ex)
        {
            return false;
        }           
    }

Answer 1

几件事 - 一件事无关，有两个相关。我希望这些组合的某些组合会有所帮助。

1. 首先，无关的评论。NpgSqlStringBuilder类是帮助神秘化连接字符串的好工具。我意识到您的工作，但是您必须进行编辑（我将在一分钟内提出），我发现它比浏览String.Format要容易得多，就像查询参数更容易（除了更安全）要比试图尝试更容易string.Format通过将参数传递给查询。另外，在您的连接字符串中声明ApplicationName，以帮助诊断服务器上发生的事情，就像您将在下一个评论中阅读一样。

2. 如果您使用的是连接池，当连接关闭时，我认为它真的没有关闭，甚至在数据库上也没有。如果您打开服务器管理员，您将看到我的意思 - 在那里悬挂，等待重复使用。尝试在连接字符串中设置pooled=false，以确保您关闭连接时真正将其关闭。

3. 如果这不起作用，请尝试一个琐碎的查询。在您不需要的情况下，成本将很小

这三个建议在这里反映：

public static NpgsqlConnection ConnectRemote()
{
    NpgsqlConnectionStringBuilder sb = new NpgsqlConnectionStringBuilder();
    sb.ApplicationName = "Connection Tester";
    sb.Host = remoteData.server;
    sb.Port = remoteData.port;
    sb.Username = remoteData.user;
    sb.Password = remoteData.password;
    sb.Database = remoteData.database;
    sb.Pooling = false;
    remoteConnection = new NpgsqlConnection(sb.ToString());
    try
    {
        remoteConnection.Open();
        NpgSqlCommand test = new NpgSqlCommand("select 1", remoteConnection);
        test.ExecuteScalar();
    }
    catch (NpgsqlException ex)
    {
       throw;
    }
    catch (Exception ex)
    {
       remoteConnection.Close();
       remoteConnection = null;
    }
    return remoteConnection;
}