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