Package com.mongodb

Examples of com.mongodb.DBCollection.drop()

164
165
166
167
168
169
170
171
172
173
174
    @Test
    public void testDropCollection() throws Exception {
        DBCollection collection = readOnlyClient.getDB("testdb").getCollection("foo");
        try {
            collection.drop();
            fail("MongoException expected");
        } catch (MongoException e) {
            // okay
        }
    }
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
    //  *write* advantage performance wise anyway
    if ((null == job.appendResults) || !job.appendResults) { // then we're going to write into temp
     
      try {
        target = DbManager.getCollection(job.getOutputDatabase(), job.outputCollectionTemp);
        target.drop();
        DbManager.getDB(job.getOutputDatabase()).getLastError();
      }
      catch (Exception e) {} // That's fine, it probably just doesn't exist yet...
    }
    // If we need any indexes for sorting/whatever then declare them here, which is faster
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
   
    // optionally drop the existing collection
    boolean drop = conf.getBoolean("mongo.output.drop", false);
    DBCollection coll = db.getCollection(collection);
    if(drop) {
      coll.drop();
    }
    else {
      if(coll.count() > 0) {
        // don't shard an existing collection - may already be sharded ...
        return;
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
   
    // optionally drop the existing collection
    boolean drop = conf.getBoolean("mongo.output.drop", false);
    DBCollection coll = db.getCollection(collection);
    if(drop) {
      coll.drop();
    }
    else {
      if(coll.count() > 0) {
        // don't shard an existing collection - may already be sharded ...
        return;
View Full Code Here
952
953
954
955
956
957
958
959
960
961
962
        new DbJob() {
            @Override
            public Object doRun() throws Exception {
                try {
                    if (dropCollection) {
                        col.drop();
                    }
                    DBObject obj = null;
                    List<DBObject> batch = new ArrayList<DBObject>();
                    while ((obj = dd.readObject()) != null) {
                        try {
View Full Code Here
326
327
328
329
330
331
332
333
334
335
336
            }
        }

        // add temp collection to sort chunks with shard key
        final DBCollection tmpchunks = config.getCollection("_tmpchunks_" + col);
        tmpchunks.drop();
        // should be safe environment, and dup keys should be ignored
        tmpchunks.setWriteConcern(WriteConcern.NORMAL);
        // can use shardKey as unique _id
//        tmpchunks.ensureIndex(shardKey, "shardKey", true);
View Full Code Here
18
19
20
21
22
23
24
25
26
27
28
    protected void createEmptyCollection(final Class clazz) {
        running(fakeApplication(TestConfig.getInstance().config()), new Runnable() {
            @Override
            public void run() {
                DBCollection col = MorphiaPlugin.db().getCollection(clazz.getSimpleName());
                col.drop();
            }
        });
    }

    protected void createEmptyCollection(final String colName) {
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
    protected void createEmptyCollection(final String colName) {
        running(fakeApplication(TestConfig.getInstance().config()), new Runnable() {
            @Override
            public void run() {
                DBCollection col = MorphiaPlugin.db().getCollection(colName);
                col.drop();
            }
        });
    }

    protected void dropAllCollections() {
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
        if (proceedWithUnitTest()) {
            DBCollection col = db.createCollection("my_collection", null);

            // delete if already exists
            {
                col.drop();
                col = db.createCollection("my_collection", null);
            }

            // create 3 records
            for (int i = 0; i < 3; i++) {
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
            DBCollection col = db.createCollection("my_collection", null);

            // delete if already exists
            {
                col.drop();
                col = db.createCollection("my_collection", null);
            }

            // create 1000 records
            for (int i = 0; i < 1000; i++) {
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.