Package org.apache.jackrabbit.oak.plugins.document.mongo

Examples of org.apache.jackrabbit.oak.plugins.document.mongo.MongoDocumentStore

482
483
484
485
486
487
488
489
490
491
492
         * @return this
         */
        public Builder setMongoDB(DB db, int changesSizeMB) {
            if (db != null) {
                if (this.documentStore == null) {
                    this.documentStore = new MongoDocumentStore(db, this);
                }

                if (this.blobStore == null) {
                    this.blobStore = new MongoBlobStore(db);
                }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
        public DocumentStore createDocumentStore() {
            try {
                MongoConnection connection = new MongoConnection(uri);
                DB db = connection.getDB();
                MongoUtils.dropCollections(db);
                return new MongoDocumentStore(db, new DocumentMK.Builder());
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
View Full Code Here
57
58
59
60
61
62
63
64
65
    private static final boolean MONGO_DB = false;
    private static final int NODE_COUNT = 10;

    DocumentStore openDocumentStore() {
        if (MONGO_DB) {
            return new MongoDocumentStore(MongoUtils.getConnection().getDB(), new DocumentMK.Builder());
        }
        return new MemoryDocumentStore();
    }
View Full Code Here
613
614
615
616
617
618
619
620
621
622
623
            DocumentNodeStore dns = (DocumentNodeStore) store;
            if (!(dns.getDocumentStore() instanceof MongoDocumentStore)) {
                System.err.println("Recovery only available for MongoDocumentStore");
                System.exit(1);
            }
            MongoDocumentStore docStore = (MongoDocumentStore) dns.getDocumentStore();
            LastRevRecoveryAgent agent = new LastRevRecoveryAgent(dns);
            MongoMissingLastRevSeeker seeker = new MongoMissingLastRevSeeker(docStore);
            CloseableIterable<NodeDocument> docs = seeker.getCandidates(0);
            closer.register(docs);
            boolean dryRun = Arrays.asList(args).contains("dryRun");
View Full Code Here
166
167
168
169
170
171
172
173
174
175
        public DocumentStore createDocumentStore(int clusterId) {
            try {
                MongoConnection connection = new MongoConnection(uri);
                DB db = connection.getDB();
                MongoUtils.dropCollections(db);
                return new MongoDocumentStore(db, new DocumentMK.Builder().setClusterId(clusterId));
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
View Full Code Here
524
525
526
527
528
529
530
531
532
533
534
         * @return this
         */
        public Builder setMongoDB(DB db, int changesSizeMB, int blobCacheSizeMB) {
            if (db != null) {
                if (this.documentStore == null) {
                    this.documentStore = new MongoDocumentStore(db, this);
                }

                if (this.blobStore == null) {
                    GarbageCollectableBlobStore s = new MongoBlobStore(db, blobCacheSizeMB * 1024 * 1024L);
                    PersistentCache p = getPersistentCache();
View Full Code Here
472
473
474
475
476
477
478
479
480
481
482
         * @return this
         */
        public Builder setMongoDB(DB db) {
            if (db != null) {
                if (this.documentStore == null) {
                    this.documentStore = new MongoDocumentStore(db, this);
                }

                if (this.blobStore == null) {
                    this.blobStore = new MongoBlobStore(db);
                }
View Full Code Here
471
472
473
474
475
476
477
478
479
480
481
         * @return this
         */
        public Builder setMongoDB(DB db) {
            if (db != null) {
                if(this.documentStore == null){
                    this.documentStore = new MongoDocumentStore(db, this);
                }

                if(this.blobStore == null){
                    this.blobStore = new MongoBlobStore(db);
                }
View Full Code Here
56
57
58
59
60
61
62
63
64
    private static final boolean MONGO_DB = false;
    private static final int NODE_COUNT = 10;

    DocumentStore openDocumentStore() {
        if (MONGO_DB) {
            return new MongoDocumentStore(MongoUtils.getConnection().getDB(), new DocumentMK.Builder());
        }
        return new MemoryDocumentStore();
    }
View Full Code Here
TOP

Related Classes of org.apache.jackrabbit.oak.plugins.document.mongo.MongoDocumentStore

  • com.mongodb.BasicDBObject
  • com.mongodb.DBCollection
  • com.mongodb.DBCursor
  • com.mongodb.DBObject
  • com.mongodb.MongoClientURI
  • com.mongodb.QueryBuilder
  • com.mongodb.ReadPreference
  • com.mongodb.WriteConcern
  • com.mongodb.WriteResult
  • org.apache.jackrabbit.oak.cache.CacheStats
    • Copyright © 2018 www.massapicom. 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.