SQLite作为一个本地文件数据库相当好用，小巧、快速、支持事务、关系型，甚至可以运行在Android上。在很久以前的一个项目中，我们用过它来将接收到的数据做本地统计，数据量很大，甚至于我们想自己搞个内存空间专门做缓存，缓存满后再一点点地往SQLite中移，现在看起来是多余的，这也不符合开发的过程。在开发中，应该先把功能做出来，如果有性能问题，再找出解决方法。直接在SQLite中做插入而不是先在内存中做，它的效率已经达到了要求。
现在跟大家分享一个对SQLite操作的帮助类，使用它可以对本地SQLite数据库进行方便的操作。
如有引用，注意写明转自：http://www.cnblogs.com/wgp13x/p/3868916.html
关键词：SQLite, C#, sqlite3.dll, SQLite Expert
摘要：SQLite作为一个本地文件数据库相当好用，小巧、快速、支持事务、关系型，在之前的一个项目中使用了它，现在把这使用经验总结一下，分享给大家。
1 usingSystem;
2 usingSystem.Data.SQLite;
3 usingSystem.Data;
4 usingSystem.Data.Common;
5
6 namespaceDXPlatformClientFramework.UC.StatAnalyzeCommon
7 {
8 publicclassSqliteHelper : IDisposable
9 {
10 publicSQLiteConnection conn;
11
12 publicvoidDispose()
13 {
14 Dispose(true);
15 GC.SuppressFinalize(this);
16 }
17
18 protectedvirtualvoidDispose(booldisposing)
19 {
20 if(disposing)
21 if(conn != null)
22 {
23 conn.Dispose();
24 conn = null;
25 }
26 }
27
28 ~SqliteHelper()
29 {
30 Dispose(false);
31 }
32
33 /// <summary>
34 /// 构造函数。
35 /// </summary>
36 /// <param name="dataBaseName">数据库名</param>
37 publicSqliteHelper(stringdataBaseName)
38 {
39 stringconnString = string.Format(@"Data Source={0}", dataBaseName);
40 conn = newSQLiteConnection(connString);
41 conn.Open();
42 }
43
44 /// <summary>
45 /// 手动打开数据库。
46 /// </summary>
47 publicvoidSqliteOpen()
48 {
49 if(conn != null&& conn.State == ConnectionState.Closed)
50 conn.Open();
51 }
52
53 /// <summary>
54 /// 通过执行SQL语句，获取表中数据。
55 /// </summary>
56 /// <param name="sError">错误信息</param>
57 /// <param name="sSQL">执行的SQL语句</param>
58 publicDataTable GetDataTable(outstringsError, stringsSQL)
59 {
60 DataTable dt = null;
61 sError = string.Empty;
62 try
63 {
64 SQLiteCommand cmd = newSQLiteCommand() { CommandText = sSQL, Connection = conn };
65 SQLiteDataAdapter dao = newSQLiteDataAdapter(cmd);
66 dt = newDataTable();
67 dao.Fill(dt);
68 }
69 catch(Exception e)
70 {
71 sError = e.Message;
72 }
73 returndt;
74 }
75
76 /// <summary>
77 /// 通过执行SQL语句，获取表中数据个数。
78 /// </summary>
79 /// <param name="sError">错误信息</param>
80 /// <param name="sSQL">执行的SQL语句</param>
81 publicintGetDataCount(outstringsError, stringsSQL)
82 {
83 DataTable dt = newDataTable();
84 sError = string.Empty;
85 SQLiteCommand cmd = newSQLiteCommand() { CommandText = sSQL, Connection = conn };
86 try
87 {
88 SQLiteDataAdapter dao = newSQLiteDataAdapter(cmd);
89 dao.Fill(dt);
90 cmd.Dispose();
91 }
92 catch(Exception e)
93 {
94 sError = e.Message;
95 }
96 finally{ cmd.Dispose(); }
97 returnint.Parse(dt.Rows[0][0].ToString());
98 }
99
100 /// <summary>
101 /// 通过执行SQL语句，执行insert,update,delete 动作，也可以使用事务。
102 /// </summary>
103 /// <param name="sError">错误信息</param>
104 /// <param name="sSQL">执行的SQL语句</param>
105 /// <param name="bUseTransaction">是否使用事务</param>
106 publicboolUpdateData(outstringsError, stringsSQL, boolbUseTransaction=false)
107
108 {
109 booliResult = false;
110 sError = string.Empty;
111 if(!bUseTransaction)
112 {
113 try
114 {
115 SQLiteCommand comm = newSQLiteCommand(conn) { CommandText = sSQL };
116 iResult = comm.ExecuteNonQuery()>0;
117 comm.Dispose();
118 }
119 catch(Exception ex)
120 {
121 sError = ex.Message;
122 }
123 }
124 else// 使用事务
125 {
126 DbTransaction trans = null;
127 trans = conn.BeginTransaction();
128 SQLiteCommand comm = newSQLiteCommand(conn) { CommandText = sSQL };
129 try
130 {
131 iResult = comm.ExecuteNonQuery()>0;
132 trans.Commit();
133 }
134 catch(Exception ex)
135 {
136 sError = ex.Message;
137 iResult = false;
138 trans.Rollback();
139 }
140 finally{comm.Dispose();trans.Dispose();}
141 }
142 returniResult;
143 }
144
145 /// <summary>
146 /// 使用事务执行多条相同的带参数的SQL语句。
147 /// </summary>
148 /// <param name="sqlString">SQL语句</param>
149 /// <param name="sqLiteParameters">每次SQL执行的参数</param>
150 publicvoidExecuteSqlTran(stringsqlString, object[][] sqLiteParameters)
151 {
152 if(sqLiteParameters.Length == 0)
153 return;
154 using(DbTransaction trans = conn.BeginTransaction())
155 {
156 if(conn.State != ConnectionState.Open)
157 conn.Open();
158 SQLiteCommand cmd = conn.CreateCommand();
159 cmd.Connection = conn;
160 try
161 {
162 for(inti = 0; i < sqLiteParameters[0].Length; i++)
163 {
164 cmd.Parameters.Add(cmd.CreateParameter());
165 }
166 //循环
167 foreach(object[] sqlParameters insqLiteParameters)
168 {
169 ExecuteSqlNonQuery(cmd, sqlString, sqlParameters);
170 }
171 trans.Commit();
172 }
173 catch(Exception ex)
174 {
175 trans.Rollback();
176 throw;
177 }
178 finally
179 {
180 cmd.Dispose();trans.Dispose();
181 }
182 }
183 }
184
185 /// <summary>
186 /// 不使用事务执行一条带参数的SQL语句。
187 /// </summary>
188 /// <param name="sqlString">SQL语句</param>
189 /// <param name="sqLiteParameters">SQL执行的参数</param>
190 publicvoidExecuteSql(stringsqlString, object[] sqLiteParameters)
191 {
192 if(conn.State != ConnectionState.Open)
193 conn.Open();
194 SQLiteCommand cmd = conn.CreateCommand();
195 cmd.Connection = conn;
196 cmd.CommandText = sqlString;
197 try
198 {
199 for(inti = 0; i < sqLiteParameters.Length; i++)
200 {
201 cmd.Parameters.Add(cmd.CreateParameter());
202 cmd.Parameters[i].Value = sqLiteParameters[i];
203 }
204 cmd.ExecuteNonQuery();
205 }
206 finally
207 {
208 cmd.Dispose();
209 }
210 }
211
212 privatevoidExecuteSqlNonQuery(SQLiteCommand cmd, stringcmdText, object[] cmdParms)
213
214 {
215 cmd.CommandText = cmdText;
216 if(cmdParms != null)
217 {
218 for(inti = 0; i < cmdParms.Length; i++ )
219 {
220 cmd.Parameters[i].Value = cmdParms[i];
221 }
222 }
223 cmd.ExecuteNonQuery();
224 }
225 }
226 }
SQLite的语法跟标准的SQL语法不太一样，比如isnull(x, y) --> 如果x为空则应该返回y，SQLite就不支持，取代的是ifnull(x, y)，使用起来也很方便。
这里提供了C#版本的的操作代码，JAVA版本的也差不多。
做了这个项目，回头看以前写的代码，惨不忍睹，太烂。尤其是关于C#多线程的，线程之间同步处理的一笔吊糟，经常缝缝补补，代码逻辑混乱。
做完后自己就立马总结了一下，关于多线程的同步，不到万不得以，不要自己做。
lock (BackWorker.ProduceLocker) { Monitor.Pulse(BackWorker.ProduceLocker); }
lock (BackWorker.ConsumeLocker) { Monitor.Wait(BackWorker.ConsumeLocker); }
这类的，非常容易把自己绕进去，而且脱离了面向对象的思想。
多线程同步无非是因为多个线程同时对同一份数据有了同时操作，它们之间得分出个先后次序来，
这在JAVA中提供了线程安全的集合在java.util.concurrent包中，这就不需要自己在线程中手动做同步了，这也非常符合面向对象的思想。
SQLite本身应该提供了多线程访问的支持。
之后的多线程开发就是使用了线程安全的集合，代码结构简单
。
来自王安琪http://www.cnblogs.com/wgp13x/
分享一个SqliteHelper类
时间： 2024-10-03 18:45:54