diff --git a/client/src/main/java/com/vesoft/nebula/client/storage/StorageClient.java b/client/src/main/java/com/vesoft/nebula/client/storage/StorageClient.java index db36a1dc6..888dadaae 100644 --- a/client/src/main/java/com/vesoft/nebula/client/storage/StorageClient.java +++ b/client/src/main/java/com/vesoft/nebula/client/storage/StorageClient.java @@ -51,6 +51,7 @@ public class StorageClient implements Serializable { private boolean enableSSL = false; private SSLParam sslParam = null; + private String user = null; private String password = null; @@ -58,6 +59,7 @@ public class StorageClient implements Serializable { // the write list for users with read permission private Map> spaceLabelWriteList = null; + private String version = null; /** @@ -129,6 +131,7 @@ public void setGraphAddress(String graphAddress) { this.graphAddress = graphAddress; } + public StorageClient setVersion(String version) { this.version = version; return this; diff --git a/client/src/test/java/com/vesoft/nebula/client/storage/StorageClientTest.java b/client/src/test/java/com/vesoft/nebula/client/storage/StorageClientTest.java index 51913838c..f6fec5f65 100644 --- a/client/src/test/java/com/vesoft/nebula/client/storage/StorageClientTest.java +++ b/client/src/test/java/com/vesoft/nebula/client/storage/StorageClientTest.java @@ -60,6 +60,7 @@ public void testStorageClientWithVersionInWhiteList() { List address = Arrays.asList(new HostAddress(ip, 9559)); StorageClient storageClient = new StorageClient(address); try { + storageClient.setGraphAddress("127.0.0.1:9669"); storageClient.setUser("root"); storageClient.setPassword("nebula");