companyentitydao.cs

毕业设计时做的,一个管理关于污染管理的, 源代码,呵呵 想想当时还真厉害,可以实现污染检测

using System;
using System.Data;
using SystemFramework;
using SystemFramework.EntityDAO;
using SystemFramework.Data;
using SystemFramework.DataAccess;

namespace itcrm.EntityDAO
{
	/// <summary>
	/// 公司实体数据操作类
	/// </summary>
	public class CompanyEntityDAO:IEntityDAO
	{
		/// <summary>
		/// 数据库操作对象
		/// </summary>
		private DBOperator m_dbOper;

		public CompanyEntityDAO(DBOperator dbOper)
		{
			this.m_dbOper=dbOper;
		}

		public CompanyEntityDAO()
		{
			this.m_dbOper=DBOperator.Instance();
			m_dbOper.Open();
		}

		/// <summary>
		/// 插入实体数据
		/// </summary>
		/// <param name="entity">实体数据</param>
		public void InsertEntity(EntityData entity)
		{
			m_dbOper.BeginTrans();
			try
			{
				//插入表内容
				foreach(DataRow row in entity.Tables["Company"].Rows)
					m_dbOper.exeSql(row,SqlManager.GetSql("Company","InsertEntity"));

				m_dbOper.CommitTrans();
			}
			catch(Exception e)
			{
				m_dbOper.RollbackTrans();
				throw e;
			}
		}
		
		/// <summary>
		/// 删除实体数据
		/// </summary>
		/// <param name="entity">实体数据</param>
		public void DeleteEntity(EntityData entity)
		{
			m_dbOper.BeginTrans();
			try
			{
				foreach(DataRow row in entity.Tables["Company"].Rows)
					m_dbOper.exeSql(row,SqlManager.GetSql("Company","DeleteEntity"));
				m_dbOper.CommitTrans();
			}
			catch(Exception e)
			{
				m_dbOper.RollbackTrans();
				throw e;
			}
		}

		/// <summary>
		/// 删除实体数据
		/// </summary>
		/// <param name="row">实体数据</param>
		public void DeleteEntity(DataRow row)
		{
			m_dbOper.BeginTrans();
			try
			{
				m_dbOper.exeSql(row,SqlManager.GetSql("Company","DeleteEntity"));
				m_dbOper.CommitTrans();
			}
			catch(Exception e)
			{
				m_dbOper.RollbackTrans();
				throw e;
			}
		}

		/// <summary>
		/// 根据关键值查找实体数据
		/// </summary>
		/// <param name="objKeyValue">关键值</param>
		/// <returns>EntityData:实体数据</returns>
		public EntityData FindByKey(object objKeyValue)
		{
			EntityData entity=new EntityData("Company");
			SQL sql=SqlManager.GetSql("Company","FindByKey");
			m_dbOper.FillEntity(sql.Sql,sql.ParamNames[0],objKeyValue,entity,"Company");
			return entity;
		}

		/// <summary>
		/// 更新实体数据
		/// </summary>
		/// <param name="entity">实体数据</param>
		public void UpdateEntity(EntityData entity)
		{
			m_dbOper.BeginTrans();
			try
			{
				//更新表内容
				foreach(DataRow row in entity.Tables["Company"].Rows)
					if(row.RowState!=DataRowState.Unchanged)
						m_dbOper.exeSql(row,SqlManager.GetSql("Company","UpdateEntity"));
				m_dbOper.CommitTrans();
			}
			catch(Exception e)
			{
				m_dbOper.RollbackTrans();
				throw e;
			}
		}
		

		/// <summary>
		/// 根据用户信息(用户类型为员工)，取得该员工所在的公司信息
		/// </summary>
		/// <param name="user">登录用户的ID</param>
		/// <returns>DataSet:公司信息</returns>
		public DataSet GetEntityByUser(string user)
		{
			
			SQL sql=SqlManager.GetSql("Company","GetEntityByUser");
			return m_dbOper.exeSqlForDataSet(sql.Sql,sql.ParamNames[0],user);
			
		}
		
		/// <summary>
		/// 根据类型和KEY取得树信息
		/// </summary>
		/// <param name="type">类型</param>
		/// <param name="key">key</param>
		/// <returns>DataSet:树信息</returns>
		public DataSet GetTreeByKey(int type,object key)
		{
			DataSet ds=null;
			object[] objValues={type,key};
			SQL sql=SqlManager.GetSql("Company","GetTreeByKey");
			ds= m_dbOper.exeSqlForDataSet(sql.Sql,sql.ParamNames,objValues);
			return ds;

		}

		public void Dispose()
		{
			Dispose(true);
			GC.SuppressFinalize(true);
		}

		protected virtual void Dispose(bool disposing)
		{
			if (!disposing)
				return;
			m_dbOper.Close();
		}
	}
}