标签: mongodb-java

我正在使用带有java-driver 2.10.1的MongoDB 2.2

我正在将一个日期字段插入到java.util.Date实例的文档中.我的实例具有以下值:

Wed Oct 10 00:00:00 CEST 2012

但是一旦进入mongo,我就有了这个值: ISODate("2012-10-09T22:00:00Z")

我的插入代码:

BasicDBObject doc =  new BasicDBObject("key", event.getKey())
                    .append("title", event.getTitle())
                    .append("description",  event.getDescription())
                    .append("date",  event.getDate());
db.getCollection("events").insert(doc);

您可以在此调试屏幕截图中查看从我的事件对象引用的日期实例:

是否与时区有关？或驱动程序的错误？

我在MongoDB集合中有这些项目:

{x: 1, y: 60, z:100}
{x: 1, y: 60, z:100}
{x: 1, y: 60, z:100}
{x: 2, y: 60, z:100}
{x: 2, y: 60, z:100}
{x: 3, y: 60, z:100}
{x: 4, y: 60, z:100}
{x: 4, y: 60, z:100}
{x: 5, y: 60, z:100}
{x: 6, y: 60, z:100}
{x: 6, y: 60, z:100}
{x: 6, y: 60, z:100}
{x: 7, y: 60, z:100}
{x: 7, y: 60, z:100}

我想查询x的不同值(即[1,2,3,4,5,6,7])...但我只想要它们的一部分(类似于我们可以用skip(a)获得的)并限制(b)).

我如何使用MongoDB的java驱动程序(如果可能,使用spring-data-mongodb)？

我在创建连接时使用mongo数据库为我的应用程序连接假脱机配置了下面的mongoOption

MongoOptions options = new MongoOptions();
   options.autoConnectRetry = true;
   options.connectionsPerHost = 40;
   options.threadsAllowedToBlockForConnectionMultiplier = 25;

除了我的应用程序,获得以下异常

com.mongodb.MongoInterruptedException: A driver operation has been interrupted
at com.mongodb.DBPortPool.get(DBPortPool.java:216)
at com.mongodb.DBTCPConnector$MyPort.get(DBTCPConnector.java:440)
at com.mongodb.DBTCPConnector.say(DBTCPConnector.java:177)
at com.mongodb.DBTCPConnector.say(DBTCPConnector.java:155)
at com.mongodb.DBApiLayer$MyCollection.update(DBApiLayer.java:349)
at com.mongodb.DBCollection.update(DBCollection.java:177)
at com.mongodb.DBCollection.save(DBCollection.java:817)
at com.mongodb.DBCollection.save(DBCollection.java:785)
at cherrypick.ck.datalayer.mongo.MongoDataAccessLayer.saveObject(MongoDataAccessLayer.java:361)
at cherrypick.ck.emailinterface.CKMailMonitor.processIncomingMessage(CKMailMonitor.java:170)
at cherrypick.ck.emailinterface.CKMailMonitor.monitorNewMessages(CKMailMonitor.java:253)
at cherrypick.ck.emailinterface.CKMailMonitor.run(CKMailMonitor.java:275)
Caused by: java.lang.InterruptedException
at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1325)
at java.util.concurrent.Semaphore.tryAcquire(Semaphore.java:414)
at com.mongodb.util.SimplePool.permitAcquired(SimplePool.java:148)
at com.mongodb.util.SimplePool.get(SimplePool.java:110)
at com.mongodb.DBPortPool.get(DBPortPool.java:214)

任何人都可以帮我解决这个问题.

在此先感谢Raja Subramani

我们以前使用过mongo-java-driver 3.0.4，在某个代码块中有这个实现 -

DBCollection docCollection = mongoClient.getDB(dbName).getCollection(collectionName);

Map<String, Object> docMap = doc.toMap(); // where doc is the CustomDocument

DBObject currentObj = docCollection.findOne(new QueryBuilder().put("id").is(doc.getId()).get());
if(currentObj == null) {
   docCollection.insert(new BasicDBObject(docMap));
} else {
   docCollection.update(currentObj, new BasicDBObject(docMap));
}

我现在想要实现的是使用mongo-java-driver 3.3.0和更新代码以摆脱不推荐使用的类和方法。我尝试过的与上述代码相对应的是 -

MongoCollection<CustomDocument> docCollections = mongoClient.getDatabase(dbName).getCollection(collectionName, CustomDocument.class);

Bson filter = Filters.eq("id", doc.getId()); // where doc is the CustomDocument
FindIterable<Document> documentList = docCollections.find(filter);
if (documentList == null) {
    docCollections.insertOne(doc);
} else {
    docCollections.findOneAndUpdate(filter, new BasicDBObject(docMap));
}

我仍然觉得缺少的是findOne在我的代码的收集和基于检查行动，对将要执行的实施insert …

我正在为我的项目使用 MongoDB Java 驱动程序来从 Java 访问我的数据库。

我通常使用Document它，因为它非常易于使用，并且所有方法都在 . 中MongoDBCollection，例如find()使用它并返回Document实例。

然而，在某些情况下，我想使用等效BsonDocument这是更详细的，但提供通过实现类型安全Map<String,BsonValue>，它Document并没有因为它实现Map<String,Object>。

我可以将 a 转换Document为 aBsonDocument：

BsonDocument bsonDoc = document.toBsonDocument(BsonDocument.class, MongoClient.getDefaultCodecRegistry());

这里的问题是，在所有的方法MongoDBCollection，比如insertOne()只需要Document实例，所以我不能使用这些。

对我来说，看起来有两种方法可以解决这个问题：

如果BsonDocumentcreated bytoBsonDocument()以某种方式得到了原始 的支持，即使我对 进行了修改Document，我也可以使用原始Document实例BsonDocument，因为原始实例Document会反映这些更改，对吗？它是这样工作的还是BsonDocument只是一个副本？

第二种方法是从BsonDocument回Document转换为. 这在某种程度上可能吗？

提前致谢！