Skip to content

Commit 1b10970

Browse files
committed
Add Scylla Cloud example
Adds an usage example which is slightly modified ReadCassandraVersion.
1 parent bc6f23a commit 1b10970

File tree

1 file changed

+33
-0
lines changed

1 file changed

+33
-0
lines changed
Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
package com.datastax.oss.driver.examples.scyllacloud;
2+
3+
import com.datastax.oss.driver.api.core.CqlSession;
4+
import com.datastax.oss.driver.api.core.DefaultProtocolVersion;
5+
import com.datastax.oss.driver.api.core.config.DefaultDriverOption;
6+
import com.datastax.oss.driver.api.core.config.DriverConfigLoader;
7+
import com.datastax.oss.driver.api.core.cql.ResultSet;
8+
import com.datastax.oss.driver.api.core.cql.Row;
9+
import java.io.File;
10+
11+
public class ReadScyllaVersion {
12+
13+
public static void main(String[] args) {
14+
String configPath = "/path/to/scylla/cloud/conf/file";
15+
File configFile = new File(configPath);
16+
DriverConfigLoader loader =
17+
DriverConfigLoader.programmaticBuilder()
18+
.withString(DefaultDriverOption.PROTOCOL_VERSION, DefaultProtocolVersion.V4.toString())
19+
.build();
20+
21+
try (CqlSession session =
22+
CqlSession.builder()
23+
.withConfigLoader(loader)
24+
.withScyllaCloudSecureConnectBundle(configFile.toPath())
25+
.build()) {
26+
ResultSet rs = session.execute("select release_version from system.local");
27+
Row row = rs.one();
28+
assert row != null;
29+
String releaseVersion = row.getString("release_version");
30+
System.out.printf("Scylla version: %s%n", releaseVersion);
31+
}
32+
}
33+
}

0 commit comments

Comments
 (0)