使用Spring Data MongoDB指定分片集合

Question

我使用Spring Boot和Spring Data MongoDB与底层分片MongoDB集群进行接口。我的Spring Boot应用程序通过mongos路由器访问集群。

使用Spring Data MongoDB，可以通过@Document（collection=“nameOfCollection”）指定对象持久化到的集合，或者默认为类名（第一个字母小写）。这些藏品不需要预先存在；它们可以在运行时创建。

要在MongoDB中分片集合，您需要

1-在数据库上启用分片：sh.enableSharding（“myDb”）

2-在分片数据库上对集合进行分片：sh.shardCollection（“myDb.myCollection”，{id:“hashed”}）

假设有一个现有的分片数据库，Spring Data MongoDB是否提供了一种用分片密钥分片集合的方法？据我所知，我不能用Spring分片集合，因此必须在我的引导应用程序运行之前配置分片集合。我觉得很奇怪，Spring允许我使用未定义的集合，但没有提供配置集合的方法。

编辑：我已经看到了spring mongo的分片，以及如何在spring data for mongo中配置对分片集合的访问？这更多地涉及到分片MongoDB集群的部署。这个问题假设所有的管道都在那里，并且集合本身必须被切分。

Answer 1

在我们的更新查询中遇到了同样的问题，内部使用了保存（）。

怎么解决的？

所以我现在已经从spring boot starter 2.1中重写了spring data mongo核心依赖项。x乘以3。我们的模型中的x版本现在支持@Sharded（）注释。

<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-mongodb</artifactId>
<version>3.1.5</version>
</dependency>

允许你说

@Document(collection = "hotelsdevice")
@Sharded(shardKey = { "device" })

public class Hotel extends BaseModel {

现在，它内部能够分辨出潜在的mongo，也就是我们的shardkey。我假设这将进一步修复count（）查询，这些查询由于相同的错误“查询需要以碎片为目标”而失败

Answer 2

即使这不是一个Spring Data解决方案，一个潜在的解决方案是如何从java执行mongo admin命令，其中DB可以从SpringMongoTemboard获取。

DB db = mongo.getDB("admin");
DBObject cmd = new BasicDBObject();
cmd.put("shardcollection", "testDB.x");
cmd.put("key", new BasicDBObject("userId", 1));
CommandResult result = db.command(cmd);

Answer 3

尽管这个问题已经很老了，但我还是遇到了同样的问题，而且似乎从最近开始就没有提供自定义切分键了。

基于注释的Shard Key配置可在sping-data-mongob： 3. x，https://docs.spring.io/spring-data/mongodb/docs/3.0.x/reference/html/#sharding

@Document("users")
@Sharded(shardKey = { "country", "userId" }) 
public class User {

    @Id
    Long id;

    @Field("userid")
    String userId;

    String country;
}

从今天起，spring boot starter mongodb附带了2个。不过是x版。