OPC.UA.DAL/DALBase.cs

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

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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using OPC.UA.Model;
using System.Reflection;
using System.Data;
using System.Data.SqlClient;

namespace OPC.UA.DAL
{
    public class DALBase<T>where T:ModelBase
    {
        public static int Insert(T info)
        {
            //获取info对象实际的类型（不是ModelBase类型，而是传递进来的实体类类型）
            Type type = info.GetType();
            //表名-->类名
            string name = type.Name;
            StringBuilder sb1 = new StringBuilder();
            StringBuilder sb2 = new StringBuilder();
            //创建参数集合
            SqlManager manager = new SqlManager();
            PropertyInfo[] pinfos = type.GetProperties();
            foreach (PropertyInfo item in pinfos)
            {
                if (item.GetCustomAttributes(typeof(ColumnAttribute), true).Length == 0)
                {
                    continue;
                }
                object value = item.GetValue(info, null);
                if (value != null)
                {
                    string colName = item.Name;
                    sb1.Append(colName + ",");
                    sb2.Append("@" + colName + ",");
                    manager.Add("@" + colName, value);
                }
            }
            if (manager.Count == 0)
            {
                throw new Exception("没有数据要添加，无法操作");
            }
            //删除拼接过程中多产生的一个逗号
            sb1.Remove(sb1.Length - 1, 1);
            sb2.Remove(sb2.Length - 1, 1);
            string sql = string.Format("insert into {0}({1}) values({2})",name,sb1.ToString(),sb2.ToString());
            manager.SqlText = sql;
            return SqlHelp.CUD(manager);
        }

        public static int InsertReturnID(T info)
        {
            //获取info对象实际的类型（不是ModelBase类型，而是传递进来的实体类类型）
            Type type = info.GetType();
            //表名-->类名
            string name = type.Name;
            StringBuilder sb1 = new StringBuilder();
            StringBuilder sb2 = new StringBuilder();
            //创建参数集合