要使用SQLite进行数据库操作,需要先将SQLite驱动程序安装到项目中。可以使用NuGet包来安装,也可以手动下载安装dll文件并添加引用。
安装完驱动程序后,可以使用以下代码来连接数据库:
using System.Data.SQLite;
string connectionString = "Data Source=mydatabase.sqlite;Version=3;";
SQLiteConnection connection = new SQLiteConnection(connectionString);
connection.Open();
其中,mydatabase.sqlite是数据库文件名,可以根据实际情况更改。
接着,可以使用SQL语句来创建表、插入数据、查询数据等操作。例如,以下代码可以创建一个名为users的表:
string sql = "CREATE TABLE users (id INTEGER PRIMARY KEY AUTOINCREMENT, name VARCHAR(50), age INTEGER)";
SQLiteCommand command = new SQLiteCommand(sql, connection);
command.ExecuteNonQuery();
插入数据的代码如下:
string sql = "INSERT INTO users (name, age) VALUES ('Tom', 20)";
SQLiteCommand command = new SQLiteCommand(sql, connection);
command.ExecuteNonQuery();
查询数据的代码如下:
string sql = "SELECT * FROM users";
SQLiteCommand command = new SQLiteCommand(sql, connection);
SQLiteDataReader reader = command.ExecuteReader();
while (reader.Read())
{
Console.WriteLine(reader["name"] + " " + reader["age"]);
}
最后,在使用事务时,可以使用以下代码来保证数据的完整性:
SQLiteTransaction transaction = connection.BeginTransaction();
try
{
// 执行数据库操作
transaction.Commit();
}
catch
{
transaction.Rollback();
}
上述代码将所有数据库操作包裹在事务中执行,如果出现错误,则回滚事务,保证数据的一致性。