ORM，创建基于Grove的.NET应用程序(二)XML:namespace prefix = o ns = "urn:schemas-microsoft-com:Office:office" />

撰稿 林学鹏 to:cnlxp@msn.com">cnlxp@msn.com

在当前项目的Entitydb下添加CustomerDB类，该类负责对Customer的数据库操作，包括添加，删除，修改等操作。

  8)重复7，完成AddressDB类。

CustomerDB.cs

  using System;

  using webApp1.Entities;

  using Grove;

  using Grove.Dataobject;

  public class CustomerDB

  {

  public CustomerDB()

  {

  }

  public void Insert(Customer c)

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  oo.BeginTranscation();

  try

  {

  oo.InsertObject(c);

  oo.Commit();

  }

  catch(System.Exception e)

  {

  oo.Rollback();

  throw e;

  }

  oo.Dispose();

  }

  public void Delete(Customer c)

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  oo.BeginTranscation();

  try

  {

  oo.RemoveObject(c);

  oo.Commit();

  }

  catch(System.Exception e)

  {

  oo.Rollback();

  throw e;

  }

  oo.Dispose(); 

  }

  public void Update(Customer c)

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  oo.BeginTranscation();

  try

  {

  oo.UpdateObject(c);

  oo.Commit();

  }

  catch(System.Exception e)

  {

  oo.Rollback();

  throw e;

  }

  oo.Dispose(); 

  }

  public EntityData selectAll()

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  IObjectQuery oq=oo.NewQuery(typeof(Customer));

  EntityData customers=new EntityData();

  oq.Execute(customers);

  oo.Dispose();

  return customers;

  }

  }

AddressDB.cs

  using System;

  using WebApp1.Entities;

  using Grove;

  using Grove.DataObject;

  public class AddressDB

  {

  public AddressDB()

  {

  }

  public void Insert(Address a)

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  oo.BeginTranscation();

  try

  {

  oo.InsertObject(a);

  oo.Commit();

  }

  catch(System.Exception e)

  {

  oo.Rollback();

  throw e;

  }

  oo.Dispose();

  }

  public void Delete(Address a)

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  oo.BeginTranscation();

  try

  {

  oo.RemoveObject(a);

  oo.Commit();

  }

  catch(System.Exception e)

  {

  oo.Rollback();

  throw e;

  }

  oo.Dispose(); 

  }

  public void Update(Address a)

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  oo.BeginTranscation();

  try

  {

  oo.UpdateObject(a);

  oo.Commit();

  }

  catch(System.Exception e)

  {

  oo.Rollback();

  throw e;

  }

  oo.Dispose(); 

  }

  public EntityData SelectAll()

  {

  IObjectOperator oo=ObjectOperatorFactory.GetObjectOperator();

  IObjectQuery oq=oo.NewQuery(typeof(Address));

  EntityData addresses=new EntityData();

  oq.Execute(addresses);

  oo.Dispose();

  return addresses;

  }

  }

代码2.数据库类