materialdaoimpl.cs

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

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

namespace DaFanRongMIS.Model.Material
{
    public class MaterialDAOImpl:MaterialDAO 
    {
        #region 增加
        public string AddMateria(MaterialEntity materia)
        {
            string str = "";
            try
            {
                string sql = "insert into Material values(@id,@name,@unitid,@category,@memo)";
                //创建命令对象
                SqlCommand cmd = new SqlCommand(sql, ConnectionDataBase.getConOpen ());
                //设置命令对象参数
                SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 20);
                parid.Value = materia.Id;
                cmd.Parameters.Add(parid);

                SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 80);
                parname.Value = materia.Name;
                cmd.Parameters.Add(parname);

                SqlParameter parunitid = new SqlParameter("@unitid", SqlDbType.VarChar, 2);
                parunitid.Value = materia.Unitid;
                cmd.Parameters.Add(parunitid);

                SqlParameter parcategory = new SqlParameter("@category", SqlDbType.VarChar, 3);
                parcategory.Value = materia.Categoryid;
                cmd.Parameters.Add(parcategory);

                SqlParameter parmemo = new SqlParameter("@memo", SqlDbType.VarChar, 2000);
                parmemo.Value = materia.Memo;
                cmd.Parameters.Add(parmemo);
                //执行命令对象
                cmd.ExecuteNonQuery();
                str = "ok";
            }//end block try
            catch (Exception ee)
            {
                str = ee.Message;
            }//end block catch
            finally
            {
                //关闭数据库
                ConnectionDataBase.getConClose ();
            }//end block finally
            //返回值
            return str;
        }
        #endregion

        #region 修改
        public string UpdateMateria(MaterialEntity materia)
        {
            string str = "";
            try
            {
                string sql = "update Material set name=@name,unitid=@unitid,categoryid=@categoryid,memo=@memo where id=@id";
                //创建命令对象
                SqlCommand cmd = new SqlCommand(sql, ConnectionDataBase.getConOpen ());
                //设置命令对象参数
                SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 20);
                parid.Value = materia.Id;
                cmd.Parameters.Add(parid);

                SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 80);
                parname.Value = materia.Name;
                cmd.Parameters.Add(parname);

                SqlParameter parunitid = new SqlParameter("@unitid", SqlDbType.VarChar, 2);
                parunitid.Value = materia.Unitid;
                cmd.Parameters.Add(parunitid);

                SqlParameter parcategory = new SqlParameter("@categoryid", SqlDbType.VarChar, 3);
                parcategory.Value = materia.Categoryid;
                cmd.Parameters.Add(parcategory);

                SqlParameter parmemo = new SqlParameter("@memo", SqlDbType.VarChar, 2000);
                parmemo.Value = materia.Memo;
                cmd.Parameters.Add(parmemo);
                //执行命令对象
                cmd.ExecuteNonQuery();
                str = "ok";
            }// end block try
            catch (Exception ee)
            {
                str = ee.Message;
            }//end block catch
            finally
            {
                //关闭数据库
                ConnectionDataBase.getConClose ();
            }//end block finally
            //返回值
            return str;
        }
        #endregion

        #region 删除
        public string DeleteMateria(string id)
        {

            string str = "";
            try
            {
                string sql = "delete from Material where id=@id";
                //创建命令对象
                SqlCommand cmd = new SqlCommand(sql, ConnectionDataBase.getConOpen ());
                //设置命令对象参数
                SqlParameter parid = new SqlParameter("@id", SqlDbType.VarChar, 20);
                parid.Value = id;
                cmd.Parameters.Add(parid);
                //执行命令对象
                cmd.ExecuteNonQuery();
                str = "ok";
            }//end block try
            catch (Exception ee)
            {
                str = ee.Message;
            }//end block catch
            finally
            {
                //关闭数据库
                ConnectionDataBase.getConClose ();
            }//end block finally
            //返回值
            return str;
        }
        #endregion

        #region 按名称查询
        public DataTable SelectLike(string name)
        {
            //声明数据适配器
            SqlDataAdapter da = new SqlDataAdapter();
            //声明数据集
            DataSet ds = new DataSet();
            //声明数据表
            DataTable dt = new DataTable();
            da.SelectCommand = new SqlCommand("select * from Material where name like @name", ConnectionDataBase.getConOpen ());
            SqlParameter parname = new SqlParameter("@name", SqlDbType.VarChar, 20);
            parname.Value = "%" + name + "%";
            da.SelectCommand.Parameters.Add(parname);
            da.Fill(ds);
            dt = ds.Tables[0];
            return dt;
        }
        #endregion

        #region 全查询
        public DataTable Select()
        {
            //声明数据适配器
            SqlDataAdapter da = new SqlDataAdapter();
            //声明数据集
            DataSet ds = new DataSet();
            //声明数据表
            DataTable dt = new DataTable();
            da.SelectCommand = new SqlCommand("select * from Material", ConnectionDataBase.getConOpen ());
            da.Fill(ds);
            dt = ds.Tables[0];
            return dt;
        }
        #endregion
    }
}