SuLei.DAL/sl_article_albums.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_albums
    {
        private string databaseprefix;//数据库表名前缀
        public sl_article_albums(string _databaseprefix)
        {
            databaseprefix = _databaseprefix;
        }

        #region 基本方法================================
        /// <summary>
        /// 增加一条数据
        /// </summary>
        public void Add(SqlConnection conn, SqlTransaction trans, List<Model.sl_article_albums> models, int channel_id, int article_id)
        {
            if (models != null)
            {
                StringBuilder strSql;
                StringBuilder str1; ;//数据字段
                StringBuilder str2;//数据参数
                foreach (Model.sl_article_albums modelt in models)
                {
                    strSql = new StringBuilder();
                    str1 = new StringBuilder();
                    str2 = new StringBuilder();
                    //利用反射获得属性的所有公共属性
                    PropertyInfo[] pros = modelt.GetType().GetProperties();
                    List<SqlParameter> paras = new List<SqlParameter>();
                    strSql.Append("insert into " + databaseprefix + "article_albums(");
                    foreach (PropertyInfo pi in pros)
                    {
                        //如果不是主键则追加sql字符串
                        if (!pi.Name.Equals("id"))
                        {
                            //判断属性值是否为空
                            if (pi.GetValue(modelt, 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));//刚插入的文章ID
                                        break;