.netcore2.0+pgsql 脚手架

mystaging介绍

• 这是一个 .netcore+pgsql 的脚手架，可以一键生成实体对象和业务层接口，让开发人员无需关注底层变动，专注编写业务代码，它可以让你使用 .netcore2.0的新特性，基于 pgsql 数据库，可以在项目中自由的使用 lambda 表达式编写业务，同时支持自定义的 sql 语句。

特性

• mystaging，非常的小巧，下面将介绍 mystaging 的项目框架。
• 一键生成，无需编写实体模型代码
• 支持数据库枚举类型自动映射生成
• 支持视图自动生成实体模型和业务操作接口
• 该项目目前处于起步阶段，可能不适用于大型项目，请结合业务需要酌情使用
• 项目 gitbhub 地址：https://github.com/lianggx/mystaging
• 开发交流QQ群：614072957

---

如何开始？

使用构建工具 MyStaging.App

1. 将 MyStaging.csproj 项目打包成 MyStaging.zip ，并复制到 MyStaging.App/bin/debug 目录下
2. 编辑构建工具下的 @build.bat 文件,配置相关参数，参数配置见参数说明
3. 运行该批处理文件，可以直接生成 proj.db 项目文件

参数说明

• -h host，数据库所在服务器地址
• -p port,端口号
• -u username，登录数据库账号名称
• -a password，登录密码
• -d database，数据库名称
• -pool pool,数据库连接池最大值，默认 32
• -proj csproj,生成的 db 层项目名称
• -o output path，生成项目的输出路径

初始化数据库连接

• 在生成的 db 项目文件根目录下，找到： _startup.cs 文件，在程序入口 Program.cs 或者 Startup.cs 的适当位置，使用以下代码，传递日志记录对象和数据库连接字符串进行 db 层初始化

 string connectionString = "Host=127.0.0.1;Port=5432;Username=postgres;Password=123456;Database=your db;Pooling=true;Maximum Pool Size=100";
 ILogger logger = loggerFactory.CreateLogger<MyStaging.Helpers.PgSqlHelper>();
 _startup.Init(logger, connectionString);

---

实体对象说明
构建工具会自动生成DAL层，包含实体模型和对象关系，由于执行数据库查询的过程中，高度依赖实体模型映射，所以在生成实体模型时，对实体做了一些ORM的映射设置，这些设置对实体模型的影响非常小。

• EntityMappingAttribute
  该特性类接受一个属性：TableName，指明该实体模型映射到数据库中的>模式.表名，如

   ```
   [EntityMapping(TableName = "public.user")]
   public partial class Public_userModel
   {
   }
   ```
  

• ForeignKeyMappingAttribute
  应用该该特性类到属性上，表示这个是一个外键引用的属性，如

    ```
    private Public_userModel _public_User=null;
    [ForeignKeyMapping,JsonIgnore]public Public_userModel Public_User { get{ if(_public_User==null)_public_User= Public_user.Context.Where(f=>f.Id==this.User_id).ToOne();  return _public_User;} }
    ```
    *以上代码还应用了特性：JsonIgnore ，表示，该外键在对象进行 json 序列化的时候选择忽略该属性*
  

• NonDbColumnMappingAttribute
  应用该该特性类到属性上，表示这个是一个自定义的属性，在进行数据库查询的时候将忽略该属性，如

   ```
   [NonDbColumnMappingAttribute,JsonIgnore] public  Public_user.UpdateBuilder UpdateBuilder{get{return new Public_user.UpdateBuilder(this.Id);}}
   ```
  

以上代码还应用了特性：JsonIgnore ，表示，该外键在对象进行 json 序列化的时候选择忽略该属性

MyStaging 命名空间

• MyStaging.Common 主要定义公共类型和资源
• MyStaging.Helpers 数据库操作帮助类、连接池管理工具类、DAL操作辅助函数
• MyStaging.Mapping 动态对象生成管理、实体对象映射定义

MyStaging.Helpers.QueryContext
DAL继承的基类，该类实现了所有对数据库操作的封装，可直接继承使用，如果使用脚手架附带的构建工具，直接进行业务编写即可

---

数据库操作

• 插入记录

    Public_userModel user = new Public_userModel();
    user.Id = Guid.NewGuid();
    user.Login_name = "test@gmail.com";
    Public_user.Insert(user);

• 修改记录

    // 自动根据主键修改
    Public_userModel user = new Public_userModel();
    user.UpdateBuilder.SetLogin_time(DateTime.Now).SaveChange(); 

    // 自定义条件修改
    user.UpdateBuilder.SetLogin_time(DateTime.Now).Where(f => f.Sex == true).SaveChange();

    // 直接修改
    Public_user.Update(Guid.Empty).SetLogin_time(DateTime.Now).Where(f => f.Sex == true).SaveChange();

    // 自定义条件的直接修改
    Public_user.UpdateBuilder.SetLogin_time(DateTime.Now).Where(f => f.Id == Guid.Empty).Where(f => f.Sex == true).SaveChange();

• 删除记录

    // 根据主键删除
    Public_user.Delete(Guid.Empty);
    // 根据条件删除
    Public_user.DeleteBuilder.Where(f => f.Id == Guid.Empty).Where(f => f.Sex == true).SaveChange();

• 查询单条记录

    Public_userModel user = Public_user.Context.Where(f => f.Login_name == "test@gmail.com").ToOne();

• 指定查询列

    Public_userModel user = Public_user.Context.Where(f => f.Login_name == "test@gmail.com").ToOne("id","login_name");

• 指定查询返回类型

    public class UserModel{
        public string Login_name{get;set;}
        public Guid Id{get;set;}
    }
    Public_userModel user = Public_user.Context.Where(f => f.Login_name == "test@gmail.com").ToOne<UserModel>("id","login_name");

• 查询列表

    List<Public_userModel> list = Public_user.Context.ToList();
    List<Public_userModel> list = Public_user.Context.Where(f => f.Login_name == "test@gmail.com").ToList();    

    public class UserModel{
        public string Login_name{get;set;}
        public Guid Id{get;set;}
    }

    List<UserModel> list = Public_user.Context.ToList<UserModel>("id","login_name");

• 表连接查询

    public class UserModel{
        public string Login_name{get;set;}
        public Guid Id{get;set;}
    }

    List<UserModel> list = Public_user.Context.Union<TopicModel>("b",UnionType.INNER_JOIN,(a,b)=>a.Id==b.User_Id).Where(a=>a.Id=Guid.Empty).Where<TopicModel>(b=>b.Publish==true).ToList<UserModel>("id","login_name");

• 分页

    Public_user.Context.Where(f => f.Login_name == "test@gmail.com").OrderBy(f=>f.State).Page(1,10);

• 排序

    Public_user.Context.Where(f => f.Login_name == "test@gmail.com").OrderBy(f=>f.State);
    Public_user.Context.Where(f => f.Login_name == "test@gmail.com").OrderDescing(f=>f.State);

• 聚合查询

    Public_user.Context.Where(f => f.Login_name == "test@gmail.com").Avg(f=>f.Age);
    Public_user.Context.Where(f => f.Login_name == "test@gmail.com").Sum(f=>f.Blance);
    // Max,Min,GroupBy,Having

• 事务

     PgSqlHelper.Transaction(() =>
        {
            Public_userModel user= Public_user.Context.Where(f => f.Login_name == "test@gmail.com").ToOne();
            user.UpdateBuilder.SetLogin_time(DateTime.Now).SaveChange();
        });