在System.Data.SQLite中拆分数据库连接与查询执行方法的最佳实践

首先明确原代码的核心问题：ConnectToDb方法中用using块包裹连接对象，using块执行完毕后连接会被自动释放（调用Dispose），此时返回的连接已经处于无效状态，无法在后续的查询方法中正常使用。

下面是两种可靠的实现方案：

方案一：由调用方管理连接生命周期 #

让连接创建方法仅负责初始化并打开连接，将连接的释放交由调用方通过using块管理，确保连接在查询完成后被正确回收。

using System.Data.SQLite;
using System.Data;

// 创建并打开数据库连接，返回已激活的连接对象
internal SQLiteConnection ConnectToDb()
{
    // 修正连接字符串格式：SQLite需要指定Data Source
    var connectionString = @"Data Source=DB\SWDB.db;";
    var dbConnection = new SQLiteConnection(connectionString);
    dbConnection.Open();
    return dbConnection;
}

// 接收已打开的连接，执行查询逻辑
internal void ExecuteQuery(string query, SQLiteConnection dbConnection)
{
    using (SQLiteCommand cmd = new SQLiteCommand(query, dbConnection))
    {
        cmd.CommandType = CommandType.Text;
        // SQLiteDataReader同样需要用using包裹，确保资源释放
        using (SQLiteDataReader reader = cmd.ExecuteReader())
        {
            // 处理查询结果的业务逻辑
            while (reader.Read())
            {
                // 示例：读取第一列数据
                var data = reader[0];
                // 后续处理...
            }
        }
    }
}

// 调用示例：由调用方用using管理连接的完整生命周期
internal void UseDatabase()
{
    using (var connection = ConnectToDb())
    {
        ExecuteQuery("SELECT * FROM YourTableName", connection);
    } // 连接在此处自动释放
}

方案二：用委托封装查询逻辑（推荐） #

将连接的创建、打开、释放逻辑封装在一个方法内，通过委托传入具体的查询操作，确保连接的生命周期完全可控，避免调用方遗漏资源释放。

using System.Data.SQLite;
using System.Data;
using System;

// 封装连接管理，接收查询逻辑委托
internal void ExecuteWithConnection(Action<SQLiteConnection> queryAction)
{
    var connectionString = @"Data Source=DB\SWDB.db;";
    using (SQLiteConnection dbConnection = new SQLiteConnection(connectionString))
    {
        dbConnection.Open();
        // 执行传入的查询逻辑
        queryAction(dbConnection);
    } // 连接在此处自动释放，无需手动关闭
}

// 具体的查询业务逻辑
internal void FetchTableData()
{
    ExecuteWithConnection(connection =>
    {
        string query = "SELECT * FROM YourTableName";
        using (SQLiteCommand cmd = new SQLiteCommand(query, connection))
        {
            cmd.CommandType = CommandType.Text;
            using (SQLiteDataReader reader = cmd.ExecuteReader())
            {
                while (reader.Read())
                {
                    // 处理数据逻辑
                }
            }
        }
    });
}

关键注意事项 #

• 连接字符串格式：原代码中的连接字符串格式错误，SQLite的连接字符串必须以Data Source=开头指定数据库文件路径。
• 可释放对象管理：SQLiteCommand和SQLiteDataReader都属于可释放资源，必须用using块包裹，确保资源及时回收。
• 方案二优势：完全封装连接的生命周期，减少调用方出错的可能，是更安全、更易维护的实现方式。

内容的提问来源于stack exchange，提问作者aleXela