Comments out old cassandra classes

This commit is contained in:
Spencer Gibb
2020-01-22 15:42:17 -05:00
parent d3ab6c918c
commit 15257f2e87

View File

@@ -20,14 +20,10 @@ import java.net.InetSocketAddress;
import java.util.HashMap;
import java.util.Map;
import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.PlainTextAuthProvider;
import com.datastax.driver.core.Session;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -37,9 +33,13 @@ import org.springframework.cloud.vault.util.VaultRule;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.vault.core.VaultOperations;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.Assume.assumeTrue;
// FIXME: 3.0.0
//import com.datastax.driver.core.Cluster;
//import com.datastax.driver.core.PlainTextAuthProvider;
//import com.datastax.driver.core.Session;
/**
* Integration tests using the cassandra secret backend. In case this test should fail
* because of SSL make sure you run the test within the
@@ -72,8 +72,8 @@ public class VaultConfigCassandraTests {
@Value("${spring.data.cassandra.password}")
String password;
@Autowired
Cluster cluster;
// @Autowired
// Cluster cluster;
/**
* Initialize the cassandra secret backend.
@@ -111,24 +111,24 @@ public class VaultConfigCassandraTests {
@Test
public void shouldConnectUsingCluster() {
this.cluster.connect().close();
// this.cluster.connect().close();
}
@Test
public void shouldUseAuthenticationSet() {
assertThat(this.cluster.getConfiguration().getProtocolOptions().getAuthProvider())
.isInstanceOf(PlainTextAuthProvider.class);
// assertThat(this.cluster.getConfiguration().getProtocolOptions().getAuthProvider())
// .isInstanceOf(PlainTextAuthProvider.class);
}
@Test
public void shouldConnectUsingCassandraClient() {
try (Cluster cluster = Cluster.builder().addContactPoint(CASSANDRA_HOST)
.withAuthProvider(new PlainTextAuthProvider(this.username, this.password))
.withoutJMXReporting().build()) {
Session session = cluster.connect();
session.close();
}
// try (Cluster cluster = Cluster.builder().addContactPoint(CASSANDRA_HOST)
// .withAuthProvider(new PlainTextAuthProvider(this.username, this.password))
// .withoutJMXReporting().build()) {
// Session session = cluster.connect();
// session.close();
// }
}
@SpringBootApplication