Skip to content

Commit 4152026

Browse files
committed
adds passwords in configuration
1 parent 9178101 commit 4152026

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

cassandra-driver/src/main/java/org/eclipse/jnosql/diana/cassandra/column/CassandraProperties.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,10 @@ class CassandraProperties {
4242

4343
private Optional<String> name;
4444

45+
private Optional<String> user;
46+
47+
private Optional<String> password;
48+
4549
private int port;
4650

4751
private String dataCenter;
@@ -63,6 +67,9 @@ public CqlSessionBuilder createCluster() {
6367
nodes.stream().map(h -> new InetSocketAddress(h, port)).forEach(builder::addContactPoint);
6468
name.ifPresent(builder::withApplicationName);
6569
builder.withLocalDatacenter(dataCenter);
70+
if (user.isPresent()) {
71+
builder.withAuthCredentials(user.orElse(""), password.orElse(""));
72+
}
6673
return builder;
6774
}
6875

@@ -91,6 +98,9 @@ public static CassandraProperties of(Map<String, String> configurations) {
9198
.map(Object::toString);
9299
cp.dataCenter = settings.get(CassandraConfigurations.DATA_CENTER.get()).map(Object::toString)
93100
.orElse(DEFAULT_DATA_CENTER);
101+
102+
cp.user = settings.get(Configurations.USER.get()).map(Object::toString);
103+
cp.password = settings.get(Configurations.PASSWORD.get()).map(Object::toString);
94104
return cp;
95105
}
96106
}

0 commit comments

Comments
 (0)