providerdaoimpl.cs

一个超市管理系统,没有错误,非常好,里面什么都有!很使用,很有用

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using DaFanRongMIS.Model.Common;

namespace DaFanRongMIS.Model.Provider
{
   public class ProviderDAOImpl : ProviderDAO
    {
        #region 增加
        public string AddProvider(ProviderEntity Provider) 
        {
            string str="";

            //声明并设置SqlCommand命令

            SqlCommand cmdadd = new SqlCommand();
            cmdadd.Connection=ConnectionDataBase.getConOpen();
            cmdadd.CommandType = CommandType.StoredProcedure;
            cmdadd.CommandText = "Add_Provider";
            //结束声明和设置SqlCommand命令


            //参数赋值

            SqlParameter IDAdd = new SqlParameter("@ID", SqlDbType.VarChar, 2);
            IDAdd.Value = Provider.ID;
            cmdadd.Parameters.Add(IDAdd);

            SqlParameter NameAdd = new SqlParameter("@Name", SqlDbType.VarChar, 20);
            NameAdd.Value = Provider.Name;
            cmdadd.Parameters.Add(NameAdd);

            SqlParameter LinkmanAdd = new SqlParameter("@Linkman", SqlDbType.VarChar, 20);
            LinkmanAdd.Value = Provider.Linkman;
            cmdadd.Parameters.Add(LinkmanAdd);

            SqlParameter PhoneAdd = new SqlParameter("@Phone", SqlDbType.VarChar, 20);
            PhoneAdd.Value = Provider.Phone;
            cmdadd.Parameters.Add(PhoneAdd);

            SqlParameter MobileAdd = new SqlParameter("@Mobile", SqlDbType.VarChar, 14);
            MobileAdd.Value = Provider.Mobile;
            cmdadd.Parameters.Add(MobileAdd);

            SqlParameter AddressAdd = new SqlParameter("@Address", SqlDbType.VarChar, 100);
            AddressAdd.Value = Provider.Address;
            cmdadd.Parameters.Add(AddressAdd);

            SqlParameter PostalCodeAdd = new SqlParameter("@PostalCode", SqlDbType.VarChar,6);
            PostalCodeAdd.Value = Provider.PostalCode;
            cmdadd.Parameters.Add(PostalCodeAdd);

            SqlParameter FaxAdd = new SqlParameter("@Fax", SqlDbType.VarChar, 13);
            FaxAdd.Value = Provider.Fax;
            cmdadd.Parameters.Add(FaxAdd);

            SqlParameter EMailAdd = new SqlParameter("@EMail", SqlDbType.VarChar, 50);
            EMailAdd.Value = Provider.EMail;
            cmdadd.Parameters.Add(EMailAdd);

            SqlParameter MemoAdd = new SqlParameter("@Memo", SqlDbType.VarChar, 2000);
            MemoAdd.Value = Provider.Memo;
            cmdadd.Parameters.Add(MemoAdd);
            //结束参数赋值

            //打开库,执行,关闭库
            try
            {

                cmdadd.Connection = Common.ConnectionDataBase.getConOpen();

                cmdadd.ExecuteNonQuery();
                str = "OK";

            }
            catch (Exception ee)
            {
                str = ee.Message;
            }
            finally
            {
                Common.ConnectionDataBase.getConClose();
            }
            //结束打开库,执行,关闭库
            return str;
            
        }
      
        #endregion

        #region 删除 

       public string DeleteProvider(ProviderEntity Provider)
        {
            string str = "";

            //声明并设置SqlCommand命令

            SqlCommand cmdDel = new SqlCommand();
            cmdDel.Connection = Common.ConnectionDataBase.getConOpen();
            cmdDel.CommandType = CommandType.StoredProcedure;
            cmdDel.CommandText = "Delete_Provider";

            //结束声明和设置SqlCommand命令


            //参数赋值
            SqlParameter IDDel = new SqlParameter("@ID", SqlDbType.VarChar, 2);
            IDDel.Value = Provider.ID;
            cmdDel.Parameters.Add(IDDel);
            //结束参数赋值

            //打开库,执行,关闭库
            try
            {
                cmdDel.Connection = Common.ConnectionDataBase.getConOpen();
                cmdDel.ExecuteNonQuery();
                str = "OK";
            }
            catch (Exception ee)
            {
                str = ee.Message;
            }
            finally
            {
                Common.ConnectionDataBase.getConClose();
            }
            //结束打开库,执行,关闭库
            return str;
        }
        #endregion

        #region 修改

