添加项目文件。

Szmedi.RvKits/Assists/DapperUtil.cs

@@ -0,0 +1,78 @@
+
+using System;
+using System.Data;
+using System.Data.SQLite;
+using System.Linq;
+using System.Windows;
+
+using Dapper;
+
+namespace Szmedi.RvKits.Assists
+{
+    public class DapperUtil
+    {
+        private readonly string connectionString;
+        private IDbConnection cnn;
+
+        public DapperUtil(string dbConnectionString)
+        {
+            connectionString = dbConnectionString;
+        }
+
+        public IDbConnection CreateConnect()
+        {
+            try
+            {
+                cnn = new SQLiteConnection(connectionString);
+                cnn.Open();
+            }
+            catch (Exception e)
+            {
+                MessageBox.Show("连接失败", e.Message);
+                LogAssists.WriteLog(e.StackTrace);
+            }
+
+            return cnn;
+        }
+
+        public int Delete(int id)
+        {
+            return cnn.Execute("delete from param where ID=" + id);
+        }
+
+        public List<T> LoadModel<T>(string tableName)
+        {
+            var output = cnn.Query<T>("select * from " + tableName, new DynamicParameters());
+            return output.ToList();
+        }
+
+        public List<T> QueryIn<T>()
+        {
+            var sql = "select * from param where id in @ids";
+            //参数类型是Array的时候，dappper会自动将其转化
+            return cnn.Query<T>(sql, new { ids = new int[2] { 1, 2 } }).ToList();
+        }
+
+        public List<T> QueryIn<T>(int[] ids)
+        {
+            var sql = "select * from param where id in @ids";
+            //参数类型是Array的时候，dappper会自动将其转化
+            return cnn.Query<T>(sql, new { ids }).ToList();
+        }
+
+        public void CloseConnect()
+        {
+            cnn.Close();
+        }
+
+        /// <summary>
+        /// </summary>
+        /// <param name="param"></param>
+        /// <param name="id"></param>
+        /// <param name="sql">"update param set MName = @MName,Age = @Age,Sex = @Sex,Phone = @Phone where ID=" + id</param>
+        public void UpdateData<T>(T param, string sql)
+        {
+            cnn.Execute(sql, param);
+        }
+    }
+}