This commit is contained in:
Alfredo Oliviero 2024-09-27 14:45:46 +02:00
parent cd27bda1c5
commit 4606421973
4 changed files with 11 additions and 6 deletions

View File

@ -1,7 +1,5 @@
package org.gcube.portal.databook.server; package org.gcube.portal.databook.server;
import static org.gcube.portal.databook.server.Schema.CREATION_TIME;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.time.Duration; import java.time.Duration;
import java.util.Arrays; import java.util.Arrays;
@ -24,6 +22,7 @@ import com.datastax.oss.driver.api.querybuilder.SchemaBuilder;
/** /**
* @author Massimiliano Assante ISTI-CNR * @author Massimiliano Assante ISTI-CNR
* @author Ahmed Ibrahim ISTI-CNR * @author Ahmed Ibrahim ISTI-CNR
* @author Alfredo Oliviero ISTI-CNR
* *
*/ */
public class CassandraClusterConnection { public class CassandraClusterConnection {
@ -62,9 +61,10 @@ public class CassandraClusterConnection {
} }
/** /**
*
* @param dropSchema set true if you want do drop the current and set up new one * @param dropSchema set true if you want do drop the current and set up new one
* the connection to cassandra cluster * the connection to cassandra cluster
* @param forceCreateNew
* @throws Exception
*/ */
public CassandraClusterConnection(boolean dropSchema, boolean forceCreateNew) throws Exception { public CassandraClusterConnection(boolean dropSchema, boolean forceCreateNew) throws Exception {
if (hosts == null || datacenterName == null || keyspaceName == null) { if (hosts == null || datacenterName == null || keyspaceName == null) {
@ -109,9 +109,11 @@ public class CassandraClusterConnection {
return myKeyspaceSession; return myKeyspaceSession;
} }
/** /**
* @param dropSchema set true if you want to drop the current and set up new one * @param dropSchema set true if you want to drop the current and set up new one
* the connection to cassandra cluster * the connection to cassandra cluster
* @param forceExecution
*/ */
public void SetUpKeySpaces(boolean dropSchema, boolean forceExecution) { public void SetUpKeySpaces(boolean dropSchema, boolean forceExecution) {
boolean createNew = false; boolean createNew = false;

View File

@ -73,6 +73,8 @@ import com.datastax.oss.driver.api.querybuilder.update.Update;
* @author Massimiliano Assante ISTI-CNR * @author Massimiliano Assante ISTI-CNR
* @author Costantino Perciante ISTI-CNR * @author Costantino Perciante ISTI-CNR
* @author Ahmed Ibrahim ISTI-CNR * @author Ahmed Ibrahim ISTI-CNR
* @author Alfredo Oliviero ISTI-CNR
*
* This class is used for querying and adding data to Cassandra via * This class is used for querying and adding data to Cassandra via
* Datastax High Level API * Datastax High Level API
*/ */
@ -2555,8 +2557,6 @@ public final class DBCassandraAstyanaxImpl implements DatabookStore {
toReturn.add(toProcess[i]); toReturn.add(toProcess[i]);
} }
return toReturn; return toReturn;
} }
/** /**

View File

@ -39,6 +39,8 @@ import com.datastax.oss.driver.api.core.CqlSession;
/** /**
* @author Massimiliano Assante ISTI-CNR * @author Massimiliano Assante ISTI-CNR
* @author Costantino Perciante ISTI-CNR * @author Costantino Perciante ISTI-CNR
* @author Alfredo Oliviero ISTI-CNR
*
* <class>DatabookStore</class> is the high level interface for querying and adding data to DatabookStore * <class>DatabookStore</class> is the high level interface for querying and adding data to DatabookStore
*/ */
public interface DatabookStore { public interface DatabookStore {

View File

@ -5,6 +5,7 @@ import com.datastax.oss.driver.api.core.CqlIdentifier;
/** /**
* @author Massimiliano Assante ISTI-CNR * @author Massimiliano Assante ISTI-CNR
* @author Ahmed Ibrahim ISTI-CNR * @author Ahmed Ibrahim ISTI-CNR
* @author Alfredo Oliviero ISTI-CNR
* *
* @version 2.0.0 October 2023 * @version 2.0.0 October 2023
* *