Java 类com.mongodb.MongoCommandException 实例源码

项目：alfresco-benchmark 文件：MongoResultService.java

/**
 * Construct a test result provider against a Mongo database and given collection name
 */
public MongoResultService(DB db, String collection)
{
    try
    {
        this.collection = db.createCollection(collection, new BasicDBObject());
        checkIndexes = true;
    }
    catch (MongoCommandException e)
    {
        if (!db.collectionExists(collection))
        {
            // The collection is really not there
            throw e;
        }
        // Someone else created it
        this.collection = db.getCollection(collection);
        this.checkIndexes = false;
    }
}

项目：ShedLock 文件：MongoLockProvider.java

@Override
public boolean insertRecord(LockConfiguration lockConfiguration) {
    Bson update = combine(
        setOnInsert(LOCK_UNTIL, Date.from(lockConfiguration.getLockAtMostUntil())),
        setOnInsert(LOCKED_AT, now()),
        setOnInsert(LOCKED_BY, hostname)
    );
    try {
        Document result = getCollection().findOneAndUpdate(
            eq(ID, lockConfiguration.getName()),
            update,
            new FindOneAndUpdateOptions().upsert(true)
        );
        return result == null;
    } catch (MongoCommandException e) {
        if (e.getErrorCode() == 11000) { // duplicate key
            // this should not normally happen, but it happened once in tests
            return false;
        } else {
            throw e;
        }

    }
}

项目：alfresco-benchmark 文件：DataReportServiceImpl.java

/**
 * Constructor
 * 
 * @param db
 *            (DB, required) the database to use
 */
public DataReportServiceImpl(DB db)
{
    if (null == db)
    {
        throw new IllegalArgumentException("'db' is mandatory!");
    }
    try
    {
        // create collection with no options
        this.collectionExtraData = db.createCollection(COLLECTION_EXTRA_DATA, null);
        this.collectionDescription = db.createCollection(COLLECTION_EXTRA_DATA_DESCRIPTION, null);
    }
    catch (MongoCommandException e)
    {
        // try to get collection anyway - if not there, re-throw
        if (!db.collectionExists(COLLECTION_EXTRA_DATA) || !db.collectionExists(COLLECTION_EXTRA_DATA_DESCRIPTION))
        {
            throw e;
        }

        this.collectionExtraData = db.getCollection(COLLECTION_EXTRA_DATA);
        this.collectionDescription = db.getCollection(COLLECTION_EXTRA_DATA_DESCRIPTION);
    }
}

项目：morphia 文件：TestDocumentValidation.java

@Test
public void findAndModify() {
    getMorphia().map(DocumentValidation.class);
    getDs().enableDocumentValidation();

    getDs().save(new DocumentValidation("Harold", 100, new Date()));

    Query<DocumentValidation> query = getDs().find(DocumentValidation.class);
    UpdateOperations<DocumentValidation> updates = getDs().createUpdateOperations(DocumentValidation.class)
                                                          .set("number", 5);
    FindAndModifyOptions options = new FindAndModifyOptions()
        .bypassDocumentValidation(false);
    try {
        getDs().findAndModify(query, updates, options);
        fail("Document validation should have complained");
    } catch (MongoCommandException e) {
        // expected
    }

    options.bypassDocumentValidation(true);
    getDs().findAndModify(query, updates, options);

    Assert.assertNotNull(query.field("number").equal(5).get());
}

项目：boteco 文件：MongoRequestRepository.java

public MongoRequestRepository(MongoDatabase database, Long minutesToExpire) {
  this.requests = database.getCollection("requests");
  try {
    this.requests.dropIndex("createdAt_1");
    logger.info("Dropped index 'createdAt', creating a new one.");
  } catch (MongoCommandException e) {
    logger.info("Index for 'createdAt' doesn't exist, creating index.");
  }
  this.requests.createIndex(new Document("createdAt", 1),
      new IndexOptions().expireAfter(minutesToExpire, TimeUnit.MINUTES));
  this.gson = new Gson();
}

项目：mongo-java-driver-rx 文件：Fixture.java

public static MongoCollection<Document> initializeCollection(final MongoNamespace namespace) throws Throwable {
    MongoDatabase database = getMongoClient().getDatabase(namespace.getDatabaseName());
    try {
        database.runCommand(new Document("drop", namespace.getCollectionName())).timeout(10, SECONDS).toBlocking().first();
    } catch (MongoCommandException e) {
        if (!e.getErrorMessage().startsWith("ns not found")) {
            throw e;
        }
    }
    return database.getCollection(namespace.getCollectionName());
}

项目：mongo-java-driver-rx 文件：Fixture.java

public static void dropDatabase(final String name) throws Throwable {
    if (name == null) {
        return;
    }
    try {
        getMongoClient().getDatabase(name).runCommand(new Document("dropDatabase", 1)).timeout(10, SECONDS).toBlocking().first();
    } catch (MongoCommandException e) {
        if (!e.getErrorMessage().startsWith("ns not found")) {
            throw e;
        }
    }
}

项目：mongo-java-driver-rx 文件：Fixture.java

public static void drop(final MongoNamespace namespace) throws Throwable {
    try {
        getMongoClient().getDatabase(namespace.getDatabaseName())
                .runCommand(new Document("drop", namespace.getCollectionName())).timeout(10, SECONDS).toBlocking().first();
    } catch (MongoCommandException e) {
        if (!e.getErrorMessage().contains("ns not found")) {
            throw e;
        }
    }
}