使用已经打开的数据库连接

Question

这有点奇怪，但我想检查与数据库的连接是否已经打开？我该如何检查？如果打开，我希望能够立即使用它，而无需查看所有声明：

sqlconnection conn = new sqlconnection("string ...");

可以这样做吗？我也知道连接字符串和连接名称。我想先检查此连接是否可用，然后继续。

Answer 1

如果您知道连接字符串，那么获取新的可用sql连接的最简单方法是创建SqlConnection类的新实例：

using (SqlConnection conn = new SqlConnection("MyConnectionString"))
{
    conn.Open();
    // Use the connection
}

.Net框架使用连接池，因此无需担心打开效率和连接问题。多个连接 - 上面的代码将重新使用可用的现有连接，或根据需要创建一个新连接。

如果您想节省一些打字时间，那么您可能会发现为自己创建一个小辅助方法或属性很有用：

class SqlHelper
{
    public static SqlConnection GetConn()
    {
        SqlConnection returnValue = new SqlConnection("MyConnectionString");
        returnValue.Open();
        return returnValue;
    }
}

用法：

using (SqlConnection conn = SqlHelper.GetConn())
{
    // Use the connection
}

Answer 2

您看过 SqlConnection 的文档吗？

http://msdn.microsoft.com/en-us /library/system.data.sqlclient.sqlconnection.aspx

我相信“State”属性会告诉您您想要什么。

如果您更一般地询问如何使用连接池中的现有连接，那么当您使用与活动连接相同的连接字符串创建新的 SqlConnection 时，这将自动完成。

如果您只是想避免编写冗余代码，请将其放入类中并重用它。

Answer 3

尽管您可能只使用 SQL Server，但熟悉 System.Data 中的所有核心接口可能是一个好习惯，因为所有数据提供程序都实现了它们。我相信 IDbConnection 上的 State 属性返回您所要求的信息（IDbConnection)

另外，您可能想以某种集中方法隐藏该逻辑：

public static IDbConnection RetrieveConnection(){
    if(DataAccess.Connection.State == ConnectionState.Open) return DataAccess.Connection;

    conn.Dispose(); //to be clean, I believe this is safe if it's already disposed
    //retrieve configured connection string
    //create and open connection
    return DataAccess.Connection;
}

所以也许 DataAccess 是您可以的地方放置和检索您的连接对象，但我会避免让每个人直接使用它。相反，让他们执行此方法可以确保连接可用。我只是想给你一些想法。

另外，您可能想更进一步，使用 NHibernate 之类的东西来为您管理连接和所有这些东西。尽管如果项目很小，这并不总是值得付出努力。

编辑：使代码更明确一点

Answer 4

Façade 设计模式应该可以帮助您。这是一个例子。

1. 外观模式（维基百科）；
2. 外观设计模式（四人组）。

“智能”外观知道什么方法需要连接到哪里，等等。外观打开连接并将其传递给底层代码段，通常包含在工厂类或类似的东西中。

public class DoSomethingFacade {
    private static readonly DoSomethingFactory _doSomethingFactory = new DoSomethingFactory();

    public static IList<T> GetList<T>() {
        using(IDbConnection connection = OpenConnection("string..."))
            return _doSomethingFactory.GetList<T>(connection);
    }

    public static IDbConnection OpenConnection(string connectionString) {
        IDbConnection openedConnection = new SqlConnection(connectionString);
        openedConnection.Open();
        return openedConnection;
    }
}

internal class DoSomethingFactory {
    internal DoSomethingFactory() { }

    internal IList<T> GetList<T>(IDbConnection connection) {
        IList<T> results = new List<T>();

        // use connection here without caring about it, 
        // as it should be provided as an opened available connection.

        return results;
    }
}