Examples of org.apache.jackrabbit.oak.plugins.memory.MemoryNodeStore.merge()

Package org.apache.jackrabbit.oak.plugins.memory

Class org.apache.jackrabbit.oak.plugins.memory.MemoryNodeStore

Examples of org.apache.jackrabbit.oak.plugins.memory.MemoryNodeStore.merge()

org.apache.jackrabbit.oak.plugins.memory.MemoryNodeStore.merge()
This implementation is equal to first rebasing the builder and then applying it to a new branch and immediately merging it back. @param builder the builder whose changes to apply @param commitHook the commit hook to apply while merging changes @return the node state resulting from the merge. @throws CommitFailedException @throws IllegalArgumentException if the builder is not acquired from a root state ofthis store


        builder = store.getRoot().builder();
        // change cp ref to point to a non-existing one
        builder.child(AsyncIndexUpdate.ASYNC).setProperty("async", "faulty");
        builder.child("testAnother").setProperty("foo", "def");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        new AsyncIndexUpdate("async", store, provider).run();
        checkPathExists(store.getRoot(), INDEX_DEFINITIONS_NAME, "rootIndex",
                INDEX_CONTENT_NODE_NAME, "def", "testAnother");
    }

View Full Code Here

        NodeBuilder builder = store.getRoot().builder();
        createIndexDefinition(builder.child(INDEX_DEFINITIONS_NAME),
                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(ASYNC_PROPERTY_NAME, "async");
        builder.child("testRoot").setProperty("foo", "abc");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        assertTrue("Expecting no checkpoints",
                store.listCheckpoints().size() == 0);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);

View Full Code Here

                store.listCheckpoints().size() == 1);
        String firstCp = store.listCheckpoints().iterator().next();


        builder = store.getRoot().builder();
        builder.child("testRoot").setProperty("foo", "def");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        async.run();
        assertTrue("Expecting one checkpoint",
                store.listCheckpoints().size() == 1);
        String secondCp = store.listCheckpoints().iterator().next();

View Full Code Here

        NodeBuilder builder = store.getRoot().builder();
        createIndexDefinition(builder.child(INDEX_DEFINITIONS_NAME),
                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(ASYNC_PROPERTY_NAME, "async");
        builder.child("testRoot").setProperty("foo", "abc");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        assertTrue("Expecting no checkpoints",
                store.listCheckpoints().size() == 0);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);

View Full Code Here

        String firstCp = store.listCheckpoints().iterator().next();


        // add content that's hidden from indexing
        builder = store.getRoot().builder();
        builder.child("testRoot").child(":hidden");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);
        async.run();


        assertTrue("Expecting one checkpoint",
                store.listCheckpoints().size() == 1);
        String secondCp = store.listCheckpoints().iterator().next();

View Full Code Here

        NodeBuilder builder = store.getRoot().builder();
        createIndexDefinition(builder.child(INDEX_DEFINITIONS_NAME),
                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(ASYNC_PROPERTY_NAME, "async");
        builder.child("testRoot").setProperty("foo", "abc");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        assertTrue("Expecting no checkpoints",
                store.listCheckpoints().size() == 0);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);

View Full Code Here


        // add some content
        builder.child("a").setProperty("foo", "abc");
        builder.child("b").setProperty("foo", Arrays.asList("abc", "def"),
                STRINGS);
        NodeState head = store.merge(builder, hook, EMPTY);


        // query the index, check it doesn't get indexed by the normal PI
        FilterImpl f = createFilter(head, NT_BASE);
        PropertyIndexLookup lookup = new PropertyIndexLookup(head);
        try {

View Full Code Here

                .getChildNode("foo").getString(ASYNC_PROPERTY_NAME));


        // add content, it should be indexed synchronously
        builder = store.getRoot().builder();
        builder.child("c").setProperty("foo", "def");
        head = store.merge(builder, hook, EMPTY);
        f = createFilter(head, NT_BASE);
        lookup = new PropertyIndexLookup(head);
        assertEquals(ImmutableSet.of("b", "c"), find(lookup, "foo", "def", f));
    }

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 = memStore.getRoot().builder();
        NodeBuilder test = builder.child("test");
        for (int i = 0; i < DocumentRootBuilder.UPDATE_LIMIT * 3; i++) {
            test.child("child-" + i);
        }
        memStore.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        DocumentNodeStore ns = new DocumentMK.Builder()
                .setUseSimpleRevision(true).getNodeStore();


        builder = ns.getRoot().builder();

View Full Code Here

0 1 2 3 4 5 6 7 8

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.