iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

java-21464: upgrade and move java-cassandra to jdk9 profile

Browse Source
This commit is contained in:
Ehsan Sasanianno
2023-09-03 14:15:55 +02:00
parent 02a680c9d6
commit 91ec107665
7 changed files with 88 additions and 146 deletions
Download Patch File Download Diff File Expand all files Collapse all files
persistence-modules/java-cassandra/src/main/java/com/baeldung/cassandra/batch/CassandraConnector.java
+2 -4
View File
@@ -5,8 +5,6 @@ import com.datastax.oss.driver.api.core.CqlSessionBuilder;
import java.net.InetSocketAddress;
import org.apache.commons.lang3.StringUtils;
public class CassandraConnector {
private CqlSession session;
@@ -14,11 +12,11 @@ public class CassandraConnector {
public void connect(final String node, final Integer port, final String dataCenter) {
CqlSessionBuilder builder = CqlSession.builder();
builder.addContactPoint(new InetSocketAddress(node, port));
if (StringUtils.isNotBlank(dataCenter)) {
if (dataCenter != null && !dataCenter.isEmpty()) {
builder.withLocalDatacenter(dataCenter);
}
session = builder.build();
session = builder.build();
}
public CqlSession getSession() {