目錄
1?基本使用流程
1.1 步驟1:添加SQLite依賴
1.2 ?步驟2:建立連接
1.3 步驟3:執行SQL命令
1.4 步驟4:查詢數據
1.5 步驟5:使用事務
2 SQLite基本使用示例
2.1 準備工作
2.2 完整示例
2.3 案例代碼解析
2.3.1 連接管理
2.3.2 執行非查詢命令
2.3.3 參數化查詢
2.3.4 使用事務
2.3.5 查詢和結果處理
本節將通過代碼示例展示如何在C#中使用SQLite數據庫。這個示例包含了創建連接、創建表、執行CRUD操作、事務處理和使用參數化查詢等基本功能。在C#應用程序中使用SQLite是一個常見的需求,特別是對于需要輕量級數據存儲的應用,將詳細總結C#中使用SQLite數據庫的基本流程,并解釋案例中的代碼含義和一些重要注意事項。
1?基本使用流程
1.1 步驟1:添加SQLite依賴
在C#項目中使用SQLite,首先需要添加適當的NuGet包:
System.Data.SQLite (完整版)
或
Microsoft.Data.Sqlite (輕量版,.NET Core/.NET 5+推薦)
通過Visual Studio的NuGet包管理器或命令行添加:
Install-Package System.Data.SQLite
或
dotnet add package Microsoft.Data.Sqlite
1.2 ?步驟2:建立連接
// 引入命名空間
using System.Data.SQLite;
?
// 連接字符串
string connectionString = "Data Source=database.db;Version=3;";
?
// 創建連接
using (SQLiteConnection connection = new SQLiteConnection(connectionString))
{connection.Open();// 執行數據庫操作...// 使用using語句確保連接被正確關閉
}
1.3 步驟3:執行SQL命令
// 執行非查詢命令(DDL或DML)
using (SQLiteCommand command = new SQLiteCommand(connection))
{command.CommandText = "CREATE TABLE IF NOT EXISTS Users (Id INTEGER PRIMARY KEY, Name TEXT, Email TEXT)";command.ExecuteNonQuery();
}
?
// 插入數據
using (SQLiteCommand command = new SQLiteCommand(connection))
{command.CommandText = "INSERT INTO Users (Name, Email) VALUES (@Name, @Email)";command.Parameters.AddWithValue("@Name", "張三");command.Parameters.AddWithValue("@Email", "zhangsan@example.com");command.ExecuteNonQuery();
}
1.4 步驟4:查詢數據
// 查詢數據
using (SQLiteCommand command = new SQLiteCommand("SELECT * FROM Users", connection))
{using (SQLiteDataReader reader = command.ExecuteReader()){while (reader.Read()){int id = reader.GetInt32(0);string name = reader.GetString(1);string email = reader.GetString(2);Console.WriteLine($"ID: {id}, Name: {name}, Email: {email}");}}
}
1.5 步驟5:使用事務
using (SQLiteConnection connection = new SQLiteConnection(connectionString))
{connection.Open();using (SQLiteTransaction transaction = connection.BeginTransaction()){try{// 執行多個數據庫操作using (SQLiteCommand command = new SQLiteCommand(connection, transaction)){command.CommandText = "INSERT INTO Users (Name) VALUES (@Name)";command.Parameters.AddWithValue("@Name", "李四");command.ExecuteNonQuery();command.CommandText = "UPDATE Users SET Email = @Email WHERE Name = @Name";command.Parameters.AddWithValue("@Email", "lisi@example.com");command.Parameters.AddWithValue("@Name", "李四");command.ExecuteNonQuery();}// 如果一切正常,提交事務transaction.Commit();}catch (Exception ex){// 發生錯誤,回滾事務transaction.Rollback();Console.WriteLine($"事務回滾: {ex.Message}");}}
}
2 SQLite基本使用示例
2.1 準備工作
首先,你需要安裝SQLite的C#驅動。在Visual Studio中,通過NuGet包管理器安裝System.Data.SQLite
或Microsoft.Data.Sqlite
包。
// 使用NuGet包管理器控制臺安裝
// Install-Package System.Data.SQLite
// 或者
// Install-Package Microsoft.Data.Sqlite
2.2 完整示例
using System;
using System.Data.SQLite; // 使用System.Data.SQLite包
using System.IO;namespace SQLiteDemo
{class Program{// 數據庫連接字符串private static string dbFile = "mydatabase.db";private static string connectionString = $"Data Source={dbFile};Version=3;";static void Main(string[] args){try{// 確保數據庫文件存在,如果不存在則創建CreateDatabaseIfNotExists();// 創建表CreateTables();// 插入數據InsertData();// 查詢數據QueryData();// 更新數據UpdateData();// 使用事務批量插入BatchInsertWithTransaction();// 刪除數據DeleteData();// 參數化查詢示例ParameterizedQueryExample();Console.WriteLine("所有操作已完成!");}catch (Exception ex){Console.WriteLine($"發生錯誤: {ex.Message}");Console.WriteLine(ex.StackTrace);}Console.ReadKey();}// 創建數據庫文件static void CreateDatabaseIfNotExists(){if (!File.Exists(dbFile)){Console.WriteLine("創建新的數據庫文件...");SQLiteConnection.CreateFile(dbFile);Console.WriteLine("數據庫文件已創建。");}else{Console.WriteLine("使用現有數據庫文件。");}}// 創建表static void CreateTables(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();Console.WriteLine("已連接到數據庫。");// 創建用戶表string createUserTableSql = @"CREATE TABLE IF NOT EXISTS Users (Id INTEGER PRIMARY KEY AUTOINCREMENT,Name TEXT NOT NULL,Email TEXT UNIQUE,Age INTEGER,RegisterDate TEXT DEFAULT CURRENT_TIMESTAMP)";// 創建訂單表,演示外鍵關系string createOrderTableSql = @"CREATE TABLE IF NOT EXISTS Orders (OrderId INTEGER PRIMARY KEY AUTOINCREMENT,UserId INTEGER,ProductName TEXT NOT NULL,Quantity INTEGER DEFAULT 1,OrderDate TEXT DEFAULT CURRENT_TIMESTAMP,FOREIGN KEY (UserId) REFERENCES Users(Id))";using (var command = new SQLiteCommand(createUserTableSql, connection)){command.ExecuteNonQuery();Console.WriteLine("Users表已創建。");}using (var command = new SQLiteCommand(createOrderTableSql, connection)){command.ExecuteNonQuery();Console.WriteLine("Orders表已創建。");}}}// 插入數據static void InsertData(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();// 插入用戶數據string insertUserSql = @"INSERT INTO Users (Name, Email, Age) VALUES (@Name, @Email, @Age)";using (var command = new SQLiteCommand(insertUserSql, connection)){// 添加參數command.Parameters.AddWithValue("@Name", "張三");command.Parameters.AddWithValue("@Email", "zhangsan@example.com");command.Parameters.AddWithValue("@Age", 28);int rowsAffected = command.ExecuteNonQuery();Console.WriteLine($"插入了 {rowsAffected} 行用戶數據。");// 獲取自增IDstring getLastIdSql = "SELECT last_insert_rowid()";using (var idCommand = new SQLiteCommand(getLastIdSql, connection)){long userId = (long)idCommand.ExecuteScalar();Console.WriteLine($"新插入用戶的ID是: {userId}");// 為該用戶添加訂單string insertOrderSql = @"INSERT INTO Orders (UserId, ProductName, Quantity)VALUES (@UserId, @ProductName, @Quantity)";using (var orderCommand = new SQLiteCommand(insertOrderSql, connection)){orderCommand.Parameters.AddWithValue("@UserId", userId);orderCommand.Parameters.AddWithValue("@ProductName", "筆記本電腦");orderCommand.Parameters.AddWithValue("@Quantity", 1);rowsAffected = orderCommand.ExecuteNonQuery();Console.WriteLine($"插入了 {rowsAffected} 行訂單數據。");}}}}}// 查詢數據static void QueryData(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();// 簡單查詢string queryUsersSql = "SELECT * FROM Users";using (var command = new SQLiteCommand(queryUsersSql, connection)){Console.WriteLine("\n所有用戶:");using (var reader = command.ExecuteReader()){while (reader.Read()){Console.WriteLine($"ID: {reader["Id"]}, 姓名: {reader["Name"]}, " +$"郵箱: {reader["Email"]}, 年齡: {reader["Age"]}, " +$"注冊日期: {reader["RegisterDate"]}");}}}// 聯表查詢string queryOrdersSql = @"SELECT o.OrderId, u.Name as UserName, o.ProductName, o.Quantity, o.OrderDateFROM Orders oJOIN Users u ON o.UserId = u.IdORDER BY o.OrderDate DESC";using (var command = new SQLiteCommand(queryOrdersSql, connection)){Console.WriteLine("\n所有訂單:");using (var reader = command.ExecuteReader()){while (reader.Read()){Console.WriteLine($"訂單ID: {reader["OrderId"]}, 用戶: {reader["UserName"]}, " +$"商品: {reader["ProductName"]}, 數量: {reader["Quantity"]}, " +$"訂單日期: {reader["OrderDate"]}");}}}// 聚合查詢string aggregateQuerySql = @"SELECT COUNT(*) as UserCount, AVG(Age) as AvgAgeFROM Users";using (var command = new SQLiteCommand(aggregateQuerySql, connection)){using (var reader = command.ExecuteReader()){if (reader.Read()){Console.WriteLine($"\n統計信息: 用戶總數: {reader["UserCount"]}, 平均年齡: {reader["AvgAge"]}");}}}}}// 更新數據static void UpdateData(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();string updateUserSql = @"UPDATE Users SET Age = @NewAge, Name = @NewNameWHERE Email = @Email";using (var command = new SQLiteCommand(updateUserSql, connection)){command.Parameters.AddWithValue("@NewAge", 29);command.Parameters.AddWithValue("@NewName", "張三(已更新)");command.Parameters.AddWithValue("@Email", "zhangsan@example.com");int rowsAffected = command.ExecuteNonQuery();Console.WriteLine($"\n更新了 {rowsAffected} 行用戶數據。");}}}// 使用事務批量插入static void BatchInsertWithTransaction(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();// 開始事務using (var transaction = connection.BeginTransaction()){try{string insertUserSql = @"INSERT INTO Users (Name, Email, Age) VALUES (@Name, @Email, @Age)";// 批量插入10個用戶using (var command = new SQLiteCommand(insertUserSql, connection, transaction)){for (int i = 1; i <= 10; i++){command.Parameters.Clear();command.Parameters.AddWithValue("@Name", $"批量用戶{i}");command.Parameters.AddWithValue("@Email", $"user{i}@example.com");command.Parameters.AddWithValue("@Age", 20 + i);command.ExecuteNonQuery();}}// 提交事務transaction.Commit();Console.WriteLine("\n事務批量插入成功,已添加10位用戶。");}catch (Exception ex){// 出錯時回滾事務transaction.Rollback();Console.WriteLine($"\n事務回滾: {ex.Message}");}}}}// 刪除數據static void DeleteData(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();// 刪除指定用戶string deleteUserSql = "DELETE FROM Users WHERE Name LIKE @NamePattern";using (var command = new SQLiteCommand(deleteUserSql, connection)){command.Parameters.AddWithValue("@NamePattern", "批量用戶%");int rowsAffected = command.ExecuteNonQuery();Console.WriteLine($"\n刪除了 {rowsAffected} 行用戶數據。");}}}// 參數化查詢示例 - 防止SQL注入static void ParameterizedQueryExample(){using (var connection = new SQLiteConnection(connectionString)){connection.Open();// 這是安全的方式,使用參數化查詢string safeQuerySql = "SELECT * FROM Users WHERE Name LIKE @NamePattern";using (var command = new SQLiteCommand(safeQuerySql, connection)){// 即使用戶輸入包含SQL注入嘗試,也會被當作普通字符串處理string userInput = "張三' OR '1'='1";command.Parameters.AddWithValue("@NamePattern", "%" + userInput + "%");Console.WriteLine("\n執行參數化查詢(防止SQL注入):");using (var reader = command.ExecuteReader()){bool hasResults = false;while (reader.Read()){hasResults = true;Console.WriteLine($"ID: {reader["Id"]}, 姓名: {reader["Name"]}");}if (!hasResults){Console.WriteLine("沒有找到匹配的記錄。");}}}// 注意: 這里演示如何使用執行單值查詢string countSql = "SELECT COUNT(*) FROM Users";using (var command = new SQLiteCommand(countSql, connection)){int count = Convert.ToInt32(command.ExecuteScalar());Console.WriteLine($"\n數據庫中共有 {count} 個用戶。");}}}}
}
2.3 案例代碼解析
2.3.1 連接管理
static void SetupExampleData()
{using (var connection = new SQLiteConnection(connectionString)){connection.Open();// 數據庫操作...}
}
解析:
using
語句確保即使發生異常,連接也會被正確釋放和關閉,避免資源泄漏
connection.Open()
建立與SQLite數據庫文件的物理連接連接字符串格式通常為
Data Source=文件路徑;Version=3;
,其中文件路徑可以是相對或絕對路徑
2.3.2 執行非查詢命令
static void ExecuteNonQuery(SQLiteConnection connection, string sql, SQLiteTransaction transaction = null)
{using (var command = new SQLiteCommand(sql, connection, transaction)){command.ExecuteNonQuery();}
}
解析:
這是一個輔助方法,用于執行不返回結果集的SQL命令(如CREATE, INSERT, UPDATE, DELETE)
參數化設計允許重用并支持事務
ExecuteNonQuery()
返回受影響的行數(對于DDL語句如CREATE TABLE通常返回0)同樣使用
using
語句確保命令資源被正確釋放
2.3.3 參數化查詢
ExecuteNonQuery(connection, @"INSERT INTO Employees (Name, DeptId, Salary, HireDate) VALUES('張三', 1, 15000, '2020-01-15')");
更安全的參數化版本:
using (var command = new SQLiteCommand(connection))
{command.CommandText = "INSERT INTO Employees (Name, DeptId, Salary, HireDate) VALUES (@Name, @DeptId, @Salary, @HireDate)";command.Parameters.AddWithValue("@Name", "張三");command.Parameters.AddWithValue("@DeptId", 1);command.Parameters.AddWithValue("@Salary", 15000);command.Parameters.AddWithValue("@HireDate", "2020-01-15");command.ExecuteNonQuery();
}
解析:
參數化查詢防止SQL注入攻擊
使用
@
前綴的參數名稱是約定
AddWithValue
方法會自動根據傳入參數的類型設置SQLite參數類型
2.3.4 使用事務
using (var transaction = connection.BeginTransaction())
{try{// 執行多個操作ExecuteNonQuery(connection, "INSERT INTO Departments (DeptId, Name) VALUES (4, '人力資源部')", transaction);ExecuteNonQuery(connection, "UPDATE Employees SET Salary = Salary * 1.1 WHERE DeptId = 1", transaction);// 假設這里有條件判斷是否提交bool shouldCommit = true;if (shouldCommit){transaction.Commit();Console.WriteLine("事務已提交。");}else{transaction.Rollback();Console.WriteLine("事務已回滾。");}}catch (Exception ex){transaction.Rollback();Console.WriteLine($"發生錯誤,事務已回滾: {ex.Message}");}
}
解析:
BeginTransaction()
開始一個新事務事務內的所有操作要么全部成功,要么全部失敗
Commit()
提交所有更改并結束事務
Rollback()
撤銷所有更改并結束事務
try-catch
塊確保在發生異常時事務被正確回滾
2.3.5 查詢和結果處理
static void DisplayQueryResults(SQLiteConnection connection, string sql)
{using (var command = new SQLiteCommand(sql, connection)){using (var reader = command.ExecuteReader()){// 獲取列名List<string> columns = new List<string>();for (int i = 0; i < reader.FieldCount; i++){columns.Add(reader.GetName(i));}// 輸出列名Console.WriteLine(string.Join(" | ", columns));Console.WriteLine(new string('-', columns.Count * 15));// 輸出行while (reader.Read()){List<string> values = new List<string>();for (int i = 0; i < reader.FieldCount; i++){values.Add(reader[i]?.ToString() ?? "NULL");}Console.WriteLine(string.Join(" | ", values));}}}
}
解析:
ExecuteReader()
返回一個SQLiteDataReader
對象,用于逐行讀取結果集
reader.FieldCount
獲取結果集的列數
reader.GetName(i)
獲取特定列的名稱
reader.Read()
將讀取指針移到下一行,如果有下一行則返回true
reader[i]
獲取當前行中索引為i的列的值
?? "NULL"
處理可能的NULL值嵌套的
using
語句確保讀取器和命令都被正確關閉
3 數據類型映射
C#類型和SQLite類型之間的映射:
C#類型 | SQLite類型 |
---|---|
int, long | INTEGER |
double, float | REAL |
string | TEXT |
byte[] | BLOB |
DateTime | TEXT/INTEGER |
bool | INTEGER |
在讀取時需要注意類型轉換,SQLite的動態類型系統可能需要額外的類型轉換處理。
4 使用注意事項
-
連接管理:
-
?總是使用
using
語句確保連接正確關閉 -
避免長時間保持連接打開
-
對于多線程應用,考慮使用連接池?
-
-
參數化查詢:
-
始終使用參數化查詢防止SQL注入
-
不要通過字符串拼接構建SQL語句
-
-
事務使用:
-
批量操作使用事務提高性能
-
保持事務盡可能短小
-
正確處理事務的異常情況
-
-
性能考慮:
-
為頻繁查詢的列創建索引
-
使用
EXPLAIN QUERY PLAN
分析查詢性能 -
大量數據操作時考慮批處理
-
-
版本兼容性:
-
確認目標SQLite版本是否支持需要的功能
-
窗口函數需要SQLite 3.25+
-
FTS5需要特殊編譯支持
-
以上就是關于如何在C#中使用SQLite數據庫的基本流程,下一節我們將通過其他的C#示例代碼來講解SQLite高級功能的實現!!!