SuLei.DAL/sl_article_goods_spec.cs

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

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

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Reflection;
using System.Text;
using SuLei.DBUtility;
using SuLei.Common;

namespace SuLei.DAL
{
    /// <summary>
    /// 商品对应规格
    /// </summary>
    public partial class sl_article_goods_spec
    {
        private string databaseprefix;//数据库表名前缀
        public sl_article_goods_spec(string _databaseprefix)
        {
            databaseprefix = _databaseprefix;
        }

        #region 基本方法================================
        /// <summary>
        /// 增加一条数据，带事务
        /// </summary>
        public int Add(SqlConnection conn, SqlTransaction trans, Model.sl_article_goods_spec model, int channel_id, int article_id)
        {
            StringBuilder strSql = new StringBuilder();
            StringBuilder str1 = new StringBuilder();//数据字段
            StringBuilder str2 = new StringBuilder();//数据参数
            //利用反射获得属性的所有公共属性
            PropertyInfo[] pros = model.GetType().GetProperties();
            List<SqlParameter> paras = new List<SqlParameter>();
            strSql.Append("insert into " + databaseprefix + "article_goods_spec(");
            foreach (PropertyInfo pi in pros)
            {
                //判断属性值是否为空
                if (pi.GetValue(model, null) != null)
                {
                    str1.Append(pi.Name + ",");//拼接字段
                    str2.Append("@" + pi.Name + ",");//声明参数
                    switch (pi.Name)
                    {
                        case "channel_id":
                            paras.Add(new SqlParameter("@" + pi.Name, channel_id));
                            break;
                        case "article_id":
                            paras.Add(new SqlParameter("@" + pi.Name, article_id));
                            break;
                        default:
                            paras.Add(new SqlParameter("@" + pi.Name, pi.GetValue(model, null)));//对参数赋值
                            break;
                    }
                }
            }
            strSql.Append(str1.ToString().Trim(','));
            strSql.Append(") values (");
            strSql.Append(str2.ToString().Trim(','));
            strSql.Append(") ");