C#操做SQLite數據庫增、刪、改、查 歡迎轉載
C#操做SQLite數據庫增、刪、改、查 歡迎轉載
轉載記得留下連接地址哦！！！
最想項目上要使用SQLite數據庫，不怕大夥笑話畢業四年了，一直使用Oracle或者MySQL或者SQLServer，可是真的是沒有用過SQLite數據庫，聽說很是輕量級，可是真沒有用過，因而網上大概搜索下，例子比較多，可是麼有一個完整的，即便有，也五花八門。。看的人頭暈，可能對於他們大神來說這都太簡單了，算求了更新一篇，新來的小夥伴請看下文，大神你就直接飄過吧!web
本例子運行效果sql
正式開始吧數據庫
1.SQLite的下載安裝
天然官網下載對應版本便可，我這裏下載的是 Precompiled Binaries for 32-bit Windows (.NET Framework 4.0) 不肯意下載的 能夠直接使用我下載過的 點擊這裏下載緩存
2.減壓找出咱們所須要的庫文件 這裏咱們只須要倆個文件下圖所示
3.下載一個數據庫管理系統來建立數據庫
我是用的是SQLiteStudio3.1.1版本 本身下載吧 下載地址：https://sqlitestudio.pl/index.rvt?act=download
測試
4.建立數據庫以及表
這裏建立一個簡單的表 UserInfo 完了代碼中會有這個數據庫 在Debug\bin目錄下ui
SQLite數據庫文件就一個後綴爲.db的文件，就沒了。。this
經過SQLiteStudio打開該數據庫spa
5.開始使用大夥所熟悉的VS了建立相關類
userinfo的Mode類.net
1 /// <summary> 2 /// UserInfo:實體類(屬性說明自動提取數據庫字段的描述信息) 3 /// </summary> 4 [Serializable] 5 public partial class UserInfo 6 { 7 public UserInfo() 8 { } 9 #region Model 10 private int _id; 11 private string _username; 12 private string _pwd; 13 private int? _age; 14 /// <summary> 15 /// 16 /// </summary> 17 public int ID 18 { 19 set { _id = value; } 20 get { return _id; } 21 } 22 /// <summary> 23 /// 24 /// </summary> 25 public string UserName 26 { 27 set { _username = value; } 28 get { return _username; } 29 } 30 /// <summary> 31 /// 32 /// </summary> 33 public string Pwd 34 { 35 set { _pwd = value; } 36 get { return _pwd; } 37 } 38 /// <summary> 39 /// 40 /// </summary> 41 public int? Age 42 { 43 set { _age = value; } 44 get { return _age; } 45 } 46 #endregion Model 47 48 }
UserInfo 的Dal類3d
1 /// <summary> 2 /// 數據訪問類:UserInfo 3 /// </summary> 4 public partial class UserInfo 5 { 6 public UserInfo() 7 { } 8 #region BasicMethod 9 10 /// <summary> 11 /// 獲得最大ID 12 /// </summary> 13 public int GetMaxId() 14 { 15 return DbHelperSQLite.GetMaxID("ID", "UserInfo"); 16 } 17 18 /// <summary> 19 /// 是否存在該記錄 20 /// </summary> 21 public bool Exists(int ID) 22 { 23 StringBuilder strSql = new StringBuilder(); 24 strSql.Append("select count(1) from UserInfo"); 25 strSql.Append(" where ID=@ID "); 26 SQLiteParameter[] parameters = { 27 new SQLiteParameter("@ID", DbType.Int32,8) }; 28 parameters[0].Value = ID; 29 30 return DbHelperSQLite.Exists(strSql.ToString(), parameters); 31 } 32 33 34 /// <summary> 35 /// 增長一條數據 36 /// </summary> 37 public bool Add(Model.UserInfo model) 38 { 39 StringBuilder strSql = new StringBuilder(); 40 strSql.Append("insert into UserInfo("); 41 strSql.Append("UserName,Pwd,Age)"); 42 strSql.Append(" values ("); 43 strSql.Append("@UserName,@Pwd,@Age)"); 44 SQLiteParameter[] parameters = { 45 new SQLiteParameter("@UserName", DbType.String,50), 46 new SQLiteParameter("@Pwd", DbType.String,25), 47 new SQLiteParameter("@Age", DbType.Int32,8)}; 48 parameters[0].Value = model.UserName; 49 parameters[1].Value = model.Pwd; 50 parameters[2].Value = model.Age; 51 52 int rows = DbHelperSQLite.ExecuteSql(strSql.ToString(), parameters); 53 if (rows > 0) 54 { 55 return true; 56 } 57 else 58 { 59 return false; 60 } 61 } 62 /// <summary> 63 /// 更新一條數據 64 /// </summary> 65 public bool Update(Model.UserInfo model) 66 { 67 StringBuilder strSql = new StringBuilder(); 68 strSql.Append("update UserInfo set "); 69 strSql.Append("UserName=@UserName,"); 70 strSql.Append("Pwd=@Pwd,"); 71 strSql.Append("Age=@Age"); 72 strSql.Append(" where ID=@ID "); 73 SQLiteParameter[] parameters = { 74 new SQLiteParameter("@UserName", DbType.String,50), 75 new SQLiteParameter("@Pwd", DbType.String,25), 76 new SQLiteParameter("@Age", DbType.Int32,8), 77 new SQLiteParameter("@ID", DbType.Int32,8)}; 78 parameters[0].Value = model.UserName; 79 parameters[1].Value = model.Pwd; 80 parameters[2].Value = model.Age; 81 parameters[3].Value = model.ID; 82 83 int rows = DbHelperSQLite.ExecuteSql(strSql.ToString(), parameters); 84 if (rows > 0) 85 { 86 return true; 87 } 88 else 89 { 90 return false; 91 } 92 } 93 94 /// <summary> 95 /// 刪除一條數據 96 /// </summary> 97 public bool Delete(int ID) 98 { 99 100 StringBuilder strSql = new StringBuilder(); 101 strSql.Append("delete from UserInfo "); 102 strSql.Append(" where ID=@ID "); 103 SQLiteParameter[] parameters = { 104 new SQLiteParameter("@ID", DbType.Int32,8) }; 105 parameters[0].Value = ID; 106 107 int rows = DbHelperSQLite.ExecuteSql(strSql.ToString(), parameters); 108 if (rows > 0) 109 { 110 return true; 111 } 112 else 113 { 114 return false; 115 } 116 } 117 /// <summary> 118 /// 批量刪除數據 119 /// </summary> 120 public bool DeleteList(string IDlist) 121 { 122 StringBuilder strSql = new StringBuilder(); 123 strSql.Append("delete from UserInfo "); 124 strSql.Append(" where ID in (" + IDlist + ") "); 125 int rows = DbHelperSQLite.ExecuteSql(strSql.ToString()); 126 if (rows > 0) 127 { 128 return true; 129 } 130 else 131 { 132 return false; 133 } 134 } 135 136 137 /// <summary> 138 /// 獲得一個對象實體 139 /// </summary> 140 public Model.UserInfo GetModel(int ID) 141 { 142 143 StringBuilder strSql = new StringBuilder(); 144 strSql.Append("select ID,UserName,Pwd,Age from UserInfo "); 145 strSql.Append(" where ID=@ID "); 146 SQLiteParameter[] parameters = { 147 new SQLiteParameter("@ID", DbType.Int32,8) }; 148 parameters[0].Value = ID; 149 150 Model.UserInfo model = new Model.UserInfo(); 151 DataSet ds = DbHelperSQLite.Query(strSql.ToString(), parameters); 152 if (ds.Tables[0].Rows.Count > 0) 153 { 154 return DataRowToModel(ds.Tables[0].Rows[0]); 155 } 156 else 157 { 158 return null; 159 } 160 } 161 162 163 /// <summary> 164 /// 獲得一個對象實體 165 /// </summary> 166 public Model.UserInfo DataRowToModel(DataRow row) 167 { 168 Model.UserInfo model = new Model.UserInfo(); 169 if (row != null) 170 { 171 if (row["ID"] != null && row["ID"].ToString() != "") 172 { 173 model.ID = int.Parse(row["ID"].ToString()); 174 } 175 if (row["UserName"] != null) 176 { 177 model.UserName = row["UserName"].ToString(); 178 } 179 if (row["Pwd"] != null) 180 { 181 model.Pwd = row["Pwd"].ToString(); 182 } 183 if (row["Age"] != null && row["Age"].ToString() != "") 184 { 185 model.Age = int.Parse(row["Age"].ToString()); 186 } 187 } 188 return model; 189 } 190 191 /// <summary> 192 /// 得到數據列表 193 /// </summary> 194 public DataSet GetList(string strWhere) 195 { 196 StringBuilder strSql = new StringBuilder(); 197 strSql.Append("select ID,UserName,Pwd,Age "); 198 strSql.Append(" FROM UserInfo "); 199 if (strWhere.Trim() != "") 200 { 201 strSql.Append(" where " + strWhere); 202 } 203 return DbHelperSQLite.Query(strSql.ToString()); 204 } 205 206 /// <summary> 207 /// 獲取記錄總數 208 /// </summary> 209 public int GetRecordCount(string strWhere) 210 { 211 StringBuilder strSql = new StringBuilder(); 212 strSql.Append("select count(1) FROM UserInfo "); 213 if (strWhere.Trim() != "") 214 { 215 strSql.Append(" where " + strWhere); 216 } 217 object obj = DbHelperSQLite.GetSingle(strSql.ToString()); 218 if (obj == null) 219 { 220 return 0; 221 } 222 else 223 { 224 return Convert.ToInt32(obj); 225 } 226 } 227 /// <summary> 228 /// 分頁獲取數據列表 229 /// </summary> 230 public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) 231 { 232 StringBuilder strSql = new StringBuilder(); 233 strSql.Append("SELECT * FROM ( "); 234 strSql.Append(" SELECT ROW_NUMBER() OVER ("); 235 if (!string.IsNullOrEmpty(orderby.Trim())) 236 { 237 strSql.Append("order by T." + orderby); 238 } 239 else 240 { 241 strSql.Append("order by T.ID desc"); 242 } 243 strSql.Append(")AS Row, T.* from UserInfo T "); 244 if (!string.IsNullOrEmpty(strWhere.Trim())) 245 { 246 strSql.Append(" WHERE " + strWhere); 247 } 248 strSql.Append(" ) TT"); 249 strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex); 250 return DbHelperSQLite.Query(strSql.ToString()); 251 } 252 253 #endregion BasicMethod 254 }
Userinfo的BLL類
1 public partial class UserInfo 2 { 3 private readonly DAL.UserInfo dal = new DAL.UserInfo(); 4 public UserInfo() 5 { } 6 #region BasicMethod 7 8 /// <summary> 9 /// 獲得最大ID 10 /// </summary> 11 public int GetMaxId() 12 { 13 return dal.GetMaxId(); 14 } 15 16 /// <summary> 17 /// 是否存在該記錄 18 /// </summary> 19 public bool Exists(int ID) 20 { 21 return dal.Exists(ID); 22 } 23 24 /// <summary> 25 /// 增長一條數據 26 /// </summary> 27 public bool Add(Model.UserInfo model) 28 { 29 return dal.Add(model); 30 } 31 32 /// <summary> 33 /// 更新一條數據 34 /// </summary> 35 public bool Update(Model.UserInfo model) 36 { 37 return dal.Update(model); 38 } 39 40 /// <summary> 41 /// 刪除一條數據 42 /// </summary> 43 public bool Delete(int ID) 44 { 45 46 return dal.Delete(ID); 47 } 48 /// <summary> 49 /// 刪除一條數據 50 /// </summary> 51 public bool DeleteList(string IDlist) 52 { 53 return dal.DeleteList(IDlist); 54 } 55 56 /// <summary> 57 /// 獲得一個對象實體 58 /// </summary> 59 public Model.UserInfo GetModel(int ID) 60 { 61 62 return dal.GetModel(ID); 63 } 64 65 ///// <summary> 66 ///// 獲得一個對象實體，從緩存中 67 ///// </summary> 68 //public Model.UserInfo GetModelByCache(int ID) 69 //{ 70 71 // string CacheKey = "UserInfoModel-" + ID; 72 // object objModel = Common.DataCache.GetCache(CacheKey); 73 // if (objModel == null) 74 // { 75 // try 76 // { 77 // objModel = dal.GetModel(ID); 78 // if (objModel != null) 79 // { 80 // int ModelCache = Maticsoft.Common.ConfigHelper.GetConfigInt("ModelCache"); 81 // Maticsoft.Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero); 82 // } 83 // } 84 // catch { } 85 // } 86 // return (Maticsoft.Model.UserInfo)objModel; 87 //} 88 89 /// <summary> 90 /// 得到數據列表 91 /// </summary> 92 public DataSet GetList(string strWhere) 93 { 94 return dal.GetList(strWhere); 95 } 96 /// <summary> 97 /// 得到數據列表 98 /// </summary> 99 public List<Model.UserInfo> GetModelList(string strWhere) 100 { 101 DataSet ds = dal.GetList(strWhere); 102 return DataTableToList(ds.Tables[0]); 103 } 104 /// <summary> 105 /// 得到數據列表 106 /// </summary> 107 public List<Model.UserInfo> DataTableToList(DataTable dt) 108 { 109 List<Model.UserInfo> modelList = new List<Model.UserInfo>(); 110 int rowsCount = dt.Rows.Count; 111 if (rowsCount > 0) 112 { 113 Model.UserInfo model; 114 for (int n = 0; n < rowsCount; n++) 115 { 116 model = dal.DataRowToModel(dt.Rows[n]); 117 if (model != null) 118 { 119 modelList.Add(model); 120 } 121 } 122 } 123 return modelList; 124 } 125 126 /// <summary> 127 /// 得到數據列表 128 /// </summary> 129 public DataSet GetAllList() 130 { 131 return GetList(""); 132 } 133 134 /// <summary> 135 /// 分頁獲取數據列表 136 /// </summary> 137 public int GetRecordCount(string strWhere) 138 { 139 return dal.GetRecordCount(strWhere); 140 } 141 /// <summary> 142 /// 分頁獲取數據列表 143 /// </summary> 144 public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) 145 { 146 return dal.GetListByPage(strWhere, orderby, startIndex, endIndex); 147 } 148 /// <summary> 149 /// 分頁獲取數據列表 150 /// </summary> 151 //public DataSet GetList(int PageSize,int PageIndex,string strWhere) 152 //{ 153 //return dal.GetList(PageSize,PageIndex,strWhere); 154 //} 155 156 #endregion BasicMethod 157 #region ExtensionMethod 158 159 #endregion ExtensionMethod 160 }
建立SQLite幫助類
1 /// <summary> 2 /// 數據訪問基礎類(基於SQLite) 3 /// 能夠用戶能夠修改知足本身項目的須要。 4 /// </summary> 5 public abstract class DbHelperSQLite 6 { 7 //數據庫鏈接字符串(web.config來配置)，能夠動態更改connectionString支持多數據庫. 8 public static string connectionString = CreateConnectionString(); 9 public DbHelperSQLite() 10 { 11 } 12 private static string CreateConnectionString() 13 { 14 15 string dbName = ConfigurationManager.AppSettings["SQLiteDB"]; 16 string sqlLitePath = "data source=" + System.Environment.CurrentDirectory+"\\"+dbName + ";version=3;"; 17 return sqlLitePath; 18 } 19 20 #region 公用方法 21 22 public static int GetMaxID(string FieldName, string TableName) 23 { 24 string strsql = "select max(" + FieldName + ")+1 from " + TableName; 25 object obj = GetSingle(strsql); 26 if (obj == null) 27 { 28 return 1; 29 } 30 else 31 { 32 return int.Parse(obj.ToString()); 33 } 34 } 35 public static bool Exists(string strSql) 36 { 37 object obj = GetSingle(strSql); 38 int cmdresult; 39 if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value))) 40 { 41 cmdresult = 0; 42 } 43 else 44 { 45 cmdresult = int.Parse(obj.ToString()); 46 } 47 if (cmdresult == 0) 48 { 49 return false; 50 } 51 else 52 { 53 return true; 54 } 55 } 56 public static bool Exists(string strSql, params SQLiteParameter[] cmdParms) 57 { 58 object obj = GetSingle(strSql, cmdParms); 59 int cmdresult; 60 if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value))) 61 { 62 cmdresult = 0; 63 } 64 else 65 { 66 cmdresult = int.Parse(obj.ToString()); 67 } 68 if (cmdresult == 0) 69 { 70 return false; 71 } 72 else 73 { 74 return true; 75 } 76 } 77 78 #endregion 79 80 #region 執行簡單SQL語句 81 82 /// <summary> 83 /// 執行SQL語句，返回影響的記錄數 84 /// </summary> 85 /// <param name="SQLString">SQL語句</param> 86 /// <returns>影響的記錄數</returns> 87 public static int ExecuteSql(string SQLString) 88 { 89 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 90 { 91 using (SQLiteCommand cmd = new SQLiteCommand(SQLString, connection)) 92 { 93 try 94 { 95 connection.Open(); 96 int rows = cmd.ExecuteNonQuery(); 97 return rows; 98 } 99 catch (System.Data.SQLite.SQLiteException E) 100 { 101 connection.Close(); 102 throw new Exception(E.Message); 103 } 104 } 105 } 106 } 107 108 /// <summary> 109 /// 執行多條SQL語句，實現數據庫事務。 110 /// </summary> 111 /// <param name="SQLStringList">多條SQL語句</param> 112 public static void ExecuteSqlTran(ArrayList SQLStringList) 113 { 114 using (SQLiteConnection conn = new SQLiteConnection(connectionString)) 115 { 116 conn.Open(); 117 SQLiteCommand cmd = new SQLiteCommand(); 118 cmd.Connection = conn; 119 SQLiteTransaction tx = conn.BeginTransaction(); 120 cmd.Transaction = tx; 121 try 122 { 123 for (int n = 0; n < SQLStringList.Count; n++) 124 { 125 string strsql = SQLStringList[n].ToString(); 126 if (strsql.Trim().Length > 1) 127 { 128 cmd.CommandText = strsql; 129 cmd.ExecuteNonQuery(); 130 } 131 } 132 tx.Commit(); 133 } 134 catch (System.Data.SQLite.SQLiteException E) 135 { 136 tx.Rollback(); 137 throw new Exception(E.Message); 138 } 139 } 140 } 141 /// <summary> 142 /// 執行帶一個存儲過程參數的的SQL語句。 143 /// </summary> 144 /// <param name="SQLString">SQL語句</param> 145 /// <param name="content">參數內容,好比一個字段是格式複雜的文章，有特殊符號，能夠經過這個方式添加</param> 146 /// <returns>影響的記錄數</returns> 147 public static int ExecuteSql(string SQLString, string content) 148 { 149 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 150 { 151 SQLiteCommand cmd = new SQLiteCommand(SQLString, connection); 152 SQLiteParameter myParameter = new SQLiteParameter("@content", DbType.String); 153 myParameter.Value = content; 154 cmd.Parameters.Add(myParameter); 155 try 156 { 157 connection.Open(); 158 int rows = cmd.ExecuteNonQuery(); 159 return rows; 160 } 161 catch (System.Data.SQLite.SQLiteException E) 162 { 163 throw new Exception(E.Message); 164 } 165 finally 166 { 167 cmd.Dispose(); 168 connection.Close(); 169 } 170 } 171 } 172 /// <summary> 173 /// 向數據庫裏插入圖像格式的字段(和上面狀況相似的另外一種實例) 174 /// </summary> 175 /// <param name="strSQL">SQL語句</param> 176 /// <param name="fs">圖像字節,數據庫的字段類型爲image的狀況</param> 177 /// <returns>影響的記錄數</returns> 178 public static int ExecuteSqlInsertImg(string strSQL, byte[] fs) 179 { 180 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 181 { 182 SQLiteCommand cmd = new SQLiteCommand(strSQL, connection); 183 SQLiteParameter myParameter = new SQLiteParameter("@fs", DbType.Binary); 184 myParameter.Value = fs; 185 cmd.Parameters.Add(myParameter); 186 try 187 { 188 connection.Open(); 189 int rows = cmd.ExecuteNonQuery(); 190 return rows; 191 } 192 catch (System.Data.SQLite.SQLiteException E) 193 { 194 throw new Exception(E.Message); 195 } 196 finally 197 { 198 cmd.Dispose(); 199 connection.Close(); 200 } 201 } 202 } 203 204 /// <summary> 205 /// 執行一條計算查詢結果語句，返回查詢結果（object）。 206 /// </summary> 207 /// <param name="SQLString">計算查詢結果語句</param> 208 /// <returns>查詢結果（object）</returns> 209 public static object GetSingle(string SQLString) 210 { 211 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 212 { 213 using (SQLiteCommand cmd = new SQLiteCommand(SQLString, connection)) 214 { 215 try 216 { 217 connection.Open(); 218 object obj = cmd.ExecuteScalar(); 219 if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value))) 220 { 221 return null; 222 } 223 else 224 { 225 return obj; 226 } 227 } 228 catch (System.Data.SQLite.SQLiteException e) 229 { 230 connection.Close(); 231 throw new Exception(e.Message); 232 } 233 } 234 } 235 } 236 /// <summary> 237 /// 執行查詢語句，返回SQLiteDataReader 238 /// </summary> 239 /// <param name="strSQL">查詢語句</param> 240 /// <returns>SQLiteDataReader</returns> 241 public static SQLiteDataReader ExecuteReader(string strSQL) 242 { 243 SQLiteConnection connection = new SQLiteConnection(connectionString); 244 SQLiteCommand cmd = new SQLiteCommand(strSQL, connection); 245 try 246 { 247 connection.Open(); 248 SQLiteDataReader myReader = cmd.ExecuteReader(); 249 return myReader; 250 } 251 catch (System.Data.SQLite.SQLiteException e) 252 { 253 throw new Exception(e.Message); 254 } 255 256 } 257 /// <summary> 258 /// 執行查詢語句，返回DataSet 259 /// </summary> 260 /// <param name="SQLString">查詢語句</param> 261 /// <returns>DataSet</returns> 262 public static DataSet Query(string SQLString) 263 { 264 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 265 { 266 DataSet ds = new DataSet(); 267 try 268 { 269 connection.Open(); 270 SQLiteDataAdapter command = new SQLiteDataAdapter(SQLString, connection); 271 command.Fill(ds, "ds"); 272 } 273 catch (System.Data.SQLite.SQLiteException ex) 274 { 275 throw new Exception(ex.Message); 276 } 277 return ds; 278 } 279 } 280 281 282 #endregion 283 284 #region 執行帶參數的SQL語句 285 286 /// <summary> 287 /// 執行SQL語句，返回影響的記錄數 288 /// </summary> 289 /// <param name="SQLString">SQL語句</param> 290 /// <returns>影響的記錄數</returns> 291 public static int ExecuteSql(string SQLString, params SQLiteParameter[] cmdParms) 292 { 293 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 294 { 295 using (SQLiteCommand cmd = new SQLiteCommand()) 296 { 297 try 298 { 299 PrepareCommand(cmd, connection, null, SQLString, cmdParms); 300 int rows = cmd.ExecuteNonQuery(); 301 cmd.Parameters.Clear(); 302 return rows; 303 } 304 catch (System.Data.SQLite.SQLiteException E) 305 { 306 throw new Exception(E.Message); 307 } 308 } 309 } 310 } 311 312 313 /// <summary> 314 /// 執行多條SQL語句，實現數據庫事務。 315 /// </summary> 316 /// <param name="SQLStringList">SQL語句的哈希表（key爲sql語句，value是該語句的SQLiteParameter[]）</param> 317 public static void ExecuteSqlTran(Hashtable SQLStringList) 318 { 319 using (SQLiteConnection conn = new SQLiteConnection(connectionString)) 320 { 321 conn.Open(); 322 using (SQLiteTransaction trans = conn.BeginTransaction()) 323 { 324 SQLiteCommand cmd = new SQLiteCommand(); 325 try 326 { 327 //循環 328 foreach (DictionaryEntry myDE in SQLStringList) 329 { 330 string cmdText = myDE.Key.ToString(); 331 SQLiteParameter[] cmdParms = (SQLiteParameter[])myDE.Value; 332 PrepareCommand(cmd, conn, trans, cmdText, cmdParms); 333 int val = cmd.ExecuteNonQuery(); 334 cmd.Parameters.Clear(); 335 336 trans.Commit(); 337 } 338 } 339 catch 340 { 341 trans.Rollback(); 342 throw; 343 } 344 } 345 } 346 } 347 348 349 /// <summary> 350 /// 執行一條計算查詢結果語句，返回查詢結果（object）。 351 /// </summary> 352 /// <param name="SQLString">計算查詢結果語句</param> 353 /// <returns>查詢結果（object）</returns> 354 public static object GetSingle(string SQLString, params SQLiteParameter[] cmdParms) 355 { 356 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 357 { 358 using (SQLiteCommand cmd = new SQLiteCommand()) 359 { 360 try 361 { 362 PrepareCommand(cmd, connection, null, SQLString, cmdParms); 363 object obj = cmd.ExecuteScalar(); 364 cmd.Parameters.Clear(); 365 if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value))) 366 { 367 return null; 368 } 369 else 370 { 371 return obj; 372 } 373 } 374 catch (System.Data.SQLite.SQLiteException e) 375 { 376 throw new Exception(e.Message); 377 } 378 } 379 } 380 } 381 382 /// <summary> 383 /// 執行查詢語句，返回SQLiteDataReader 384 /// </summary> 385 /// <param name="strSQL">查詢語句</param> 386 /// <returns>SQLiteDataReader</returns> 387 public static SQLiteDataReader ExecuteReader(string SQLString, params SQLiteParameter[] cmdParms) 388 { 389 SQLiteConnection connection = new SQLiteConnection(connectionString); 390 SQLiteCommand cmd = new SQLiteCommand(); 391 try 392 { 393 PrepareCommand(cmd, connection, null, SQLString, cmdParms); 394 SQLiteDataReader myReader = cmd.ExecuteReader(); 395 cmd.Parameters.Clear(); 396 return myReader; 397 } 398 catch (System.Data.SQLite.SQLiteException e) 399 { 400 throw new Exception(e.Message); 401 } 402 403 } 404 405 /// <summary> 406 /// 執行查詢語句，返回DataSet 407 /// </summary> 408 /// <param name="SQLString">查詢語句</param> 409 /// <returns>DataSet</returns> 410 public static DataSet Query(string SQLString, params SQLiteParameter[] cmdParms) 411 { 412 using (SQLiteConnection connection = new SQLiteConnection(connectionString)) 413 { 414 SQLiteCommand cmd = new SQLiteCommand(); 415 PrepareCommand(cmd, connection, null, SQLString, cmdParms); 416 using (SQLiteDataAdapter da = new SQLiteDataAdapter(cmd)) 417 { 418 DataSet ds = new DataSet(); 419 try 420 { 421 da.Fill(ds, "ds"); 422 cmd.Parameters.Clear(); 423 } 424 catch (System.Data.SQLite.SQLiteException ex) 425 { 426 throw new Exception(ex.Message); 427 } 428 return ds; 429 } 430 } 431 } 432 433 434 private static void PrepareCommand(SQLiteCommand cmd, SQLiteConnection conn, SQLiteTransaction trans, string cmdText, SQLiteParameter[] cmdParms) 435 { 436 if (conn.State != ConnectionState.Open) 437 conn.Open(); 438 cmd.Connection = conn; 439 cmd.CommandText = cmdText; 440 if (trans != null) 441 cmd.Transaction = trans; 442 cmd.CommandType = CommandType.Text;//cmdType; 443 if (cmdParms != null) 444 { 445 foreach (SQLiteParameter parm in cmdParms) 446 cmd.Parameters.Add(parm); 447 } 448 } 449 450 #endregion 451 452 453 454 }
6.建立一個WinForm窗體用於測試
大概是這樣的，我用的是VS2017
數據庫配置文件新增App.config文件 其他的沒有用，是Mysql的鏈接字符串，能夠不用管。。。
窗體代碼大概是這樣的比較簡單，只是實現簡單的操做，具體細節那就交個你們了。。。
1 public partial class Form1 : Form 2 { 3 public Form1() 4 { 5 InitializeComponent(); 6 } 7 8 9 BLL.UserInfo bll = new BLL.UserInfo(); 10 11 12 //數據庫鏈接 13 SQLiteConnection m_dbConnection; 14 private void button1_Click(object sender, EventArgs e) 15 { 16 17 DataSet ds = bll.GetAllList(); 18 19 this.dataGridView1.DataSource = ds.Tables[0]; 20 21 } 22 23 int count = 0; 24 private void button2_Click(object sender, EventArgs e) 25 { 26 count++; 27 Model.UserInfo userInfo = new Model.UserInfo(); 28 userInfo.UserName = "Count" + count; 29 userInfo.Pwd = "123456"; 30 userInfo.Age = count; 31 32 bll.Add(userInfo); 33 34 DataSet ds = bll.GetAllList(); 35 this.dataGridView1.DataSource = ds.Tables[0]; 36 37 } 38 39 private void button3_Click(object sender, EventArgs e) 40 { 41 42 Model.UserInfo userInfo = new Model.UserInfo(); 43 userInfo.ID = int.Parse(this.label1.Text); 44 userInfo.UserName = this.textBox1.Text; 45 userInfo.Pwd = this.textBox2.Text; 46 userInfo.Age = int.Parse(this.textBox3.Text); 47 bll.Update(userInfo); 48 49 50 DataSet ds = bll.GetAllList(); 51 this.dataGridView1.DataSource = ds.Tables[0]; 52 53 54 } 55 56 private void dataGridView1_MouseClick(object sender, MouseEventArgs e) 57 { 58 DataGridViewRow row = this.dataGridView1.CurrentRow; 59 this.label1.Text = row.Cells[0].Value.ToString(); 60 this.textBox1.Text = row.Cells[1].Value.ToString(); 61 this.textBox2.Text = row.Cells[2].Value.ToString(); 62 this.textBox3.Text = row.Cells[3].Value.ToString(); 63 64 65 } 66 67 private void button4_Click(object sender, EventArgs e) 68 { 69 bll.Delete(int.Parse(this.label1.Text)); 70 71 72 DataSet ds = bll.GetAllList(); 73 this.dataGridView1.DataSource = ds.Tables[0]; 74 } 75 76 private void linkLabel1_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e) 77 { 78 79 Process.Start("IExplore", "https://www.cnblogs.com/JiYF/"); 80 } 81 }
7.運行效果
8.項目結構文件
到這裏就完了，新手本身去下載調試吧，。。。。。愛大家喲 麼麼噠！❥(^_-)
源代碼工程下載地址
或者博客留言，給出郵箱，發你！！！
舒適小提示：
SQLite版本問題，若是你使用的32位，記得項目編譯採用X86 若是你是64位則採用X64 不然會提示錯誤信息，就醬紫。。。。。。。。。。
相關文章
- 1. SQLite數據庫增刪改查操做
- 2. Android SQLite數據庫增刪改查操做的使用
- 3. Android的SQLite數據庫的增刪改查操做
- 4. flask 數據庫操做（增刪改查）--
- 5. MySQL數據庫操做【增刪改查】
- 6. python 操做 sqlite 數據庫(建表, 增刪改查)
- 7. 【Android】Sqlite數據庫增刪改查
- 8. MySQL數據庫操做——增刪查改
- 9. android數據庫增刪改查操做
- 10. mybatis數據庫增刪改查操做
- 更多相關文章...
- • Hibernate實現增刪改查 - Hibernate教程
- • SQLite 創建數據庫 - SQLite教程
- • Flink 數據傳輸及反壓詳解
- • TiDB 在摩拜單車在線數據業務的應用和實踐
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
