SQLite SELECT 数据操作指南：使用 C#

本文将详细介绍如何使用 C# 在 SQLite 数据库中执行 SELECT 操作。SELECT 操作是数据库查询中最常用和最重要的操作，用于从数据库中检索数据。

准备工作

首先，确保你的项目中已安装 System.Data.SQLite NuGet 包。在你的 C# 文件顶部添加以下 using 语句：

C#
using System;
using System.Data;
using System.Data.SQLite;

连接到数据库

在执行任何查询之前，我们需要建立与数据库的连接。以下是一个建立连接的辅助方法：

C#
public static SQLiteConnection ConnectToDatabase(string dbPath)
{
    try
    {
        SQLiteConnection connection = new SQLiteConnection($"Data Source={dbPath};Version=3;");
        connection.Open();
        return connection;
    }
    catch (Exception ex)
    {
        Console.WriteLine($"连接数据库时出错：{ex.Message}");
        return null;
    }
}

基本的 SELECT 操作

查询所有记录

以下是一个查询表中所有记录的方法：

C#
public static void SelectAllRecords(SQLiteConnection connection, string tableName)
{
    try
    {
        string sql = $"SELECT * FROM {tableName}";
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            using (SQLiteDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        Console.Write($"{reader.GetName(i)}: {reader[i]}, ");
                    }
                    Console.WriteLine();
                }
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"查询所有记录时出错：{ex.Message}");
    }
}

使用示例：

SQL
SelectAllRecords(connection, "Users");

使用条件查询

以下是一个带条件的查询方法：

C#
public static void SelectRecordsWithCondition(SQLiteConnection connection, string tableName, string condition)
{
    try
    {
        string sql = $"SELECT * FROM {tableName} WHERE {condition}";
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            using (SQLiteDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        Console.Write($"{reader.GetName(i)}: {reader[i]}, ");
                    }
                    Console.WriteLine();
                }
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"条件查询记录时出错：{ex.Message}");
    }
}

使用示例：

JavaScript
SelectRecordsWithCondition(connection, "Users", "Age > 30");

使用参数化查询

为了防止 SQL 注入攻击并提高性能，我们应该使用参数化查询：

C#
public static void SelectRecordsWithParameters(SQLiteConnection connection, string tableName, string condition, Dictionary<string, object> parameters)
{
    try
    {
        string sql = $"SELECT * FROM {tableName} WHERE {condition}";
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            foreach (var param in parameters)
            {
                command.Parameters.AddWithValue(param.Key, param.Value);
            }

            using (SQLiteDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        Console.Write($"{reader.GetName(i)}: {reader[i]}, ");
                    }
                    Console.WriteLine();
                }
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"参数化查询记录时出错：{ex.Message}");
    }
}

使用示例：

C#
var parameters = new Dictionary<string, object>
{
    { "@minAge", 25 },
    { "@maxAge", 40 }
};
SelectRecordsWithParameters(connection, "Users", "Age BETWEEN @minAge AND @maxAge", parameters);

高级 SELECT 操作

使用聚合函数

SQLite 支持多种聚合函数，如 COUNT, AVG, SUM 等。以下是一个使用聚合函数的示例：

C#
public static void SelectWithAggregation(SQLiteConnection connection, string tableName, string aggregation)
{
    try
    {
        string sql = $"SELECT {aggregation} FROM {tableName}";
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            object result = command.ExecuteScalar();
            Console.WriteLine($"聚合结果：{result}");
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"执行聚合查询时出错：{ex.Message}");
    }
}

使用示例：

SQL
SelectWithAggregation(connection, "Users", "AVG(Age)");

使用 ORDER BY 和 LIMIT

以下是一个带排序和限制结果数量的查询方法：

C#
public static void SelectWithOrderAndLimit(SQLiteConnection connection, string tableName, string orderBy, int limit)
{
    try
    {
        string sql = $"SELECT * FROM {tableName} ORDER BY {orderBy} LIMIT {limit}";
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            using (SQLiteDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        Console.Write($"{reader.GetName(i)}: {reader[i]}, ");
                    }
                    Console.WriteLine();
                }
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"执行排序和限制查询时出错：{ex.Message}");
    }
}

使用示例：

SQL
SelectWithOrderAndLimit(connection, "Users", "Age DESC", 5);

使用 JOIN

以下是一个使用 JOIN 的示例方法：

