实战揭秘：开发.Net平台应用系统框架

public class Product
		{
	string ProductID;
	string ProductName;
	float Account;	
}

public interface IClassBuilder
		{
	EntityData BuildClass(string strClassName);	//获取类数据结构
	SqlStruct GetSqlStruct(string strClassName,string strSqlName);
	}

EntityData entity=EntityDataManager.GetEmptyEntity("Product");

public EntityData BuildClass(string strClassName)
		{
			IClassBuilder 
builder=ClassBuilderFactory.GetClassBuilder(strClassName);
				return builder.BuildClass(strClassName);
	}

<?xml version="1.0" encoding="gb2312" ?>
<Builders>
		<Class Name="ProductType" 
BuilderName="Jobsinfo.SingleTableClassBuilder" />	
</Builders>

public interface IEntityDAO : IDisposable
	{
		void InsertEntity(EntityData entity);
		void UpdateEntity(EntityData entity);
		void DeleteEntity(EntityData entity);
        EntityData FindByPrimaryKey(object strKeyValue);
	}

public class ProductEntityDAO: IEntityDAO
{
	private DBCommon db;  //这是数据库访问的类
	public ProductEntityDAO()
	{
		db=new DBCommon();
		db.Open();
		}
		public ProductEntityDAO(DBCommon cdb)
		{
			this.db=cdb;
		}
		// 插入一个实体
		public void InsertEntity(EntityData entity)
		{
			CheckData(entity);
			db.BeginTrans();
			try
			{
				foreach(DataRow row in 
entity.Tables["Product"].Rows)
db.exeSql(row,SqlManager.GetSqlStruct("Product","InsertProduct"));
				db.CommitTrans();
			}
			catch(Exception e)
			{
				db.RollbackTrans();
				throw e;
			}
		}
	 
	 //修改一个实体类
	 public void UpdateEntity(EntityData entity)
		{
			CheckData(entity);
			db.BeginTrans();
			try
			{
				foreach(DataRow row in 
entity.Tables["Product"].Rows)
					if(row.RowState!=DataRowState.Unchanged)
db.exeSql(row,SqlManager.GetSqlStruct("Product","UpdateProduct"));
				db.CommitTrans();
			}
			catch(Exception e)
			{
				db.RollbackTrans();
				throw e;
			}
		}
	 	//删除一个实体类
		public void DeleteEntity(EntityData entity)
		{
			CheckData(entity);
			db.BeginTrans();
			try
			{
				foreach(DataRow row in 
entity.Tables["Product"].Rows)
db.exeSql(row,SqlManager.GetSqlStruct("Product","DeleteProduct"));
				db.CommitTrans();
			}
			catch(Exception e)
			{
				db.RollbackTrans();
				throw e;
			}
		}		
	 	//查找实体类
		public EntityData FindByPrimaryKey(object KeyValue)
		{
			EntityData entity=new EntityData("Product");
			SqlStruct 
sqlProduct=SqlManager.GetSqlStruct("Product","SelectByIDProduct");
db.FillEntity(sqlProduct.SqlString,sqlProduct.ParamsList[0],
KeyValue,entity,"Product");
		return entity;
		}
		public EntityData FindAllProduct()
		{
			EntityData entity=new EntityData("Product");
			SqlStruct 
sqlProduct=SqlManager.GetSqlStruct("Product","FindAllProduct");
db.FillEntity(sqlProduct.SqlString,null,null,entity,"Product");
			return entity;
		}
		// 校验数据数据输入的有效性
		private void CheckData(EntityData entity)
		{
if(entity.Tables["Product"].Rows[0]["ProductID"].ToString().Length>40)
				throw new ErrorClassPropertyException
("Property ProductID should be less than 40 characters");
		}
		public void Dispose()
		{
			Dispose(true);
			GC.SuppressFinalize(true);
		}
		protected virtual void Dispose(bool disposing)
		{
			if (! disposing)
			return; // we're being collected, 
			so let theGC take care of this object
			db.Close();
		}
}

public void StoreIntoWarehouse(EntityData IndepotForm)
	{
		DataTable tbl=IndepotForm.Tables["InDepotFormDetail"];
		try
		{
			ProductEntityDAO ped=new ProductEntityDAO();
			for(int i=0;i<tbl.Rows.Count;i++)
			{
				DataRow formdetail=tbl.Rows[i];
				string productID=formdetail["ProductID"].ToString();
					decimal
inCount=(decimal)formdetail["InCount"];
		EntityData product=ped.FindByPrimaryKey(productID);
			DataRow productRow=product.GetRecord("Product");
productRow["CurrentCount"]=(decimal)productRow["CurrentCount"]+inCount;
				ped.UpdateEntity(product);
				}
				ped.Dispose();
				InDepotFormEntityDAO inDepotForm=new 
InDepotFormEntityDAO();
				inDepotForm.InsertEntity(IndepotForm);
				IndepotForm.Dispose();
				ContextUtil.SetComplete();
			}
			catch(Exception ee)
			{
				ContextUtil.SetAbort();
				throw ee;
			}
		}