Abp.NHibernate连接PostgreSQl数据库的方法

using System.Reflection;

using Abp.Configuration.Startup;

using Abp.Modules;

using Abp.NHibernate;

using FluentNHibernate.Cfg.Db;

/**

* 命名空间: abpPgtest

* 功 能： 配置数据库

* 类 名： NhHibernateModel

* 作 者: 东腾

* 时 间： 2018/1/29 17:04:27

*/

namespace abpPgtest

{

   [DependsOn( typeof (AbpNHibernateModule))]

   public class NhHibernateModel:AbpModule

   {

     //重写PreInitialize方法

     public override void PreInitialize()

     {

       var pgStr = "Server=localhost;Port=5432;Database=DTDB;User Id=DT;Password=DT" ;

       var config = Configuration.Modules.AbpNHibernate().FluentConfiguration

         .Database(PostgreSQLConfiguration.Standard.ConnectionString(pgStr));

       config.Mappings(a => a.FluentMappings.AddFromAssembly(Assembly.GetEntryAssembly()));

       //base.PreInitialize();

     }

     //重写Initialize方法

     public override void Initialize()

     {

       IocManager.RegisterAssemblyByConvention(Assembly.GetCallingAssembly());

       // base.Initialize();

     }

   }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using Abp.Domain.Entities;

using Abp.NHibernate.EntityMappings;

/**

* 命名空间: abpPgtest.testModel

* 功 能： 数据库表实体及映射

* 类 名： testModel

* 作 者: 东腾

* 时 间： 2018/1/29 17:21:19

*/

namespace abpPgtest.testModel

{

   public class testModelMap : EntityMap<testModel>

   {

     public testModelMap(): base ( "dt_tb_test" )

     {

       //Id(x => x.Id).GeneratedBy.Increment();//数据库表中没有自增的Id时需要映射一个Id

       Map(x => x.Company);

       Map(x => x.Name);

       //References<userModel>(a => a.Id).Not.LazyLoad().Column("外键ID");//数据库中有关联表时使用

     }

   }

   public class testModel:Entity< int >

   {

     public virtual int Id { get ; set ; }

     public virtual string Name { get ; set ; }

     public virtual string Company { get ; set ; }

   }

}

var bootstrapper = AbpBootstrapper.Create<NhHibernateModel>();

bootstrapper.Initialize();

var resp = bootstrapper.IocManager.Resolve<IRepository<testModel>>();

//添加数据

   var model = new testModel

     {

      Name = "东腾" ,

      Company = "东腾科技"

     };

  resp.Insert(model);

//更新数据

   var m = resp.Get(1);

   m.Name = "东腾1" ;

   resp.Update(m);

var allList = resp.GetAllList();

//删除数据,更具where条件删除

   Expression<Func<testModel, bool >> where = a =>a.Id==3;

   resp.Delete(where);