Castle ActiveRecord学习实践(11)——ActiveRecordMediator

ActiveRecordMediator类也为实体类提供了持久化的方法（CRUD）,先来看看ActiveRecordMediator中的方法

ActiveRecordMediator类实现了很多常用的方法。包括 Create、Delete、FindOne、FindAll、FindByPrimaryKey、Save、SlicedFindAll、Update等。

基本操作

// Create
Customer c = new Customer();
c.Name = "Mr. Johnson";
c.Address = String.Empty;
ActiveRecordMediator<Customer>.Save(c);

// Read/Update
Customer loaded = ActiveRecordMediator<Customer>.FindOne(Expression.Eq("Name", "Mr. Johnson"));
loaded.Address = "Middle of the Road";
ActiveRecordMediator<Customer>.Save(loaded);

// Delete
ActiveRecordMediator<Customer>.Delete(c);

验证支持

// Entity
[ActiveRecord]
public class Customer
{
        private Guid id;

        [PrimaryKey(PrimaryKeyType.GuidComb)]
        public Guid Id
        {
                get { return id; }
                set { id = value; }
        }
        private string name;

        [Property(Unique=true,NotNull=true)]
        [ValidateNonEmpty]
        [ValidateIsUnique]
        public string Name
        {
                get { return name; }
                set { name = value; }
        }
        private string address;

        [Property(NotNull=true)]
        [ValidateNonEmpty]
        public string Address
        {
                get { return address; }
                set { address = value; }
        }
}

// using code
Customer c = new Customer();
c.Name = "Mr. Johnson";
c.Address = String.Empty;

IValidatorRunner runner =
        new ValidatorRunner(new CachedValidationRegistry());
if (runner.IsValid(c))
        ActiveRecordMediator<Customer>.Save(c);
else
        foreach (string msg in runner.GetErrorSummary(c).ErrorMessages)
                Console.WriteLine(msg);

利用ActiveRecordMediator类实现Repository模式

ActiveRecordMediator类提供了SlicedFindAll方法，可以用此方法处理数据分页。

首先创建IRepository接口

public interface IRepository<T>
{
    void Save(T item);
    void Remove(T item);
    T FindById(object id);
    T FindOne(params ICriterion[] criteria);
    IEnumerable<T> FindBy(params ICriterion[] criteria);
    IEnumerable<T> FindBy(out int count, params ICriterion[] criteria);
    IEnumerable<T> FindBy(int pageSize, int pageCount,NHibernate.Criterion.Order[] order,out int count, params ICriterion[] criteria);
}

接口中包含了基本的Create,Update,Delete,Find方法，还包含了给定条件查询单体，给定条件查询list

创建一个BaseRepository类

public class BaseRepository<T> : IRepository<T> where T : class
{
    protected ActiveRecordMediator<T> mediator;
    public virtual void Save(T item)
    {
        ActiveRecordMediator<T>.Save(item);
    }

    public virtual void Remove(T item)
    {
        ActiveRecordMediator<T>.Delete(item);
    }

    public virtual T FindById(object id)
    {
        return ActiveRecordMediator<T>.FindByPrimaryKey(id);
    }

    public virtual T FindOne(params NHibernate.Criterion.ICriterion[] criteria)
    {
        return ActiveRecordMediator<T>.FindOne(criteria);
    }

    public virtual IEnumerable<T> FindBy(params NHibernate.Criterion.ICriterion[] criteria)
    {
        return ActiveRecordMediator<T>.FindAll(criteria);
    }

    public virtual IEnumerable<T> FindBy(int pageSize, int pageCount, NHibernate.Criterion.Order[] order, out int count, params NHibernate.Criterion.ICriterion[] criteria)
    {
        int _Count = 0;
        _Count = ActiveRecordMediator<T>.FindAll(criteria).Count();
        count = _Count;
        return (IEnumerable<T>)ActiveRecordMediator<T>.SlicedFindAll(typeof(T), (pageSize - 1) * pageCount, pageCount, order, criteria);

    }


    public virtual IEnumerable<T> FindBy(out int count, params NHibernate.Criterion.ICriterion[] criteria)
    {
        int _Count = 0;
        _Count = ActiveRecordMediator<T>.FindAll(criteria).Count();
        count = _Count;
        return ActiveRecordMediator<T>.FindAll(criteria);
    }
}

创建Customer的资源库契约的具体实现类CustomerRepository

public class CustomerRepository : BaseRepository<Customer>
{
    public override void Save(Customer item)
    {
        base.Save(item);
    }
    public override void Remove(Customer item)
    {
        base.Remove(item);
    }
    public override Customer FindById(object id)
    {
        return base.FindById(id);
    }

    public override Customer FindOne(params NHibernate.Criterion.ICriterion[] criteria)
    {
        return base.FindOne(criteria);
    }
    public override IEnumerable<Customer> FindBy(params NHibernate.Criterion.ICriterion[] criteria)
    {
        return base.FindBy(criteria);
    }

    public override IEnumerable<Customer> FindBy(out int count, params NHibernate.Criterion.ICriterion[] criteria)
    {
        return base.FindBy(out count, criteria);
    }

    public override IEnumerable<Customer> FindBy(int pageSize, int pageCount, NHibernate.Criterion.Order[] order, out int count, params NHibernate.Criterion.ICriterion[] criteria)
    {
        return base.FindBy(pageSize, pageCount, order, out count, criteria);
    }
}

调用

int count=0;
var list1 = dal.FindBy(
                1,
                10,
                new[] { NHibernate.Criterion.Order.Desc("id") },
                out count, NHibernate.Criterion.Expression.Between("Age",20, 30));
foreach (var item in list1)
{
    Response.Write(item.Id+"</br>");
}