bulletinaccessor.cs

新闻网站

using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.Data;
using Common;
using Common.Entities;


namespace DAL.Accessor
{
    public class BulletinAccessor
    {
        //添加公告
        public void Add(BulletinData bulletinData)
        {
            SqlParameter[] sqlParameters = {
					new SqlParameter("@BulletinTitle", SqlDbType.NVarChar),
					new SqlParameter("@BulletinBody", SqlDbType.NVarChar),
					new SqlParameter("@MemberName", SqlDbType.NVarChar)
					
					};
            sqlParameters[0].Value = bulletinData.BulletinTitle;
            sqlParameters[1].Value = bulletinData.BulletinBody;
            sqlParameters[2].Value = bulletinData.MemberName;         
            

            using (SqlConnection conn = new SqlConnection())
            {
                conn.ConnectionString = SqlHelper.ConnectionStringLocalTransaction;
                SqlHelper.ExecuteNonQuery(conn, CommandType.StoredProcedure, "Bulletin_ADD", sqlParameters);
            }

        }
        //修改公告
        public void Update(BulletinData bulletinData)
        {
            SqlParameter[] sqlParameters = {
					new SqlParameter("@BulletinTitle", SqlDbType.NVarChar),
					new SqlParameter("@BulletinBody", SqlDbType.NVarChar),
					new SqlParameter("@MemberName", SqlDbType.NVarChar),
				    new SqlParameter("@BulletinId",SqlDbType.Int)
					};
            sqlParameters[0].Value = bulletinData.BulletinTitle;
            sqlParameters[1].Value = bulletinData.BulletinBody;
            sqlParameters[2].Value = bulletinData.MemberName;
            sqlParameters[3].Value = bulletinData.BulletinId;
            using (SqlConnection conn = new SqlConnection())
            {
                conn.ConnectionString = SqlHelper.ConnectionStringLocalTransaction;
                SqlHelper.ExecuteNonQuery(conn, CommandType.StoredProcedure, "Bulletin_Update", sqlParameters);
            }
        }
        //返回公告列表
        public List<BulletinData> GetList()
        {
            List<BulletinData> list = new List<BulletinData>();
            SqlDataReader reader = SqlHelper.ExecuteReader(SqlHelper.ConnectionStringLocalTransaction, CommandType.StoredProcedure, "Bulletin_GetList", null);
            while (reader.Read())
            {
                BulletinData bulletinData = new BulletinData();
                bulletinData.BulletinId = int.Parse(reader["BulletinId"].ToString());
                bulletinData.BulletinTitle = reader["BulletinTitle"].ToString();
                bulletinData.AddDate = DateTime.Parse(reader["AddDate"].ToString());
                list.Add(bulletinData);
            }
            return list;
        }
        //查询一条公告
        public BulletinData GetModel(int id)
        {
            SqlParameter[] sqlParameters = {
					new SqlParameter("@BulletinId", SqlDbType.Int)						
					};
            sqlParameters[0].Value = id;
            SqlDataReader reader = SqlHelper.ExecuteReader(SqlHelper.ConnectionStringLocalTransaction, CommandType.StoredProcedure, "Bulletin_GetModel", sqlParameters);
            BulletinData bulletinData = new BulletinData();
            if (reader.Read())
            {
                bulletinData.BulletinId = int.Parse(reader["BulletinId"].ToString());
                bulletinData.BulletinTitle = reader["BulletinTitle"].ToString();
                bulletinData.BulletinBody = reader["BulletinBody"].ToString();
                bulletinData.MemberName = reader["MemberName"].ToString();              
               
            }
            return bulletinData;
        }
        //删除公告
        public void Delete(int id)
        {
            SqlParameter[] sqlParameters = { 
                new SqlParameter("@BulletinId",SqlDbType.Int)
            };
            sqlParameters[0].Value = id;
            using (SqlConnection conn = new SqlConnection())
            {
                conn.ConnectionString = SqlHelper.ConnectionStringLocalTransaction;
                SqlHelper.ExecuteNonQuery(conn, CommandType.StoredProcedure, "Bulletin_Delete", sqlParameters);
            }
        }
    }
}