From c450d63194d2e44bc171eb208121e7bffa1f81e3 Mon Sep 17 00:00:00 2001
From: Valery Kharseko <vharseko@3a-systems.ru>
Date: Sat, 03 Aug 2024 06:55:50 +0000
Subject: [PATCH] [#368] CASSANDRA ADD property -Dkeyspace=ldap_opendj (#370)

---
 opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java |    6 +++---
 1 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java b/opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java
index 547b085..8a94353 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/backends/cassandra/Storage.java
@@ -11,7 +11,7 @@
  * Header, with the fields enclosed by brackets [] replaced by your own identifying
  * information: "Portions Copyright [year] [name of copyright owner]".
  *
- * Copyright 2023 3A Systems, LLC.
+ * Copyright 2023-2024 3A Systems, LLC.
  */
 package org.opends.server.backends.cassandra;
 
@@ -129,7 +129,7 @@
 	public void open(AccessMode accessMode) throws Exception {
 		this.accessMode=accessMode;
 		session=CqlSession.builder()
-				.withApplicationName("OpenDJ "+config.getDBDirectory()+"."+config.getBackendId())
+				.withApplicationName("OpenDJ "+getKeyspaceName()+"."+config.getBackendId())
 				.withConfigLoader(DriverConfigLoader.fromDefaults(Storage.class.getClassLoader()))
 				.build();
 		if (AccessMode.READ_WRITE.equals(accessMode)) {
@@ -154,7 +154,7 @@
 	}
 
 	String getKeyspaceName() {
-		return "\""+config.getDBDirectory().replaceAll("[^a-zA-z0-9_]", "_")+"\"";
+		return "\""+System.getProperty("keyspace",config.getDBDirectory()).replaceAll("[^a-zA-z0-9_]", "_")+"\"";
 	}
 	
 	String getTableName() {

--
Gitblit v1.10.0