C#
public static void SelectWithJoin(SQLiteConnection connection, string table1, string table2, string joinCondition)
{
    try
    {
        string sql = $"SELECT * FROM {table1} INNER JOIN {table2} ON {joinCondition}";
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            using (SQLiteDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    for (int i = 0; i < reader.FieldCount; i++)
                    {
                        Console.Write($"{reader.GetName(i)}: {reader[i]}, ");
                    }
                    Console.WriteLine();
                }
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine($"执行 JOIN 查询时出错：{ex.Message}");
    }
}

使用示例：

SQL
SelectWithJoin(connection, "Users", "Orders", "Users.Id = Orders.UserId");

使用 DataTable 存储结果

对于需要在内存中处理查询结果的情况，我们可以使用 DataTable：

C#
public static DataTable SelectToDataTable(SQLiteConnection connection, string sql)
{
    try
    {
        DataTable dt = new DataTable();
        using (SQLiteCommand command = new SQLiteCommand(sql, connection))
        {
            using (SQLiteDataAdapter adapter = new SQLiteDataAdapter(command))
            {
                adapter.Fill(dt);
            }
        }
        return dt;
    }
    catch (Exception ex)
    {
        Console.WriteLine($"查询到 DataTable 时出错：{ex.Message}");
        return null;
    }
}

使用示例：

C#
DataTable dt = SelectToDataTable(connection, "SELECT * FROM Users WHERE Age > 30");
foreach (DataRow row in dt.Rows)
{
    foreach (DataColumn col in dt.Columns)
    {
        Console.Write($"{col.ColumnName}: {row[col]}, ");
    }
    Console.WriteLine();
}

完整示例

以下是一个完整的示例，展示了如何使用上述所有方法：

C#
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SQLite;

class Program
{
    static void Main(string[] args)
    {
        string dbPath = "C:\\example.db";
        SQLiteConnection connection = ConnectToDatabase(dbPath);

        if (connection != null)
        {
            // 查询所有记录
            Console.WriteLine("所有用户：");
            SelectAllRecords(connection, "Users");

            // 条件查询
            Console.WriteLine("\n30岁以上的用户：");
            SelectRecordsWithCondition(connection, "Users", "Age > 30");

            // 参数化查询
            Console.WriteLine("\n25到40岁的用户：");
            var parameters = new Dictionary<string, object>
            {
                { "@minAge", 25 },
                { "@maxAge", 40 }
            };
            SelectRecordsWithParameters(connection, "Users", "Age BETWEEN @minAge AND @maxAge", parameters);

            // 聚合查询
            Console.WriteLine("\n用户平均年龄：");
            SelectWithAggregation(connection, "Users", "AVG(Age)");

            // 排序和限制结果
            Console.WriteLine("\n年龄最大的5个用户：");
            SelectWithOrderAndLimit(connection, "Users", "Age DESC", 5);

            // JOIN 查询
            Console.WriteLine("\n用户及其订单：");
            SelectWithJoin(connection, "Users", "Orders", "Users.Id = Orders.UserId");

            // 查询到 DataTable
            Console.WriteLine("\n30岁以上的用户（使用 DataTable）：");
            DataTable dt = SelectToDataTable(connection, "SELECT * FROM Users WHERE Age > 30");
            foreach (DataRow row in dt.Rows)
            {
                foreach (DataColumn col in dt.Columns)
                {
                    Console.Write($"{col.ColumnName}: {row[col]}, ");
                }
                Console.WriteLine();
            }

            // 关闭连接
            connection.Close();
        }
    }

    // 在这里实现所有上述方法
}

注意事项

始终使用参数化查询来防止 SQL 注入攻击。
对于大型结果集，考虑使用分页查询或流式处理来避免内存问题。
正确处理 NULL 值，特别是在使用聚合函数时。
在完成操作后，记得关闭数据库连接。
对于频繁执行的查询，可以考虑使用预处理语句（prepared statements）来提高性能。

结论

本文详细介绍了如何使用 C# 在 SQLite 数据库中执行各种 SELECT 操作，包括基本查询、条件查询、参数化查询、聚合查询、排序和限制结果、JOIN 操作以及使用 DataTable 存储结果。这些操作覆盖了大多数常见的数据检索场景。

目录

准备工作

连接到数据库

基本的 SELECT 操作

查询所有记录

使用条件查询

使用参数化查询

高级 SELECT 操作

使用聚合函数

使用 ORDER BY 和 LIMIT

使用 JOIN

使用 DataTable 存储结果

完整示例

注意事项

结论