leaseinfoservice.cs~rf197ba0d.tmp

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

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

namespace DiscSystemDAL.SqlServer
{
    public class LeaseInfoService:ILeaseInfoService
    {
        private static string connStr = ConfigurationManager.ConnectionStrings["Sql"].ConnectionString;
        #region ILeaseInfoService 成员

        public List<LeaseInfo> SelectLeaseInfo(object obj)
        {
            List<LeaseInfo> list = new List<LeaseInfo>();
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = "proc_select_LeaseInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@where",SqlDbType.VarChar,50).Value = obj;
                using (SqlDataReader dr=cmd.ExecuteReader())
                {
                    while (dr.Read())
                    {
                        LeaseInfo li = new LeaseInfo();
                        li.LeaseID = (int)dr["LeaseID"];
                        li.MemberName = (string)dr["MemberName"];
                        li.DiscName = (string)dr["DiscName"];
                        li.LeaseDate = (DateTime)dr["LeaseDate"];
                        li.ReturnDate = (DateTime)dr["ReturnDate"];
                        list.Add(li);
                    }
                }

            }
            return list;
        }

        public int InsertLeaseInfo(LeaseInfo lease)
        {
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = "proc_insert_LeaseInfo";
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@MemberName", SqlDbType.VarChar, 20).Value = lease.MemberName;
                cmd.Parameters.Add("@DiscName", SqlDbType.VarChar, 30).Value = lease.DiscName;
                check = cmd.ExecuteNonQuery();
            }
            return check;
        }

        public int UpdateLeaseInfo(LeaseInfo lease)
        {
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = "proc_update_LeaseInfo";
                SqlCommand cmd = new SqlCommand(cmdStr,conn);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.Parameters.Add("@LeaseID", SqlDbType.Int).Value = lease.LeaseID;
                check = cmd.ExecuteNonQuery();
            }
            
            return check;
        }

        public int DeleteLeaseInfo(int LeaseID)
        {
            int check = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                string cmdStr = string.Format("delete from LeaseInfo where LeaseID = {0}",LeaseID);
                SqlCommand cmd = new SqlCommand(cmdStr, conn);
                check = cmd.ExecuteNonQuery();
            }
            return check;
        }

        #endregion
    }
}