discinfoservice.cs~rf2be8edb.tmp

个人版音像管理系统,可以扩展,内含数据库,支持多数据库使用

using System;
using System.Collections.Generic;
using System.Text;
using DiscSystemModel;
using DiscSystemIDAL;
using System.Data.SqlClient;
using System.Configuration;
using System.Data;


namespace DiscSystemDAL.SqlServer
{
    public class DiscInfoService:IDiscInfoService
    {
        private static string connStr = ConfigurationManager.ConnectionStrings["Sql"].ConnectionString;

        #region IDiscInfoService 成员

        public List<DiscInfo> SelectDiscInfo(object obj)
        {
            List<DiscInfo> discList = new List<DiscInfo>();
            using (SqlConnection conn=new SqlConnection(connStr))
            {
                string cmdStr = "proc_select_DiscInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@where", SqlDbType.VarChar, 50).Value = obj;
                conn.Open();
                using (SqlDataReader dr= cmd.ExecuteReader())
                {
                    while (dr.Read())
                    {
                        DiscInfo disc = new DiscInfo();
                        disc.DiscID = (int)dr["discID"];
                        disc.DiscName = (string)dr["discName"];
                        disc.Author = (string)dr["Author"];
                        disc.Director = (string)dr["Director"];
                        disc.SimpleInfo = (string)dr["SimpleInfo"];
                        disc.DiscTP = (string)dr["DiscTP"];
                        if ((int)dr["DiscState"] == 1)
                        {
                            disc.DiscState = "存货";
                        }
                        else
                        {
                            disc.DiscState = "租出";
                        }
                        discList.Add(disc);
                    }
                }
                
            }
            return discList;
        }

        public int InsertDiscInfo(DiscInfo disc)
        {
            int check = 0;
            using (SqlConnection conn=new SqlConnection(connStr))
            {
                string cmdStr = "proc_insert_DiscInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@DiscName", SqlDbType.VarChar, 20).Value = disc.DiscName;
                cmd.Parameters.Add("@Author", SqlDbType.VarChar, 20).Value = disc.Author;
                cmd.Parameters.Add("@Director", SqlDbType.VarChar, 20).Value = disc.Director;
                cmd.Parameters.Add("@SimpleInfo", SqlDbType.VarChar, 200).Value = disc.SimpleInfo;
                cmd.Parameters.Add("@TypeName", SqlDbType.VarChar, 20).Value = disc.DiscTP;
                conn.Open();
                check = cmd.ExecuteNonQuery();

            }
            return check;
        }

        public int UpdateDiscInfo(DiscInfo disc)
        {
            int state = 0;
            if (disc.DiscState == "存货")
            {
                state = 1;
            }
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = "";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                conn.Open();
                check = cmd.ExecuteNonQuery();

            }
            return check;
        }

        public int DeleteDiscInfo(int discID)
        {
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = string.Format("delete from DiscInfo where DiscID = {0}",discID);
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                conn.Open();
                check = cmd.ExecuteNonQuery();

            }
            return check;
        }

        #endregion
    }
}