vhyahtJP

1using System;
2using System.Collections.Generic;
3using System.Linq;
4using System.Text;
5using Community.CsharpSqlite.SQLiteClient;
6
7namespace csharp_sqlite_testproject
8{
9    class ThirdStep
10    {
11        // DB接続文字列
12        // この記述でカレントディレクトリの db.sqlite が接続先となる
13        private const String connectionStr = @"uri=file:db.sqlite";
14
15        // (参考)hogeテーブル作成用SQL
16        private const String createTableSQL = @"CREATE TABLE IF NOT EXISTS hoge(name, email)";
17
18        // INSERTæ–‡
19        private const String insertSQL = @"INSERT INTO hoge VALUES (?, ?)";
20
21
22        // prepared statement を使ってのinsert
23        public void Start()
24        {
25            // using使えるところはどんどん使う
26            using (var con = new SqliteConnection(connectionStr))
27            {
28                con.Open(); // DB接続
29
30                using (var tran = con.BeginTransaction()) // トランザクション開始
31                {
32                    using (var cmd = con.CreateCommand()) // SQLオブジェクト作成
33                    {
34                        cmd.CommandText = insertSQL; // SQL設定
35
36                        foreach (var i in Enumerable.Range(1, 5))
37                        {
38                            // SqliteParameter の作成
39                            var param1 = new SqliteParameter()
40                            {
41                                // ParameterName というオプションもあるのがだ使われてないっぽい
42                                DbType = System.Data.DbType.String,
43                                Value = string.Format("user{0}", i),
44                            };
45
46                            var param2 = new SqliteParameter()
47                            { 
48                                DbType = System.Data.DbType.String,
49                                Value = string.Format("user{0}@example.com", i),
50                            };
51
52                            // コマンドオブジェクトを使いまわす場合はClear()が必要
53                            // addの順番がprepared statementの割り当て順となる
54                            cmd.Parameters.Clear();
55                            cmd.Parameters.Add(param1);
56                            cmd.Parameters.Add(param2);
57                                                       
58
59                            // 3.7.7.1だとPrepare()呼ばなくてもprepared statementが適応される
60                            // 今後の修正でどうなるかわからないので呼ぶことが望ましいか
61                            cmd.Prepare();
62
63                            cmd.ExecuteNonQuery();
64                        }
65
66                    }
67
68                    tran.Commit(); // コミット
69                }
70            }
71        }
72    }
73}