Package com.mongodb

Examples of com.mongodb.DBCollection.drop()


  }

  public void dropCollection() {
    DBCollection messagesCollection = chatDatabase
        .getCollection("historymessages");
    messagesCollection.drop();
  }

  public void insert10Messages() {
    MessagesHistoryMongo conect = new MessagesHistoryMongo();
    Statut statut = Statut.EN_LIGNE;
View Full Code Here


        final MockEndpoint mock = getMockEndpoint("mock:test");
        final Calendar startTimestamp = Calendar.getInstance();
       
        // get default tracking collection
        DBCollection trackingCol = db.getCollection(MongoDbTailTrackingConfig.DEFAULT_COLLECTION);
        trackingCol.drop();
        trackingCol = db.getCollection(MongoDbTailTrackingConfig.DEFAULT_COLLECTION);
       
        // create a capped collection with max = 1000
        cappedTestCollection = db.createCollection(cappedTestCollectionName,
                BasicDBObjectBuilder.start().add("capped", true).add("size", 1000000000).add("max", 1000).get());
View Full Code Here

        assertEquals(0, cappedTestCollection.count());
        final MockEndpoint mock = getMockEndpoint("mock:test");
       
        // get the custom tracking collection and drop it (tailTrackDb=einstein&tailTrackCollection=curie&tailTrackField=newton)
        DBCollection trackingCol = mongo.getDB("einstein").getCollection("curie");
        trackingCol.drop();
        trackingCol = mongo.getDB("einstein").getCollection("curie");
       
        // create a capped collection with max = 1000
        cappedTestCollection = db.createCollection(cappedTestCollectionName,
                BasicDBObjectBuilder.start().add("capped", true).add("size", 1000000000).add("max", 1000).get());
View Full Code Here

                AbstractClassMetaData cmd = getMetaDataManager().getMetaDataForClass(className, clr);
                if (cmd != null)
                {
                    DBCollection collection = db.getCollection(MongoDBUtils.getCollectionName(cmd));
                    collection.dropIndexes();
                    collection.drop();
                }
            }
        }
        finally
        {
View Full Code Here

        final MockEndpoint mock = getMockEndpoint("mock:test");
        final Calendar startTimestamp = Calendar.getInstance();
       
        // get default tracking collection
        DBCollection trackingCol = db.getCollection(MongoDbTailTrackingConfig.DEFAULT_COLLECTION);
        trackingCol.drop();
        trackingCol = db.getCollection(MongoDbTailTrackingConfig.DEFAULT_COLLECTION);
       
        // create a capped collection with max = 1000
        cappedTestCollection = db.createCollection(cappedTestCollectionName,
                BasicDBObjectBuilder.start().add("capped", true).add("size", 1000000000).add("max", 1000).get());
View Full Code Here

        assertEquals(0, cappedTestCollection.count());
        final MockEndpoint mock = getMockEndpoint("mock:test");
       
        // get the custom tracking collection and drop it (tailTrackDb=einstein&tailTrackCollection=curie&tailTrackField=newton)
        DBCollection trackingCol = mongo.getDB("einstein").getCollection("curie");
        trackingCol.drop();
        trackingCol = mongo.getDB("einstein").getCollection("curie");
       
        // create a capped collection with max = 1000
        cappedTestCollection = db.createCollection(cappedTestCollectionName,
                BasicDBObjectBuilder.start().add("capped", true).add("size", 1000000000).add("max", 1000).get());
View Full Code Here

    DB db = mongoClient.getDB("test");
   
    DBCollection coll = db.getCollection("testCollection");
   
    // removes the existing documents
    coll.drop();

    List<DBObject> list = new ArrayList<DBObject>();
    for (int i=0; i<JSONArray.length(); i++) {
      logger.info("Inserting: " + JSONArray.get(i).toString().replaceAll("\\.", ""));
View Full Code Here

@SuppressWarnings("javadoc")
public class MongoUtil {

    public static void clearCommitCollection(MongoConnection mongoConnection) {
        DBCollection commitCollection = mongoConnection.getCommitCollection();
        commitCollection.drop();
    }

    public static void clearDatabase(MongoConnection mongoConnection) {
        clearNodeCollection(mongoConnection);
        clearCommitCollection(mongoConnection);
View Full Code Here

        clearHeadCollection(mongoConnection);
    }

    public static void clearHeadCollection(MongoConnection mongoConnection) {
        DBCollection headCollection = mongoConnection.getHeadCollection();
        headCollection.drop();
    }

    public static void clearNodeCollection(MongoConnection mongoConnection) {
        DBCollection nodeCollection = mongoConnection.getNodeCollection();
        nodeCollection.drop();
View Full Code Here

        headCollection.drop();
    }

    public static void clearNodeCollection(MongoConnection mongoConnection) {
        DBCollection nodeCollection = mongoConnection.getNodeCollection();
        nodeCollection.drop();
    }

    public static void initCommitCollection(MongoConnection mongoConnection) {
        DBCollection commitCollection = mongoConnection.getCommitCollection();
        DBObject index = new BasicDBObject();
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.