Examples of org.apache.jackrabbit.oak.spi.state.NodeStore.merge()

Package org.apache.jackrabbit.oak.spi.state

Class org.apache.jackrabbit.oak.spi.state.NodeStore

Examples of org.apache.jackrabbit.oak.spi.state.NodeStore.merge()

org.apache.jackrabbit.oak.spi.state.NodeStore.merge()
Merges the changes from the passed {@code builder} intothe store. @param builder the builder whose changes to apply @param commitHook the commit hook to apply while merging changes @param info commit info associated with this merge operation,or {@code null} if no local commit information is available @return the node state resulting from the merge. @throws CommitFailedException if the merge failed @throws IllegalArgumentException if the builder is not acquiredfrom a root state of this store

        for (int i = 0; i < NUM_REVS_THRESHOLD; i++) {
            builder = ns.getRoot().builder();
            builder.setProperty("p", i);
            test = builder.child("test");
            test.setProperty("foo", i);
            ns.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);
        }
        mk.runBackgroundOperations();
        NodeDocument doc = store.find(NODES, Utils.getIdFromPath("/test"));
        assertNotNull(doc);
        // the local _commitRoot map must still contain the entry for

View Full Code Here

        NodeBuilder idxb = newLuceneIndexDefinition(index, "lucene",
                ImmutableSet.of(TYPENAME_STRING));
        idxb.setProperty(PERSISTENCE_NAME, PERSISTENCE_FILE);
        idxb.setProperty(PERSISTENCE_PATH, getIndexDir());


        nodeStore.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        builder = nodeStore.getRoot().builder();
        builder.setProperty("foo", "bar");


        NodeState indexed = nodeStore.merge(builder, HOOK, CommitInfo.EMPTY);

View Full Code Here

        nodeStore.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        builder = nodeStore.getRoot().builder();
        builder.setProperty("foo", "bar");


        NodeState indexed = nodeStore.merge(builder, HOOK, CommitInfo.EMPTY);


        assertQuery(tracker, indexed, "foo", "bar");


        builder = nodeStore.getRoot().builder();
        builder.setProperty("foo2", "bar2");

View Full Code Here


        assertQuery(tracker, indexed, "foo", "bar");


        builder = nodeStore.getRoot().builder();
        builder.setProperty("foo2", "bar2");
        indexed = nodeStore.merge(builder, HOOK, CommitInfo.EMPTY);


        assertQuery(tracker, indexed, "foo2", "bar2");
    }


    @Test

View Full Code Here

                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(REINDEX_ASYNC_PROPERTY_NAME, true);
        builder.child("testRoot").setProperty("foo", "abc");


        // merge it back in
        store.merge(builder, hook, CommitInfo.EMPTY);


        // first check that the async flag exist
        NodeState ns1 = checkPathExists(store.getRoot(),
                INDEX_DEFINITIONS_NAME, "rootIndex");
        assertTrue(ns1.getProperty(REINDEX_PROPERTY_NAME)

View Full Code Here

            NodeBuilder builder = b.child("Folder#" + j);
            for (int i = 0; i <(number < 1000 ? number : 1000); i++) {
                builder.child("Test#" + i).setProperty("ts", System.currentTimeMillis());
            }
        }
        store.merge(rootbuilder, EmptyHook.INSTANCE, CommitInfo.EMPTY);
        storeS.flush();


        final StandbyServer server = new StandbyServer(port, storeS, useSSL);
        server.start();

View Full Code Here

                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(ASYNC_PROPERTY_NAME, "async");
        builder.child("testRoot").setProperty("foo", "abc");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

        builder.child("testRoot").setProperty("foo", "abc")
                .setProperty("bar", "def");
        builder.child("testSecond").setProperty("bar", "ghi");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

        builder.child("testRoot").setProperty("foo", "abc");
        builder.child("newchild").child("other").child("testChild")
                .setProperty("foo", "xyz");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(ASYNC_PROPERTY_NAME, "async");
        builder.child("testRoot").setProperty("foo", "abc");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.getIndexStats().pause();
        async.run();
        assertFalse(store.getRoot().getChildNode(INDEX_DEFINITIONS_NAME)

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.