首页 > 数据库> 文章详细

java mongodb orm 实现-基于mongodb-driver开发的ORM

2021-11-28 18:04:25 阅读：159 来源： 互联网

标签：java BuildPo mongodb void private 索引 ORM MongoManager public

导论：
MongoDB是一个非常有前途的数据库，MongoDB官方对自己的定位是通用数据库，其实这个定位跟MySQL有些像。虽其流行度还远未达到MySQL的水平，但笔者有个可能不恰当的比较，MongoDB就像N年前的MySQL，随着时间的推移，会变得越来越强大，也会越来越流行。

由于基于mongo 官方提供的api使用比较复杂，不方便与业务开发，所以本项目基于官方api进行封装，简化了关于文档的查询，创建以及索引维护。

m-db

English 简体中文

简介

这是个什么？

欢迎使用本项目。

本项目基于mongodb-driver封装开发，极大简化了原生API，使得开发人员专注业务本身。项目采用注解风格模式，简化了类似xml这样的配置。

主要功能

1：简单文档映射
2：内嵌文档映射
3：异步存储。批量存储
4：索引管理

主要功能	是否支持	是否异步
读操作	是	否
写操作	是	是
批量读	是	否
批量写	是	是
索引维护	是	否

使用说明

索引管理

一、索引维护

通过注解@Indexed 和@CompoundIndexed 实现简单索引和联合索引的自动创建与维护，简化mongodb 索引的使用和维护

/**
* 联合索引：多个字段组合索引构成
*
*/
@Inherited
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE})
public @interface CompoundIndexed {

  Indexed[] value();

  int order() default -1;

  boolean unique() default true;
}

/**
* 普通索引：为某个字段建立索引
*/
@Target({ElementType.ANNOTATION_TYPE, ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
public @interface Indexed {

  boolean unique() default false;

  String name();

  int order() default -1;
}

/**
* 失效时间索引：本document 具有时效性
*/
@Target({ElementType.ANNOTATION_TYPE, ElementType.FIELD})
@Retention(RetentionPolicy.RUNTIME)
public @interface ExpireIndex {

  boolean unique() default false;

  String name() default "";

  int order() default -1;
}

详细使用见IndexTest中，当给每个document 的po类上或字段标记索引时，则索引会进行创建。

创建索引

二、简单文档使用

简单文档：文档结构简单，字段类型基本为基础数据类型字段。
使用步骤：

2.1 :组装实体类PO对象

/**
 * 一个简单文档
 */
@MongoDocument(table = "user_build")
@CompoundIndexed(value = {@Indexed(name = "uid"), @Indexed(name = "build_id")})
public class BuildPo extends AbstractMongoPo {

    @MongoId(name = "uid")
    private long uid;
    @MongoId(name = "build_id", tick = true)
    @BsonProperty("build_id")
    private long buildId;
    private int x;
    private int y;
    private String type;
    private String name;

其中通过注解@MongoDocument 数据库名字，指定表名，注解@CompoundIndex 指定用那几个字段作为联合索引
也可以用@Indexed 来单独指定索引,使用@MongoId来指定主键，由于mongodb无法实现类似mysql自增，索引采用此注解来来是否指定主键自增

2.2 添加数据

  public static void addBuild() throws MException {
        BuildPo buildPo = new BuildPo();
        buildPo.setY(6);
        buildPo.setX(7);
        buildPo.setUid(1);
        buildPo.setName("北京SOHO大厦");
        buildPo.setType("高端建筑");
        MongoManager.getInstance().add(buildPo);
    }

2.3 批量添加

    private static void addManyBuild() throws MException {
        List<BuildPo> list = new ArrayList<>();
        for (int i = 0; i < 100; i++) {
            BuildPo po = new BuildPo();
            po.setUid(2049);
            po.setX(i);
            po.setY(i);
            list.add(po);
        }
        MongoManager.getInstance().addMany(list);
    }

例如添加之后的数据在mongodb中可以查询到

2.4 查询

查询方式可分为两种，一种是利用@mongoID注解的主键进行查询，一种是通过某个字段进行find 查询


/**
    * 主键查询
    */
   public static void get() throws MException {
       BuildPo b = MongoManager.getInstance().get(BuildPo.class, PrimaryKey.builder("uid", 1), PrimaryKey.builder("build_id", 7));
       System.out.println(b.getBuildId());
   }

   public static void getAll() throws MException {
       List<BuildPo> bs = MongoManager.getInstance().getAll(BuildPo.class, PrimaryKey.builder("uid", 1));
       System.out.println("getAll size=" + bs.size());
   }

 public static void findOne() throws MException {
       BuildPo b = MongoManager.getInstance().findOne(BuildPo.class, Query.builder().and("uid", 1).and("build_id", 7));
       System.out.println(b.getX() + "|" + b.getY());

   }

   public static void findAll() throws MException {
       List<BuildPo> bs = MongoManager.getInstance().findAll(BuildPo.class, Query.builder().and("uid", 1).and("y", 6), QueryOptions.builder().limit(100));
       System.out.println("findAll size=" + bs.size());

   }

2.5 修改

修改一个文档中的某个字段，使用方式如下，例如将查询出来的build 名字进行修改


    public static void update() throws MException {
        BuildPo b = MongoManager.getInstance().get(BuildPo.class, PrimaryKey.builder("uid", 1), PrimaryKey.builder("build_id", 2));
        b.setName("new name build");
        MongoManager.getInstance().update(b);
    }

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-qB7M58hV-1638093207578)(https://github.com/twjitm/m-db-test/blob/main/images/update.jpg?raw=true)]

三、异步：写改

系统支持异步操作。将操作封装为一个task，添加到异步队列中，数据库执行线程会从队列中取得操作任务。

3.1 开启异步操作

 private static void init() {
        mongoManager = new MongoManager("127.0.0.1:27017", true);
    }

3.2 异步操作原理


 private void execute() {
        if (pool.isEmpty()) {
            return;
        }
        pool.forEach((k, v) -> collectionManager.getCollection(k).bulkWrite(v));
        pool.clear();
    }

最后

源码地址

感谢大家对本项目的支持，要是发现有不好的地方，欢迎提交issues。欢迎star

标签：java,BuildPo,mongodb,void,private,索引,ORM,MongoManager,public
来源： https://blog.csdn.net/baidu_23086307/article/details/121594863

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9