PSI.DAL/BQuery.cs

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

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

using PSI.Common;
using PSI.DbUtility;
using PSI.Models.UIModels;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace PSI.DAL
{
        public class BQuery<T>
        {
                #region 查询
                /// <summary>
                /// 按条件查询获取实体信息
                /// </summary>
                /// <param name="strWhere"></param>
                /// <param name="strCols"></param>
                /// <param name="paras"></param>
                /// <returns></returns>
                public T GetModel(string strWhere, string strCols, params SqlParameter[] paras)
                {
                        //生成查询语句
                        string selSql = CreateSql.CreateSelectSql<T>(strWhere, strCols);
                        //生成Reader对象
                        SqlDataReader reader = SqlHelper.ExecuteReader(selSql, 1, paras);
                        //转换为实体对象
                        T model = DbConvert.SqlDataReaderToModel<T>(reader, strCols);
                        //关闭阅读器
                        reader.Close();
                        return model;
                }

                /// <summary>
                /// 根据Id获取信息实体
                /// </summary>
                /// <param name="id"></param>
                /// <param name="strCols"></param>
                /// <returns></returns>
                public T GetById(int id, string strCols)
                {
                        Type type = typeof(T);
                        //构建条件
                        string strWhere = $"[{type.GetPrimary()}]=@Id";
                        SqlParameter[] paras = { new SqlParameter("@Id", id) };
                        return GetModel(strWhere, strCols, paras);
                }

                /// <summary>
                /// 根据条件判断存在
                /// </summary>
                /// <param name="strWhere"></param>
                /// <param name="paras"></param>
                /// <returns>true or false</returns>
                public bool Exists(string strWhere, params SqlParameter[] paras)
                {