package com.palantir.atlasdb.jdbc;

import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;

import com.palantir.atlasdb.keyvalue.jdbc.JdbcKeyValueService;
import com.palantir.atlasdb.keyvalue.jdbc.JdbcTimestampBoundStore;

public class JdbcTimestampBoundStoreTest {
    private JdbcKeyValueService kvs;
    private JdbcTimestampBoundStore store;

    @Before
    public void setUp() throws Exception {
        kvs = JdbcTests.createEmptyKvs();
        store = JdbcTimestampBoundStore.create(kvs);
    }

    @After
    public void tearDown() throws Exception {
        kvs.close();
    }

    @Test
    public void testTimestampBoundStore() {
        long upperLimit1 = store.getUpperLimit();
        long upperLimit2 = store.getUpperLimit();
        Assert.assertEquals(upperLimit1, upperLimit2);
        store.storeUpperLimit(upperLimit2 + 1);
        long upperLimit3 = store.getUpperLimit();
        Assert.assertEquals(upperLimit3, upperLimit2 + 1);
    }
}

/**
 * Copyright 2016 Palantir Technologies
 *
 * Licensed under the BSD-3 License (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://opensource.org/licenses/BSD-3-Clause
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.palantir.atlasdb.jdbc;

import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;

import com.palantir.atlasdb.keyvalue.jdbc.JdbcKeyValueService;
import com.palantir.atlasdb.keyvalue.jdbc.JdbcTimestampBoundStore;

public class JdbcTimestampBoundStoreTest {
    private JdbcKeyValueService kvs;
    private JdbcTimestampBoundStore store;

    @Before
    public void setUp() throws Exception {
        kvs = JdbcTests.createEmptyKvs();
        store = JdbcTimestampBoundStore.create(kvs);
    }

    @After
    public void tearDown() throws Exception {
        kvs.close();
    }

    @Test
    public void testTimestampBoundStore() {
        long upperLimit1 = store.getUpperLimit();
        long upperLimit2 = store.getUpperLimit();
        Assert.assertEquals(upperLimit1, upperLimit2);
        store.storeUpperLimit(upperLimit2 + 1);
        long upperLimit3 = store.getUpperLimit();
        Assert.assertEquals(upperLimit3, upperLimit2 + 1);
    }
}

add license