分享一个SqliteHelper类
SQLite作为一个本地文件数据库相当好用,小巧、快速、支持事务、关系型,甚至可以运行在Android上。在很久以前的一个项目中,我们用过它来将接收到的数据做本地统计,数据量很大,甚至于我们想自己搞个内存空间专门做缓存,缓存满后再一点点地往SQLite中移,现在看起来是多余的,这也不符合开发的过程。在开发中,应该先把功能做出来,如果有性能问题,再找出解决方法。直接在SQLite中做插入而不是先在内存中做,它的效率已经达到了要求。
现在跟大家分享一个对SQLite操作的帮助类,使用它可以对本地SQLite数据库进行方便的操作。
如有引用,注意写明转自:http://www.cnblogs.com/wgp13x/p/3868916.html
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 }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。