using System.Data.Common;csharp

/// <summary>
/// ADO.NET 関連のオブジェクトを作成するためのファクトリインタフェースです。
/// </summary>
public interface DbFactory {
    DbConnection CreateDbConnection();
    DbParameter CreateDbParameter();
}

using System.Data.Common;
using System.Data.SQLite;

/// <summary>
/// System.Data.SQLite を使用して DbFactory インタフェースを実装します。
/// SQLite に依存する部分はこのクラスにまとめられます。
/// </summary>
public class SQLiteDbFactory : DbFactory {
    private const string DATABASE_FILENAME = "sample.db";

    public DbConnection CreateDbConnection() {
        string conStr = string.Format("Data Source={0}", DATABASE_FILENAME);
        return new SQLiteConnection(conStr);
    }

    public DbParameter CreateDbParameter() {
        return new SQLiteParameter();
    }
}

using System;
using System.Data.Common;

public class MainClass {
    private static DbFactory m_dbFactory = new SQLiteDbFactory();

    // test_tbl テーブルを作成する
    public void CreateTable(DbConnection con) {
        using (DbCommand cmd = con.CreateCommand()) {
            cmd.CommandText =
                "CREATE TABLE IF NOT EXISTS test_tbl(id INTEGER PRIMARY KEY, title TEXT)";
            cmd.ExecuteNonQuery();
        }
    }

    // test_tbl テーブルにサンプルデータを追加
    public void AddRecord(DbConnection con) {
        using (DbTransaction tran = con.BeginTransaction()) {
            using (DbCommand cmd = con.CreateCommand()) {
                // DbParameter を使って効率的に SQL クエリを生成
                DbParameter param = m_dbFactory.CreateDbParameter();
                cmd.CommandText = "INSERT INTO test_tbl (title) VALUES(?)";
                cmd.Parameters.Add(param);
                for (int i = 0; i < 10; ++i) {
                    param.Value = "Title " + i;
                    cmd.ExecuteNonQuery();
                }
            }
            tran.Commit();
        }
    }

    // test_tbl 内のデータを表示する
    public void ShowRecord(DbConnection con) {
        using (DbCommand cmd = con.CreateCommand()) {
            cmd.CommandText = "SELECT * FROM test_tbl";
            using (DbDataReader reader = cmd.ExecuteReader()) {
                while (reader.Read()) {
                    Console.WriteLine(String.Format("id={0}, title={1}", reader[0], reader[1]));
                }
            }
        }
    }

    // テスト
    static void Main(string[] args) {
        MainClass mc = new MainClass();
        using (DbConnection con = m_dbFactory.CreateDbConnection()) {
            con.Open();
            mc.CreateTable(con);
            mc.AddRecord(con);
            mc.ShowRecord(con);
        }
    }
}