导论:
MongoDB是一个非常有前途的数据库,MongoDB官方对自己的定位是通用数据库,其实这个定位跟MySQL有些像。虽其流行度还远未达到MySQL的水平,但笔者有个可能不恰当的比较,MongoDB就像N年前的MySQL,随着时间的推移,会变得越来越强大,也会越来越流行。
由于基于mongo 官方提供的api使用比较复杂,不方便与业务开发,所以本项目基于官方api进行封装,简化了关于文档的查询,创建以及索引维护。
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类上或字段标记索引时,则索引会进行创建。
简单文档:文档结构简单,字段类型基本为基础数据类型字段。
使用步骤:
/** * 一个简单文档 */ @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自增,索引采用此注解来来是否指定主键自增
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); }
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中可以查询到
查询方式可分为两种,一种是利用@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()); }
修改一个文档中的某个字段,使用方式如下,例如将查询出来的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,添加到异步队列中,数据库执行线程会从队列中取得操作任务。
private static void init() { mongoManager = new MongoManager("127.0.0.1:27017", true); }
private void execute() { if (pool.isEmpty()) { return; } pool.forEach((k, v) -> collectionManager.getCollection(k).bulkWrite(v)); pool.clear(); }
源码地址
感谢大家对本项目的支持,要是发现有不好的地方,欢迎提交issues。欢迎star