|
| 1 | +using System; |
| 2 | +using System.Collections.Generic; |
| 3 | +using System.Linq; |
| 4 | +using System.Text; |
| 5 | + |
| 6 | +using Mono.Data.Sqlite; |
| 7 | +using System.IO; |
| 8 | +using System.Data; |
| 9 | + |
| 10 | +namespace Todo |
| 11 | +{ |
| 12 | + public class ADODatabase : IADODatabase |
| 13 | + { |
| 14 | + static object locker = new object (); |
| 15 | + |
| 16 | + public SqliteConnection connection; |
| 17 | + |
| 18 | + public string path; |
| 19 | + |
| 20 | + /// <summary> |
| 21 | + /// Initializes a new instance of the <see cref="Tasky.DL.TaskDatabase"/> TaskDatabase. |
| 22 | + /// if the database doesn't exist, it will create the database and all the tables. |
| 23 | + /// </summary> |
| 24 | + public ADODatabase(string dbPath) |
| 25 | + { |
| 26 | + var output = ""; |
| 27 | + path = dbPath; |
| 28 | + // create the tables |
| 29 | + bool exists = File.Exists (dbPath); |
| 30 | + |
| 31 | + if (!exists) { |
| 32 | + connection = new SqliteConnection ("Data Source=" + dbPath); |
| 33 | + |
| 34 | + connection.Open (); |
| 35 | + var commands = new[] { |
| 36 | + "CREATE TABLE [TodoItem] (ID INTEGER PRIMARY KEY ASC, Name NTEXT, Notes NTEXT, Done INTEGER);" |
| 37 | + }; |
| 38 | + foreach (var command in commands) { |
| 39 | + using (var c = connection.CreateCommand ()) { |
| 40 | + c.CommandText = command; |
| 41 | + var i = c.ExecuteNonQuery (); |
| 42 | + } |
| 43 | + } |
| 44 | + } else { |
| 45 | + // already exists, do nothing. |
| 46 | + } |
| 47 | + Console.WriteLine (output); |
| 48 | + } |
| 49 | + |
| 50 | + /// <summary>Convert from DataReader to Task object</summary> |
| 51 | + TodoItem FromReader (SqliteDataReader r) { |
| 52 | + var t = new TodoItem(); |
| 53 | + t.Id = Convert.ToInt32 (r ["ID"]); |
| 54 | + t.Name = r ["Name"].ToString (); |
| 55 | + t.Notes = r ["Notes"].ToString (); |
| 56 | + t.Done = Convert.ToInt32 (r ["Done"]) == 1 ? true : false; |
| 57 | + return t; |
| 58 | + } |
| 59 | + |
| 60 | + public IEnumerable<TodoItem> GetItems() |
| 61 | + { |
| 62 | + var tl = new List<TodoItem>(); |
| 63 | + |
| 64 | + lock (locker) { |
| 65 | + connection = new SqliteConnection ("Data Source=" + path); |
| 66 | + connection.Open (); |
| 67 | + using (var contents = connection.CreateCommand ()) { |
| 68 | + contents.CommandText = "SELECT [ID], [Name], [Notes], [Done] from [TodoItem]"; |
| 69 | + var r = contents.ExecuteReader (); |
| 70 | + while (r.Read ()) { |
| 71 | + tl.Add (FromReader(r)); |
| 72 | + } |
| 73 | + } |
| 74 | + connection.Close (); |
| 75 | + } |
| 76 | + return tl; |
| 77 | + } |
| 78 | + |
| 79 | + public IEnumerable<TodoItem> GetItemsNotDone() |
| 80 | + { |
| 81 | + var tl = new List<TodoItem>(); |
| 82 | + |
| 83 | + lock (locker) { |
| 84 | + connection = new SqliteConnection ("Data Source=" + path); |
| 85 | + connection.Open (); |
| 86 | + using (var contents = connection.CreateCommand ()) { |
| 87 | + contents.CommandText = "SELECT [ID], [Name], [Notes], [Done] FROM [TodoItem] WHERE [Done] = 0"; |
| 88 | + var r = contents.ExecuteReader (); |
| 89 | + while (r.Read ()) { |
| 90 | + tl.Add (FromReader(r)); |
| 91 | + } |
| 92 | + } |
| 93 | + connection.Close (); |
| 94 | + } |
| 95 | + return tl; |
| 96 | + } |
| 97 | + |
| 98 | + public TodoItem GetItem(int id) |
| 99 | + { |
| 100 | + var t = new TodoItem(); |
| 101 | + lock (locker) { |
| 102 | + connection = new SqliteConnection ("Data Source=" + path); |
| 103 | + connection.Open (); |
| 104 | + using (var command = connection.CreateCommand ()) { |
| 105 | + command.CommandText = "SELECT [ID], [Name], [Notes], [Done] from [TodoItem] WHERE [ID] = ?"; |
| 106 | + command.Parameters.Add (new SqliteParameter (DbType.Int32) { Value = id }); |
| 107 | + var r = command.ExecuteReader (); |
| 108 | + while (r.Read ()) { |
| 109 | + t = FromReader (r); |
| 110 | + break; |
| 111 | + } |
| 112 | + } |
| 113 | + connection.Close (); |
| 114 | + } |
| 115 | + return t; |
| 116 | + } |
| 117 | + |
| 118 | + public int SaveItem(TodoItem item) |
| 119 | + { |
| 120 | + int r; |
| 121 | + lock (locker) { |
| 122 | + if (item.Id != 0) { |
| 123 | + connection = new SqliteConnection ("Data Source=" + path); |
| 124 | + connection.Open (); |
| 125 | + using (var command = connection.CreateCommand ()) { |
| 126 | + command.CommandText = "UPDATE [TodoItem] SET [Name] = ?, [Notes] = ?, [Done] = ? WHERE [ID] = ?;"; |
| 127 | + command.Parameters.Add (new SqliteParameter (DbType.String) { Value = item.Name }); |
| 128 | + command.Parameters.Add (new SqliteParameter (DbType.String) { Value = item.Notes }); |
| 129 | + command.Parameters.Add (new SqliteParameter (DbType.Int32) { Value = item.Done }); |
| 130 | + command.Parameters.Add (new SqliteParameter (DbType.Int32) { Value = item.Id }); |
| 131 | + r = command.ExecuteNonQuery (); |
| 132 | + } |
| 133 | + connection.Close (); |
| 134 | + return r; |
| 135 | + } else { |
| 136 | + connection = new SqliteConnection ("Data Source=" + path); |
| 137 | + connection.Open (); |
| 138 | + using (var command = connection.CreateCommand ()) { |
| 139 | + command.CommandText = "INSERT INTO [TodoItem] ([Name], [Notes], [Done]) VALUES (? ,?, ?)"; |
| 140 | + command.Parameters.Add (new SqliteParameter (DbType.String) { Value = item.Name }); |
| 141 | + command.Parameters.Add (new SqliteParameter (DbType.String) { Value = item.Notes }); |
| 142 | + command.Parameters.Add (new SqliteParameter (DbType.Int32) { Value = item.Done }); |
| 143 | + r = command.ExecuteNonQuery (); |
| 144 | + } |
| 145 | + connection.Close (); |
| 146 | + return r; |
| 147 | + } |
| 148 | + |
| 149 | + } |
| 150 | + } |
| 151 | + |
| 152 | + public int DeleteItem(int id) |
| 153 | + { |
| 154 | + lock (locker) { |
| 155 | + int r; |
| 156 | + connection = new SqliteConnection ("Data Source=" + path); |
| 157 | + connection.Open (); |
| 158 | + using (var command = connection.CreateCommand ()) { |
| 159 | + command.CommandText = "DELETE FROM [TodoItem] WHERE [ID] = ?;"; |
| 160 | + command.Parameters.Add (new SqliteParameter (DbType.Int32) { Value = id}); |
| 161 | + r = command.ExecuteNonQuery (); |
| 162 | + } |
| 163 | + connection.Close (); |
| 164 | + return r; |
| 165 | + } |
| 166 | + } |
| 167 | + } |
| 168 | +} |
| 169 | + |
0 commit comments