       public string UpdateProvider(ProviderEntity Provider)
        {
            string str = "";

            //声明并设置SqlCommand命令

            SqlCommand cmdUpdate= new SqlCommand();
            cmdUpdate.Connection = ConnectionDataBase.getConOpen();
            cmdUpdate.CommandType = CommandType.StoredProcedure;
            cmdUpdate.CommandText = "Update_Provider";
            //结束声明和设置SqlCommand命令


            //参数赋值
            SqlParameter IDUpdate = new SqlParameter("@ID", SqlDbType.VarChar, 2);
            IDUpdate.Value = Provider.ID;
            cmdUpdate.Parameters.Add(IDUpdate);

            SqlParameter NameUpdate = new SqlParameter("@Name", SqlDbType.VarChar, 20);
            NameUpdate.Value = Provider.Name;
            cmdUpdate.Parameters.Add(NameUpdate);

            SqlParameter LinkmanUpdate = new SqlParameter("@Linkman", SqlDbType.VarChar, 20);
            LinkmanUpdate.Value = Provider.Linkman;
            cmdUpdate.Parameters.Add(LinkmanUpdate);

            SqlParameter PhoneUpdate = new SqlParameter("@Phone", SqlDbType.VarChar, 20);
            PhoneUpdate.Value = Provider.Phone;
            cmdUpdate.Parameters.Add(PhoneUpdate);

            SqlParameter MobileUpdate = new SqlParameter("@Mobile", SqlDbType.VarChar, 14);
            MobileUpdate.Value = Provider.Mobile;
            cmdUpdate.Parameters.Add(MobileUpdate);

            SqlParameter AddressUpdate = new SqlParameter("@Address", SqlDbType.VarChar, 100);
            AddressUpdate.Value = Provider.Address;
            cmdUpdate.Parameters.Add(AddressUpdate);

            SqlParameter PostalCodeUpdate = new SqlParameter("@PostalCode", SqlDbType.VarChar, 6);
            PostalCodeUpdate.Value = Provider.PostalCode;
            cmdUpdate.Parameters.Add(PostalCodeUpdate);

            SqlParameter FaxUpdate = new SqlParameter("@Fax", SqlDbType.VarChar, 13);
            FaxUpdate.Value = Provider.Fax;
            cmdUpdate.Parameters.Add(FaxUpdate);

            SqlParameter EMailUpdate = new SqlParameter("@EMail", SqlDbType.VarChar, 50);
            EMailUpdate.Value = Provider.EMail;
            cmdUpdate.Parameters.Add(EMailUpdate);

            SqlParameter MemoUpdate = new SqlParameter("@Memo", SqlDbType.VarChar, 2000);
            MemoUpdate.Value = Provider.Memo;
            cmdUpdate.Parameters.Add(MemoUpdate);
            //结束参数赋值

            //打开库,执行,关闭库
            try
            {

                cmdUpdate.Connection = Common.ConnectionDataBase.getConOpen();

                cmdUpdate.ExecuteNonQuery();
                str = "OK";

            }
            catch (Exception ee)
            {
                str = ee.Message;
            }
            finally
            {
                Common.ConnectionDataBase.getConClose();
            }
            //结束打开库,执行,关闭库
            return str;
        }
        #endregion

        #region 查找(无条件)
        public DataTable SelectProvider(ProviderEntity Provider)
        {
            SqlDataAdapter da = new SqlDataAdapter();
            DataSet ds = new DataSet();
            DataTable dt = new DataTable();
            SqlCommand cmd = new SqlCommand();
            cmd.CommandType = CommandType.StoredProcedure;
            cmd.CommandText = "Select_Provider";
            cmd.Connection = Common.ConnectionDataBase.getConOpen();
            da.SelectCommand = cmd;
            da.Fill(ds);
            dt = ds.Tables[0];
            return dt;
        }
        #endregion

        #region 查找(有条件)
       public DataTable SelectedProvider(ProviderEntity Provider)
       {
           SqlDataAdapter da = new SqlDataAdapter();
           DataSet ds = new DataSet();
           DataTable dt = new DataTable();
           SqlCommand cmdSelect = new SqlCommand();
           cmdSelect.CommandType = CommandType.StoredProcedure;
           cmdSelect.CommandText = "Selected_Provider";
           cmdSelect.Connection = Common.ConnectionDataBase.getConOpen();

           string str = "";
                    
           //参数赋值
     

           SqlParameter IDSelect = new SqlParameter("@ID", SqlDbType.VarChar, 3);
           IDSelect.Value = Provider.ID;
           cmdSelect.Parameters.Add(IDSelect);

           SqlParameter NameSelect = new SqlParameter("@Name", SqlDbType.VarChar, 20);
           NameSelect.Value = Provider.Name;
           cmdSelect.Parameters.Add(NameSelect);

           SqlParameter LinkmanSelect = new SqlParameter("@Linkman", SqlDbType.VarChar, 20);
           LinkmanSelect.Value = Provider.Linkman;
           cmdSelect.Parameters.Add(LinkmanSelect);

           SqlParameter PhoneSelect = new SqlParameter("@Phone", SqlDbType.VarChar, 20);
           PhoneSelect.Value = Provider.Phone;
           cmdSelect.Parameters.Add(PhoneSelect);

           SqlParameter MobileSelect = new SqlParameter("@Mobile", SqlDbType.VarChar, 14);
           MobileSelect.Value = Provider.Mobile;
           cmdSelect.Parameters.Add(MobileSelect);

           SqlParameter AddressSelect = new SqlParameter("@Address", SqlDbType.VarChar, 100);
           AddressSelect.Value = Provider.Address;
           cmdSelect.Parameters.Add(AddressSelect);

           SqlParameter PostalCodeSelect = new SqlParameter("@PostalCode", SqlDbType.VarChar, 6);
           PostalCodeSelect.Value = Provider.PostalCode;
           cmdSelect.Parameters.Add(PostalCodeSelect);

           SqlParameter FaxSelect = new SqlParameter("@Fax", SqlDbType.VarChar, 13);
           FaxSelect.Value = Provider.Fax;
           cmdSelect.Parameters.Add(FaxSelect);

           SqlParameter EMailSelect = new SqlParameter("@EMail", SqlDbType.VarChar, 50);
           EMailSelect.Value = Provider.EMail;
           cmdSelect.Parameters.Add(EMailSelect);

           SqlParameter MemoSelect = new SqlParameter("@Memo", SqlDbType.VarChar, 2000);
           MemoSelect.Value = Provider.Memo;
           cmdSelect.Parameters.Add(MemoSelect);
           //结束参数赋值

           da.SelectCommand = cmdSelect;
           da.Fill(ds);
           dt = ds.Tables[0];
           return dt;
       }

       #endregion

    }
}