unitdaoimpl.cs

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

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

namespace DaFanRongMIS.Model.Unit
{
   public  class UnitDAOImpl:UnitDAO
   {
       #region 增加
       public string AddUnit(UnitEntity unit)
       {
           UnitEntity ue = new UnitEntity();
           UnitDAO ud = new UnitDAOImpl();
           string str = "";
           try
           {
               //创建命令对象
               string sql = "insert into unit values (@id,@name)";
               SqlCommand cmd = new SqlCommand(sql, ConnectionDataBase.getConOpen());
               //设置命令对象参数
               SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 2);
               parid.Value = unit.Id;
               cmd.Parameters.Add(parid);

               SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 20);
               parname.Value = unit.Name;
               cmd.Parameters.Add(parname);
               //执行命令对象
               cmd.ExecuteNonQuery();
               str = "ok";
           }
           catch (Exception ee)
           {
               str = ee.Message;
           }
           finally
           {
               ConnectionDataBase.getConClose();
           }
           return str;
       }
       #endregion

       #region 删除
       public string DeleteUnit(string id)
       {
           UnitEntity ue = new UnitEntity();
           UnitDAO ud = new UnitDAOImpl();
           string str = "";
           try
           {
               string sql = "delete from unit where id=@id";
               //创建命令对象
               SqlCommand cmd = new SqlCommand(sql, ConnectionDataBase.getConOpen());
               //设置命令对象参数
               SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 2);
               parid.Value = id;
               cmd.Parameters.Add(parid);

               cmd.ExecuteNonQuery();
               str = "ok";
           }
           catch (Exception ee)
           {
               str = ee.Message;
           }
           finally
           {
               ConnectionDataBase.getConClose();
           }
           return str;
       }
       #endregion

       #region 按编号查询
       public DataTable SelectLikeID(string id)
       {

           //声明数据适配器
           SqlDataAdapter da = new SqlDataAdapter();
           //声明数据集
           DataSet ds = new DataSet();
           //声明数据表
           DataTable dt = new DataTable();
           //创建命令对象
           da.SelectCommand = new SqlCommand();
           da.SelectCommand.Connection = ConnectionDataBase.getConOpen();
           da.SelectCommand.CommandText = "select *from unit where id=@id";
           SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 5);
           parid.Value = id;
           da.SelectCommand.Parameters.Add(parid);
           da.Fill(ds);
           dt = ds.Tables[0];
           ConnectionDataBase.getConClose();
           return dt;
       }
       #endregion

       #region 按名称查询
       public DataTable SelectLike(string name)
       {

           //声明数据适配器
           SqlDataAdapter da = new SqlDataAdapter();
           //声明数据集
           DataSet ds = new DataSet();
           //声明数据表
           DataTable dt = new DataTable();
           //创建命令对象
           da.SelectCommand = new SqlCommand();
           da.SelectCommand.Connection = ConnectionDataBase.getConOpen();
           da.SelectCommand.CommandText = "select *from unit where name=@name";
           SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 20);
           parname.Value = name;
           da.SelectCommand.Parameters.Add(parname);
           da.Fill(ds);
           dt = ds.Tables[0];
           ConnectionDataBase.getConClose();
           return dt;

       }
       #endregion

       #region 按编号和名称查询
       public DataTable SelectLikeIDName(string id, string name)
       {
           //声明数据适配器
           SqlDataAdapter da = new SqlDataAdapter();
           //声明数据集
           DataSet ds = new DataSet();
           //声明数据表
           DataTable dt = new DataTable();
           //创建命令对象
           da.SelectCommand = new SqlCommand();
           da.SelectCommand.Connection = ConnectionDataBase.getConOpen();
           da.SelectCommand.CommandText = "select *from unit where name=@name and id=@id";
           SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 20);
           parname.Value = name;
           da.SelectCommand.Parameters.Add(parname);
           SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 5);
           parid.Value = id;
           da.SelectCommand.Parameters.Add(parid);
           da.Fill(ds);
           dt = ds.Tables[0];
           ConnectionDataBase.getConClose();
           return dt;
       }
       #endregion

       #region 全查询
       public DataTable Select()
       {
           DataSet ds = new DataSet();
           DataTable dt = new DataTable();
           SqlDataAdapter da = new SqlDataAdapter();
           //创建命令对象
           da.SelectCommand = new SqlCommand();
           //设置命令对象参数
           da.SelectCommand.Connection =  ConnectionDataBase.getConOpen();
           da.SelectCommand.CommandText = "select * from unit";
           //用dataadapter的fill方法把数据添加到ds中
           da.Fill(ds);
           //将ds的datables的方法用dt接收
           dt = ds.Tables[0];
           return dt;
       }
       #endregion

       #region 删除的时候查下编号
       public void SelectId()
       {
           string sql = "select count (*) from unit where id=@id";
           //创建命令对象
           SqlCommand cmd = new SqlCommand(sql,  ConnectionDataBase.getConOpen ());
           cmd.ExecuteScalar();
           ConnectionDataBase.getConClose();
       }
       #endregion

       public string UpdataUnit(UnitEntity unit)
       {
           UnitEntity ue = new UnitEntity();
           UnitDAO ud = new UnitDAOImpl();
           string str = "";
           try
           {
               //创建命令对象
               string sql = "update  unit set name=@name where id=@id";
               SqlCommand cmd = new SqlCommand(sql,  ConnectionDataBase.getConOpen ());
               //设置命令对象参数
               SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 2);
               parid.Value = unit.Id;
               cmd.Parameters.Add(parid);

               SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 20);
               parname.Value = unit.Name;
               cmd.Parameters.Add(parname);
               //执行命令对象
               cmd.ExecuteNonQuery();
               str = "ok";
           }
           catch (Exception ee)
           {
               str = ee.Message;
           }
           finally
           {
                ConnectionDataBase.getConClose ();
           }
           return str;
       }

       #region 无条件查询计量单位名称，用于材料模块、产品模块
       public DataTable SelectUnit()
       {
           SqlCommand cmd = null;
           //数据表类型变量，用于接收满足查询条件的结果
           DataTable dt;
           try
           {
               //声明适配器对象da
               SqlDataAdapter da = new SqlDataAdapter();
               //定义数据集对象ds
               DataSet ds = new DataSet();

               //使用参数方式查询
               cmd = new SqlCommand("select distinct name from Unit ", ConnectionDataBase.getConOpen());


               //指定适配器属性SelectCommand，与命令对象绑定
               da.SelectCommand = cmd;

               //将查询结果到数据集中，以表的形式存在
               da.Fill(ds, "Unit");

               //得到这张表的记录，返回给变量dt
               dt = ds.Tables["Unit"];


           }
           catch (Exception ee)
           {
               dt = null;
           }
           finally
           {
               ConnectionDataBase.getConClose();
           }
           return dt;

       }
       #endregion

       #region 按计量单位名称查询名称和编号，用于材料模块、产品模块
       public DataTable SelectUnitbyName(string name)
       {
           SqlCommand cmd = null;
           //数据表类型变量，用于接收满足查询条件的结果
           DataTable dt;
           try
           {
               //声明适配器对象da
               SqlDataAdapter da = new SqlDataAdapter();
               //定义数据集对象ds
               DataSet ds = new DataSet();

               //使用参数方式查询
               cmd = new SqlCommand("select name as '计量单位名称',id as '计量单位编号' from Unit where name = @name ", ConnectionDataBase.getConOpen());

               //指定参数列表

               SqlParameter paraname = new SqlParameter("@name", SqlDbType.VarChar, 21);
               paraname.Value = name;
               cmd.Parameters.Add(paraname);


               //指定适配器属性SelectCommand，与命令对象绑定
               da.SelectCommand = cmd;

               //将查询结果到数据集中，以表的形式存在
               da.Fill(ds, "Unit");

               //得到这张表的记录，返回给变量dt
               dt = ds.Tables["Unit"];


           }
           catch (Exception ee)
           {
               dt = null;
           }
           finally
           {
               ConnectionDataBase.getConClose();
           }
           return dt;

       }
       #endregion
   }
}