.NET C# で SQLite を使ってみる

.NET C#プロジェクトで大量のデータ扱う時に、気軽にSQLでデータを操作したいときに、**SQLite** は、選択肢として適してるかと思い、基本的な操作について調べてみたので、以下まとめてみます。

1. SQLite を採用するメリット

SQLite はサーバーレスで動作するリレーショナルデータベースで、以下の特性を持ちます。

・運用の簡略化
　DBサーバーの構築が不要。データベース全体が単一のファイル（`.db`）として完結。
・ポータビリティ
　実行バイナリとDBファイルを配布するだけで動作し、環境依存が極めて少ない。
・扱いやすさ
　 標準的なSQLをサポートしており、将来的に他のRDBMS（MySQL, PostgreSQL等）へ移行する際の敷居も低い。

2. 開発環境のセットアップ

.NET環境では、公式ライブラリである `Microsoft.Data.Sqlite` が利用できます。

3. 基本実装：接続とスキーマ定義

データベースへの接続には `SqliteConnection` を使用します。

using Microsoft.Data.Sqlite;

// 接続文字列の定義
var connectionString = "Data Source=sample.db";

using (var connection = new SqliteConnection(connectionString))
{
    connection.Open();

    // テーブル定義の実行
    var createTableSql = @"
        CREATE TABLE IF NOT EXISTS Users (
            Id INTEGER PRIMARY KEY AUTOINCREMENT,
            Name TEXT NOT NULL,
            Age INTEGER
        )";

    using var command = new SqliteCommand(createTableSql, connection);
    command.ExecuteNonQuery();
}

var insertSql = "INSERT INTO Users (Name, Age) VALUES ($name, $age)";
using var command = new SqliteCommand(insertSql, connection);

// パラメータによる安全な値のセット
command.Parameters.AddWithValue("$name", "田中太郎");
command.Parameters.AddWithValue("$age", 25);

command.ExecuteNonQuery();

var selectSql = "SELECT Id, Name, Age FROM Users WHERE Age >= $age";
using var command = new SqliteCommand(selectSql, connection);
command.Parameters.AddWithValue("$age", 20);

using (var reader = command.ExecuteReader())
{
    while (reader.Read())
    {
        // 序数（インデックス）指定による型安全なデータ取得
        var id = reader.GetInt32(0);
        var name = reader.GetString(1);
        var age = reader.GetInt32(2);

        Debug.WriteLine($"ID: {id}, Name: {name}, Age: {age}");
    }
}

// トランザクションの明示的な開始
using var transaction = connection.BeginTransaction();

try 
{
    var command = connection.CreateCommand();
    command.Transaction = transaction;
    command.CommandText = "INSERT INTO Users (Name, Age) VALUES ($name, $age)";

    for (int i = 0; i < 10000; i++) 
    {
        command.Parameters.Clear();
        command.Parameters.AddWithValue("$name", $"User_{i}");
        command.Parameters.AddWithValue("$age", 20);
        command.ExecuteNonQuery();
    }

    // 全ての処理が成功した場合に確定
    transaction.Commit();
} 
catch (Exception) 
{
    // エラー発生時はロールバックを行い、データのアトミック性を担保
    transaction.Rollback();
    throw;
}