Examples of sequenceCurrentValue()

Examples of com.foundationdb.qp.operator.StoreAdapter.sequenceCurrentValue()

103
104
105
106
107
108
109
110
111
112
113
        TableName sequenceName = new TableName(parts[0], parts[1]);
        StoreAdapter store = context.getQueryContext().getStore();
        Sequence sequence = store.getSequence(sequenceName);
        long value = nextValue ?
            store.sequenceNextValue(sequence) :
            store.sequenceCurrentValue(sequence);

        logger.debug("Sequence loading : {} -> {}", sequenceName, value);

        output.putInt64(value);
    }
View Full Code Here

Examples of com.foundationdb.qp.operator.StoreAdapter.sequenceCurrentValue()

97
98
99
100
101
102
103
104
105
106
107
        executeDDL(sql);
        Sequence s1 = ais().getSequence(seqName);
        assertNotNull("s1", s1);

        txnService().beginTransaction(session());
        assertEquals("start val a", 0, adapter.sequenceCurrentValue(s1));
        assertEquals("next val a", 1, adapter.sequenceNextValue(s1));
        txnService().commitTransaction(session());

        txnService().beginTransaction(session());
        assertEquals("next val b", 2, adapter.sequenceNextValue(s1));
View Full Code Here

Examples of com.foundationdb.qp.operator.StoreAdapter.sequenceCurrentValue()

103
104
105
106
107
108
109
110
111
112
113
        assertEquals("next val a", 1, adapter.sequenceNextValue(s1));
        txnService().commitTransaction(session());

        txnService().beginTransaction(session());
        assertEquals("next val b", 2, adapter.sequenceNextValue(s1));
        assertEquals("cur val b", 2, adapter.sequenceCurrentValue(s1));
        txnService().rollbackTransactionIfOpen(session());

        txnService().beginTransaction(session());
        // Expected gap, see nextValue() impl
        assertEquals("next val c", 3, adapter.sequenceNextValue(s1));
View Full Code Here

Examples of com.foundationdb.qp.operator.StoreAdapter.sequenceCurrentValue()

136
137
138
139
140
141
142
143
144
145
146
            executeDDL(create);
            Sequence s1 = ais().getSequence(seqName);
            assertNotNull("s1, loop"+i, s1);

            txnService().beginTransaction(session());
            assertEquals("start val, loop"+i, 0, adapter.sequenceCurrentValue(s1));
            assertEquals("next val, loop"+i, 1, adapter.sequenceNextValue(s1));
            txnService().commitTransaction(session());

            executeDDL(drop);
        }
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.