使用spring数据mongodb获取MongoDatabase

Question

我正在尝试无限期地跟踪 mongo oplog 集合。我目前使用的代码如下。

MongoClient mongoClient = new MongoClient(<host>,<27017>);

MongoCollection oplogColl =
                   mongoClient
                           .getDatabase("local")
                           .getCollection("oplog.rs");

MongoCursor oplogCursor =
                   oplogColl
                           .find(new Document("ts", filter))
                           .cursorType(CursorType.TailableAwait)
                           .noCursorTimeout(true)
                           .sort(new Document("$natural", 1))
                           .iterator();

我正在尝试使用 spring-data 获得相同的实现，其中将在属性文件中指定 mongo uri。因此我需要访问 MongoDatabase 或 MongoClient。

在 spring 中尝试使用 MongodbFactory 类，但它返回了一个 DB 类型的实例，这是访问 mongo 的旧 mongo 实现。

如何使用 Spring Data 使用 MongoDatabase/MongoCollection/MongoClient。

Answer 1

MongoClient 扩展了Mongo，所以

@Configuration
public class AppConfig {
   public @Bean Mongo mongo() throws UnknownHostException {
       return new Mongo("localhost");
   }
}

如果你不想直接编写 Mongo 类

/*
* Factory bean that creates the com.mongodb.Mongo instance
*/
@Bean
public MongoClientFactoryBean mongo() {
    MongoClientFactoryBean mongo = new MongoClientFactoryBean();
    mongo.setHost("localhost");
    return mongo;
}

编辑：

@Configuration
public class AppConfig {
   public @Bean MongoClient mongo() throws UnknownHostException {
       return new MongoClient("localhost");
   }
}

---

用法：

@Autowired
private Mongo mongo;

MongoOperations mongoOps = new MongoTemplate(mongo, "databaseName");

编辑：

@Autowired
private MongoClient mongoClient;

MongoOperations mongoOps = new MongoTemplate(mongoClient, "databaseName");