namespace Test.DataAccess.FNhibernate
{
    public class DBContext
    {
        private static ISessionFactory _sessionFactory;
        private static ISessionFactory SessionFactory
        {
            get
            {
                if (_sessionFactory == null)
                {
                    InitializeSessionFactory();
                }
                return _sessionFactory;
            }
        }

        private static void InitializeSessionFactory()
        {
            string connectionString = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=10.1.1.1)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=orcl)));User Id=test;Password=test123;";
            var cfg = new DBConfiguration();
            _sessionFactory = Fluently.Configure().Database(
                  OracleClientConfiguration.Oracle10
                 .ConnectionString(connectionString)
                 .Provider<NHibernate.Connection.DriverConnectionProvider>()
                 .Driver<NHibernate.Driver.OracleClientDriver>()
                 )
                 .Mappings(m => m.AutoMappings.Add(AutoMap.AssemblyOf<PRODUCT>(cfg).Conventions.Setup(c =>
                 {
                     c.Add<PrimaryKeyConvention>();
                     c.Add<CascadeConvention>();
                 })))
                 .BuildSessionFactory();
        }

        public static ISession OpenSession()
        {
            return SessionFactory.OpenSession();
        }

        /// <summary>
        /// 这个暂时用，可能重复
        /// </summary>
        /// <returns></returns>
        public static long GenerateID()
        {
            long i = 1;

            foreach (byte b in Guid.NewGuid().ToByteArray())
            {
                i *= ((int)b + 1);
            }

            string number = String.Format("{0:d9}", (DateTime.Now.Ticks / 10) % 1000000000);

            return long.Parse(number);
        }
    }
}

namespace Test.DataAccess.FNhibernate.DB
{
    public class PRODUCT
    {
        public virtual int PRODUCT_ID { get; set; }
        public virtual string PRODUCT_NAME { get; set; }
    }
}

namespace Test.DataAccess.FNhibernate
{
    public class DBConfiguration : DefaultAutomappingConfiguration
    {
        public override bool ShouldMap(Type type)
        {
            return type.Namespace == "TEST.DataAccess.FNhibernate.DB";
        }
        public override bool IsId(Member member)
        {
            string className = member.DeclaringType.Name;
            if (member.Name == className + "_ID")
            {
                return true;
            }
            return false;
        }
    }
}

namespace HeLi.DataAccess.FNhibernate
{
    public class PrimaryKeyConvention : IIdConvention
    {
        public void Apply(IIdentityInstance instance)
        {
            var type = instance.EntityType;
            if (type.Name == typeof(PRODUCT).Name)
            {
                instance.GeneratedBy.Assigned();
            }
        }
    }
}

using (var session = DBContext.OpenSession())
            {
                using (var tran = session.BeginTransaction())
                {

                    var list = session.CreateCriteria(typeof(PRODUCT)).List<PRODUCT>();//取出整个表

                    var dbUser = session.QueryOver<PRODUCT>().Where(p => p.PORUDCTID = 1).SingleOrDefault();
                    if (dbUser != null)
                    {
                        dbUser.PRODUCT_NAME = "镜子";
                        session.SaveOrUpdate(dbUser);
                    }

                    var product = new PRODUCT();
                    product.PRODUCT_ID = DBContext.GenerateID();
                    product.PRODUCT_NAME = "盒子";
                    session.Save(product);
                    tran.Commit();

                }
            }