MongoDatabase与弹簧数据mongodb

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(); 

我试图用弹簧数据，其中蒙戈URI将在属性文件中指定，以获得相同的实现。因此我需要访问MongoDatabase或MongoClient。

在春天尝试使用MongodbFactory类，但它返回一个类型为DB的实例，这是一个用于访问mongo的旧mongo实现。

如何使用spring数据来使用MongoDatabase/MongoCollection/MongoClient。

Answer 1

MongoClient延伸Mongo，所以

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

如果你不想代码来蒙戈类直接

/* 
* 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");