SpringBoot 集成 Spring Data Mongodb 操作 MongoDB

## 快速开始
基础用法：http://www.mydlq.club/article/85/
示例项目：https://github.com/my-dlq/blog-example/tree/master/springboot/springboot-mongodb-example
官方文档：https://www.mongodb.com/docs/manual/
CURD 
https://docs.mongoing.com/mongodb-crud-operations
中文翻译4.2版： https://mongodb.net.cn/
与简单的SQL对照：https://coldsmog.cn/project-4/doc-190/

## 使用样例
### 查询全部
```
Query query = new Query();
mongoTemplate.find(query, entityClass, tableName);
```
### 查询指定列
```
Query query = new Query();
query.fields().include("name");
mongoTemplate.find(query, entityClass, tableName);
```

### 查询
```
Query andQuery = Query.query(
	Criteria.where("name").is("小明")
		.and("eventReadTimeList.type").is(types)
);
Query orQuery = Query.query(
    // or语法
	new Criteria().orOperator(
		Criteria.where("name").is("小明"),
		// name.old=[], 查询数组曾用名
		Criteria.where("name.$.old").in("秀儿"),
		// name.show 字段不存在
		Criteria.where("name.show").exists(false)
	)
);
mongoTemplate.find(orQuery, EntityClass.class, tableName);
```

### 批量put
```
List<T> dataList = new ArrayList<>()；
List<Pair<Query, Update>> updateList = new ArrayList<>(dataList.size());
BulkOperations operations = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, collectionName);
dataList.forEach(data -> {
  Query query = new Query(new 
  Criteria(field1).is(value1)).addCriteria(new Criteria(field2).is(value2));
  Update update = new Update();
  for (int index = 0; index < dataList.size(); index++) {
    String key = data.getKey();
    String value = data.getValue();
 　 update.set(key, value);
  }
  Pair<Query, Update> updatePair = Pair.of(query, update);
  updateList.add(updatePair);
});
operations.upsert(updateList);
BulkWriteResult result = operations.execute();
```

### 内嵌数组实例
```
Update update = new Update();
update.set("eventReadTimeList.$.type", types);
update.set("eventReadTimeList.$.date", new Date());
Query query = Query.query(new Criteria().andOperator(Criteria.where("tenantId").is(tenantId),
	Criteria.where("userId").is(userId),
	Criteria.where("eventReadTimeList.type").is(types)));
mongoTemplate.updateFirst(query, update, EventRead.class,collectionName);
```
https://blog.csdn.net/sinat_38259539/article/details/84765843

### 字段重命名与BigDecimal类型转换
```
@Ducoument(value = "tableName")
public class NodeData{

// 注意使用mongodb的注解
	@Field(value="rate", target=Field.Decimal128)
	private BigDecimal rate;
}
```

### 插入时间和修改时间自动生成
```
// 启动类加上注解@EnableMongoAuditing
@Data
public class BaseMongoObject {

// 坑：自己设id， 创建时被认为是更新，没有创建时间
    @Id
    private String id;

@CreatedDate
    private Long createdAt;

@LastModifiedDate
    private Long updatedAt;
}
```
https://blog.csdn.net/weixin_40852944/article/details/125905996

### 数据分片
```
# 准备数据
db.createCollection("orders");
db.orders.insert([
    { "_id": 1, "customerId": "customer1", "amount": 100, "age": 18 },
    { "_id": 2, "customerId": "customer2", "amount": 200, "age": 64 },
    // ...其他文档
]);
# 创建启用分片集合, 若不指定则是 _id 为key分片
sh.shardCollection("orders", { "age": 1 });

# 按标签分片
sh.addShardTag('orders01', 'junior')
sh.addShardTag('orders02', 'middle')
sh.addShardTag('orders03', 'senior')
sh.addTagRange('orders', {'age': MinKey}, {'age':20}, 'junior')
sh.addTagRange('orders', {'age': 21}, {'age':40}, 'middle')
sh.addTagRange('orders', {'age': 41}, {'age': MaxKey}, 'senior')

# 查询时，将先按查询条件分标签，再查标签对应数据
db.orders.aggregate([
    {
        $match: { "age": {$in: [30， 40] } }
    },
    // ...其他聚合阶段
]);
```
注意需要使用 [mongos](https://mongodb.net.cn/manual/reference/program/mongos/#bin.mongos) 进行分片命令的查询
https://mongodb.net.cn/manual/reference/method/js-sharding/