mirror of https://github.com/tikv/client-java.git
parent
5dbfe03b2c
commit
712509f771
5
pom.xml
5
pom.xml
|
|
@ -582,6 +582,11 @@
|
||||||
<commitIdGenerationMode>full</commitIdGenerationMode>
|
<commitIdGenerationMode>full</commitIdGenerationMode>
|
||||||
</configuration>
|
</configuration>
|
||||||
</plugin>
|
</plugin>
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.apache.maven.plugins</groupId>
|
||||||
|
<artifactId>maven-surefire-plugin</artifactId>
|
||||||
|
<version>3.0.0-M5</version>
|
||||||
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -17,10 +17,21 @@
|
||||||
|
|
||||||
package org.tikv;
|
package org.tikv;
|
||||||
|
|
||||||
|
import org.tikv.common.PDClient;
|
||||||
|
import org.tikv.common.StoreVersion;
|
||||||
import org.tikv.common.TiConfiguration;
|
import org.tikv.common.TiConfiguration;
|
||||||
|
import org.tikv.common.TiSession;
|
||||||
import org.tikv.util.TestUtils;
|
import org.tikv.util.TestUtils;
|
||||||
|
|
||||||
public class BaseRawKVTest {
|
public class BaseRawKVTest {
|
||||||
|
|
||||||
|
protected boolean tikvVersionNewerThan(String expectedVersion) {
|
||||||
|
TiConfiguration conf = createTiConfiguration();
|
||||||
|
TiSession session = TiSession.create(conf);
|
||||||
|
PDClient pdClient = session.getPDClient();
|
||||||
|
return StoreVersion.minTiKVVersion(expectedVersion, pdClient);
|
||||||
|
}
|
||||||
|
|
||||||
protected TiConfiguration createTiConfiguration() {
|
protected TiConfiguration createTiConfiguration() {
|
||||||
String pdAddrsStr = TestUtils.getEnv("RAWKV_PD_ADDRESSES");
|
String pdAddrsStr = TestUtils.getEnv("RAWKV_PD_ADDRESSES");
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -21,11 +21,13 @@ import static org.junit.Assert.assertFalse;
|
||||||
import static org.junit.Assert.assertTrue;
|
import static org.junit.Assert.assertTrue;
|
||||||
|
|
||||||
import org.junit.After;
|
import org.junit.After;
|
||||||
|
import org.junit.Assume;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.tikv.BaseRawKVTest;
|
import org.tikv.BaseRawKVTest;
|
||||||
|
|
||||||
public class PDClientIntegrationTest extends BaseRawKVTest {
|
public class PDClientIntegrationTest extends BaseRawKVTest {
|
||||||
|
|
||||||
private TiSession session;
|
private TiSession session;
|
||||||
|
|
||||||
@Before
|
@Before
|
||||||
|
|
@ -44,6 +46,7 @@ public class PDClientIntegrationTest extends BaseRawKVTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testPauseCheck() throws Exception {
|
public void testPauseCheck() throws Exception {
|
||||||
|
Assume.assumeTrue(tikvVersionNewerThan("v5.3.0"));
|
||||||
try (PDClient client = session.getPDClient()) {
|
try (PDClient client = session.getPDClient()) {
|
||||||
PDChecker checker = PDChecker.Merge;
|
PDChecker checker = PDChecker.Merge;
|
||||||
for (int i = 0; i < 2; i++) {
|
for (int i = 0; i < 2; i++) {
|
||||||
|
|
|
||||||
|
|
@ -26,6 +26,7 @@ import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
import org.junit.After;
|
import org.junit.After;
|
||||||
|
import org.junit.Assume;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.tikv.BaseRawKVTest;
|
import org.tikv.BaseRawKVTest;
|
||||||
|
|
@ -37,6 +38,7 @@ import org.tikv.raw.RawKVClient;
|
||||||
import org.tikv.util.TestUtils;
|
import org.tikv.util.TestUtils;
|
||||||
|
|
||||||
public class RawKVIngestTest extends BaseRawKVTest {
|
public class RawKVIngestTest extends BaseRawKVTest {
|
||||||
|
|
||||||
private TiSession session;
|
private TiSession session;
|
||||||
|
|
||||||
private static final int KEY_NUMBER = 16;
|
private static final int KEY_NUMBER = 16;
|
||||||
|
|
@ -59,6 +61,7 @@ public class RawKVIngestTest extends BaseRawKVTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void rawKVIngestTest() {
|
public void rawKVIngestTest() {
|
||||||
|
Assume.assumeTrue(tikvVersionNewerThan("v5.2.0"));
|
||||||
RawKVClient client = session.createRawClient();
|
RawKVClient client = session.createRawClient();
|
||||||
|
|
||||||
// gen test data
|
// gen test data
|
||||||
|
|
@ -88,6 +91,7 @@ public class RawKVIngestTest extends BaseRawKVTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void rawKVIngestTestWithTTL() throws InterruptedException {
|
public void rawKVIngestTestWithTTL() throws InterruptedException {
|
||||||
|
Assume.assumeTrue(tikvVersionNewerThan("v5.2.0"));
|
||||||
long ttl = 10;
|
long ttl = 10;
|
||||||
RawKVClient client = session.createRawClient();
|
RawKVClient client = session.createRawClient();
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -24,6 +24,7 @@ import com.google.protobuf.ByteString;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import org.junit.After;
|
import org.junit.After;
|
||||||
|
import org.junit.Assume;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.tikv.BaseRawKVTest;
|
import org.tikv.BaseRawKVTest;
|
||||||
|
|
@ -32,6 +33,7 @@ import org.tikv.common.TiSession;
|
||||||
import org.tikv.common.region.TiRegion;
|
import org.tikv.common.region.TiRegion;
|
||||||
|
|
||||||
public class RegionSplitTest extends BaseRawKVTest {
|
public class RegionSplitTest extends BaseRawKVTest {
|
||||||
|
|
||||||
private TiSession session;
|
private TiSession session;
|
||||||
|
|
||||||
private static final int KEY_NUMBER = 10;
|
private static final int KEY_NUMBER = 10;
|
||||||
|
|
@ -53,6 +55,7 @@ public class RegionSplitTest extends BaseRawKVTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void rawKVSplitTest() {
|
public void rawKVSplitTest() {
|
||||||
|
Assume.assumeTrue(tikvVersionNewerThan("v5.1.0"));
|
||||||
List<byte[]> splitKeys = new ArrayList<>(KEY_NUMBER);
|
List<byte[]> splitKeys = new ArrayList<>(KEY_NUMBER);
|
||||||
for (int i = 0; i < KEY_NUMBER; i++) {
|
for (int i = 0; i < KEY_NUMBER; i++) {
|
||||||
splitKeys.add(genRandomKey(KEY_PREFIX, KEY_LENGTH));
|
splitKeys.add(genRandomKey(KEY_PREFIX, KEY_LENGTH));
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue