recommendaccessor.cs

本系统是基于三层架构和Ajax控件结合的酒店预订系统

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using DBaoBookingManagement.Entity;

namespace DBaoBookingManagement.DataAccess
{
    public class RecommendAccessor:DataAccessor
    {
        //查询所有推荐人
        public DataTable QueryAll()
        {
            string sql = "select * from Recommend";
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("查询所有推荐人时出现错误：" + ex.Message);
            }
        }

        //根据ID查询推荐人
        public DataTable QueryById(int id)
        {
            string sql = "select * from Recommend where RecId="+id;
            try
            {
                return base.Query(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据ID查询推荐人时出现错误：" + ex.Message);
            }
        }

        //根据ID删除推荐人
        public bool DeleteById(int id)
        {
            string sql = "delete Recommend where RecId=" + id;
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("根据ID删除推荐人时出现错误：" + ex.Message);
            }
        }

        //插入推荐人
        public bool Insert(Recommend entity)
        {
            string recName = entity.RecName;
            string sql = "insert into Recommend(RecName) values('" + recName + "')";
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("插入推荐人时出现错误：" + ex.Message);
            }
        }

        //修改推荐人
        public bool Update(Recommend entity)
        {
            int id = entity.RecId;
            string recName = entity.RecName;
            string sql = "update Recommend set RecName='" + recName + "' where RecId="+id;
            try
            {
                return base.ExecuteSqlNoneQuery(sql);
            }
            catch (Exception ex)
            {
                throw new Exception("修改推荐人时出现错误：" + ex.Message);
            }
        }
    }
}