<?xml version="1.0" encoding="utf-8" ?>
<hibernate-configuration xmlns="urn:nhibernate-configuration-2.2">
    <session-factory name="nHibernate.Test">
        <property name="connection.driver_class">NHibernate.Driver.SqlClientDriver</property>
        <property name="connection.connection_string">
            Server=.;initial catalog=Northwind;uid=sa;pwd=123456;Integrated Security=SSPI
        </property>
        <property name="dialect">NHibernate.Dialect.MsSql2008Dialect</property>
        <property name="show_sql">true</property>
        <mapping assembly="nHibernateTest"/>
    </session-factory>
</hibernate-configuration>

<?xml version="1.0" encoding="utf-8" ?>
<hibernate-mapping xmlns="urn:nhibernate-mapping-2.2" assembly="nHibernateTest" namespace="nHibernateTest.Entity">
    <class name="Customers" table="Customers">
        <id name="CustomerID" column="CustomerID" type="String">
            <generator class="assigned"/>
        </id>
        <property name="CompanyName" />
        <property name="ContactName" />
        <property name="ContactTitle" />
        <property name="Address" />
        <property name="City" />
        <property name="Region" />
        <property name="PostalCode" />
        <property name="Country" />
        <property name="Phone" />
        <property name="Fax" />
    </class>
</hibernate-mapping>

<!--Customers xml mapping  -->
<set name="Orders" generate="true">
     <key column="CustomerID" />
     <one-to-many class="Orders"/>
</set>
//Customers实体增加
//构造函数
public Customers()
{
       Orders=new HashSet<Orders>();
}
public virtual ISet<Orders> Orders{get;set;}

<!--Orders xml mapping-->
<many-to-one name="Customers" class="Customers" >
       <column name="CustomerID"/>
</many-to-one>
//Orders实体增加
public virtual Customers Customers{get;set;}

//多对多关系
<!--Customers xml mapping-->
<set  name="CustomerDemographics" table="CustomerCustomerDemo" schema="dbo" generic="true">
            <key  column="CustomerID" />
            <many-to-many class="CustomerDemographics" fetch="join" column="CustomerTypeID"/>
</set>
//Customers实体,构造函数相应增加实例化
public virtual ISet<CustomerDemographics> CustomerDemographics{get;set;}

<!--CustomerDemographics xml mapping-->
<set name="Customers" table="CustomerCustomerDemo" >
    <key column="CustomerTypeID"/>
    <many-to-many class="Customers" fetch="join" column="CustomerID"/>
</set>
//CustomerDemographics实体增加实例化
public virtual ISet<Customers> Customers{get;set;}

public interface IRepository<T, EntityKey> where T : IAggregateRoot
    {
         void Add(T entity);

         void Remove(T entity);

         void Save(T entity);

         T FindBy(EntityKey Id);

         IEnumerable<T> FindAll();

         IEnumerable<T> FindAll(int index, int pageSize, out int count);

         IEnumerable<T> FindBy(IList<ICriterion> queryList, Order order);

         IEnumerable<T> FindBy(IList<ICriterion> queryList,Order order, int index,int pageSize,out  int count);
    }
public abstract class Repository<T, EntityKey> : IRepository<T, EntityKey>
        where T : IAggregateRoot
    {
        private IUnitOfWork _uow;


        public Repository(IUnitOfWork uow)
        {
            _uow = uow;
        }

        public void Add(T entity)
        {
            _uow.RegisterNew(entity);
            //throw new NotImplementedException();
        }

        public void Remove(T entity)
        {
            _uow.RegisterRemoved(entity);
            //throw new NotImplementedException();
        }

        public void Save(T entity)
        {
            _uow.RegisterAmended(entity);
        }

        public T FindBy(EntityKey Id)
        {
            return _uow.Session.Get<T>(Id);
        }

        public IEnumerable<T> FindAll()
        {
            return (List<T>)_uow.Session.CreateCriteria(typeof(T)).List();
        }

        public IEnumerable<T> FindAll(int index, int pageSize, out int count)
        {
            ICriteria CriteriaQuery = _uow.Session.CreateCriteria(typeof(T));

            index=(index>=1?index:1);


            var countCirteria = CriteriaQuery.Clone() as ICriteria;

            var futureCount = countCirteria.SetProjection(Projections.RowCount()).FutureValue<Int32>();

            count = futureCount.Value;

            var queryList = CriteriaQuery.SetFirstResult((index-1)*pageSize).SetMaxResults(pageSize).List();



            return (List<T>)queryList;
        }

        public IEnumerable<T> FindBy(IList<ICriterion> queryList, Order order)
        {
            //Restrictions.Eq("Category.Id", 2) 进行添加查询数据
            ICriteria CriteriaQuery = _uow.Session.CreateCriteria(typeof(T));

            foreach (var queryItem in queryList)
            {
                CriteriaQuery.Add(queryItem);
            }

            return CriteriaQuery.AddOrder(order).List<T>();
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="queryList"></param>
        /// <param name="order"></param>
        /// <param name="index"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public IEnumerable<T> FindBy(IList<ICriterion> queryList, Order order, int index, int pageSize, out int count)
        {

            ICriteria CriteriaQuery = _uow.Session.CreateCriteria(typeof(T));

            foreach (var queryItem in queryList)
            {
                CriteriaQuery.Add(queryItem);
            }

            var listByQuery = CriteriaQuery;


            var countCrieriaQuery = CriteriaQuery.Clone() as ICriteria;

            var rowCount = countCrieriaQuery.SetProjection(Projections.RowCount()).FutureValue<Int32>();

            count = rowCount.Value;

            index = index >= 1 ? index : 1;

            return listByQuery.AddOrder(order).SetFirstResult((index - 1) * pageSize).SetMaxResults(pageSize).List<T>();
        }