Services/TableService.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using AppManager.CustomEnum;
using AppManager.DataBase;
using AppManager.Excep;
using AppManager.Pojo;
using System;
using System.Collections.Generic;
using System.Data.SQLite;
using System.Reflection;
using System.Text;

namespace AppManager.Services {
    /// <summary>
    /// 操作http发送数据
    /// </summary>
    internal class TableService<T> where T : TableData {
        private static readonly SqLiteHelper SqlLiteHelper = SqLiteFactory.GetSqLiteHelper(DbConstants.DbName, DbConstants.DbPassword);

        protected TableService() {
            InitTable();
        }

        private void InitTable() {
            string tableName = GetTableName();
            // 判断表是否存在
            if (!SqlLiteHelper.TableExists(tableName)) {
                // 创建表
                CreateTable();
            } else {
                StringBuilder sb = new StringBuilder();
                List<string> nameList = GetTableParam();
                // 获取自己和父类的属性
                var infos = typeof(T).GetProperties();
                foreach (var info in infos) {
                    var tableParam = GetAttributeByProperty<TableParam>(info);
                    if (null == tableParam) {
                        continue;
                    }
                    if (!nameList.Contains(tableParam.param)) {
                        if (sb.Length > 0) {
                            sb.Append(", ");
                        }
                        sb.Append(tableParam.param).Append(" ").Append(tableParam.type);
                        if (tableParam.isKey) {
                            sb.Append(" PRIMARY KEY AUTOINCREMENT");
                        }
                    }
                }
                if (sb.Length > 0) {
                    sb.Insert(0, $"ALTER TABLE {tableName} ADD COLUMN ");
                    SqlLiteHelper.ExecuteNonQuery(sb.ToString(), null);
                }
            }
        }

        /// <summary>
        /// 插入数据并返回ID
        /// </summary>
        /// <param name="t"></param>
        /// <returns></returns>
        public long Insert(T t) {