【C#】SQLiteで今すぐデータベースを使う方法とサンプルを紹介

//参照先を追加
using System.Data.Linq;
using System.Data.SQLite;

private void ExecuteNonQuery(string query)
{
    try
    {
        // 接続先を指定
        using (var conn = new SQLiteConnection("Data Source=DataBase.sqlite"))
        using (var command = conn.CreateCommand())
        {
            // 接続
            conn.Open();

            // コマンドの実行処理
            command.CommandText = query;
            command.ExecuteNonQuery();
            //var value = command.ExecuteNonQuery();
            //MessageBox.Show($"更新されたレコード数は {value} です。");
        }
    }
    catch (Exception ex)
    {
        //例外が発生した時はメッセージボックスを表示
        MessageBox.Show(ex.Message);
    }
}

private void CreateTable()
{
    // テーブル名が存在しなければ作成する
    StringBuilder query = new StringBuilder();
    query.Clear();
    query.Append("CREATE TABLE IF NOT EXISTS PURCHASELIST (");
    query.Append(" NO INTEGER NOT NULL");
    query.Append(" ,DATETIME TEXT NOT NULL");
    query.Append(" ,NAME TEXT NOT NULL");
    query.Append(" ,PRICE INTEGER NOT NULL");
    query.Append(" ,primary key (NO)");
    query.Append(")");

    // クエリー実行
    ExecuteNonQuery(query.ToString());
}

private void InsertRecord(int no, string datetime, string name, int price)
{
    // レコードの登録
    var query = "INSERT INTO PURCHASELIST (NO,DATETIME,NAME,PRICE) VALUES (" +
        $"{no},'{datetime}','{name}',{price})";

    // クエリー実行
    ExecuteNonQuery(query.ToString());
}

InsertRecord(1, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "coffee", 100);
InsertRecord(2, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "meet", 350);
InsertRecord(3, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "snacks", 200);
InsertRecord(4, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), "juice", 150);

private List<string> SerachRecordData(string column, string word)
{
    // 検索条件
    var query = "SELECT * FROM PURCHASELIST WHERE " +
        $"{column} = '{word}' ORDER BY NO ASC";

    var result = new List<string>();
    // 接続先を指定
    using (var conn = new SQLiteConnection("Data Source=DataBase.sqlite"))
    using (var command = conn.CreateCommand())
    {
        // 接続
        conn.Open();

        // コマンドの実行処理
        command.CommandText = query;
        using (SQLiteDataReader reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                var array = new string[]
                {
                    reader.GetValue(0).ToString(),
                    reader.GetValue(1).ToString(),
                    reader.GetValue(2).ToString(),
                    reader.GetValue(3).ToString()
                };
                result.AddRange(array);
            }
        }
    }

    return result;
}

var result = SerachRecordData("NAME", "coffee");

private void UpdateRecord(int no, string datetime, string name, int price)
{
    // レコードの登録
    var query = $"UPDATE PURCHASELIST SET DATETIME = '{datetime}', NAME = '{name}',PRICE = '{price}' " +
        $"WHERE NO = {no};";

    // クエリー実行
    ExecuteNonQuery(query.ToString());
}

UpdateRecord(1, DateTime.Now.ToString(), "tea", 100);

private void DeleteRecord(string column, string word)
{
    // レコードの削除
    var query = "DELETE FROM PURCHASELIST WHERE " +
        $"{column} = '{word}'";

    // クエリー実行
    ExecuteNonQuery(query.ToString());
}

DeleteRecord("NAME", "coffee");

private void DropTable()
{
    // テーブルの削除
    var query = "DROP TABLE PURCHASELIST";

    // クエリー実行
    ExecuteNonQuery(query.ToString());
}

private string VersionCheck()
{
    var result = "";

    // データベースの接続先を指定
    using (var conn = new SQLiteConnection("Data Source=DataBase.sqlite"))
    {
        // データベースに接続
        conn.Open();

        // コマンドの実行処理
        using (var command = conn.CreateCommand())
        {
            //バージョン確認のコマンド実行
            command.CommandText = "select sqlite_version()";
            result = command.ExecuteScalar().ToString();
        }
    }

    return result;
}