Xiezn.Core/Business/DB/DbContext.cs

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

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

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Xiezn.Core.Common.Helpers;
using Xiezn.Core.Models.ConfModel;

namespace Xiezn.Core.Business.DB
{
    public class DbContext<T> where T : class, new()
    {
        public DbContext()
        {
            DbConfig dbConfig = ConfigHelper.GetConfig<DbConfig>("DbConfig");

            Db = new SqlSugarClient(new ConnectionConfig()
            {
                ConnectionString = dbConfig.ConnectionString,
                DbType = dbConfig.DbType.ToLower() == "mysql" ? DbType.MySql : DbType.SqlServer,
                InitKeyType = InitKeyType.Attribute,
                IsAutoCloseConnection = true,

            });

            Db.Aop.OnLogExecuting = (sql, pars) =>
            {
                // Console.WriteLine(sql + "\r\n" +
                    // Db.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
                // Console.WriteLine();
            };
        }

        public SqlSugarClient Db;
        public SimpleClient<T> CurrentDb { get { return new SimpleClient<T>(Db); } }

        public dynamic Common(string tableName, string columnName, string columnValue = "", int type = 0, string sign = "option", int remindStart = 0, int remindEnd = 0)
        {
            sign = sign.ToLower();
            string sql = "";
            dynamic res = null;
            switch (sign)
            {
                case "option":
                    string where = "";
                    if (type == 1)
                    {
                        where = " WHERE level = " + type;
                    }

                    if (type > 1)
                    {
                        where = " WHERE level = " + type + " AND parent = " + columnValue;
                    }
                    sql = "SELECT " + columnName + " FROM " + tableName + where;
                    res = Db.Ado.SqlQuery<string>(sql).ToList();
                    break;

                case "follow":
                    sql = "SELECT * FROM " + tableName +" WHERE " + columnName + " = '" + columnValue + "'";