removes APIs from Cassandra

Author: otaviojava

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

@@ -132,11 +132,11 @@ public interface CassandraColumnFamilyManager extends ColumnFamilyManager {
     Stream<ColumnEntity> execute(Statement statement) throws NullPointerException;
 
     /**
-     * Executes an query and uses as {@link CassandraPrepareStatment}
+     * Executes an query and uses as {@link CassandraPreparedStatement}
      *
      * @param query the query
      * @return the CassandraPrepareStatment instance
      * @throws NullPointerException when query is null
      */
-    CassandraPrepareStatment nativeQueryPrepare(String query) throws NullPointerException;
+    CassandraPreparedStatement nativeQueryPrepare(String query) throws NullPointerException;
 }

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

@@ -18,7 +18,6 @@
 
 import com.datastax.driver.core.Cluster;
 import com.datastax.driver.core.Session;
-import jakarta.nosql.column.ColumnFamilyManagerAsyncFactory;
 import jakarta.nosql.column.ColumnFamilyManagerFactory;
 
 import java.util.List;
@@ -27,7 +26,7 @@
 /**
  * The Cassandra implementation to {@link ColumnFamilyManagerFactory}
  */
-public class CassandraColumnFamilyManagerFactory implements ColumnFamilyManagerFactory, ColumnFamilyManagerAsyncFactory {
+public class CassandraColumnFamilyManagerFactory implements ColumnFamilyManagerFactory {
 
     private final Cluster cluster;
 
@@ -50,11 +49,6 @@ public CassandraColumnFamilyManager get(String database) {
         return new DefaultCassandraColumnFamilyManager(cluster.connect(database), executor, database);
     }
 
-    @Override
-    public CassandraColumnFamilyManagerAsync getAsync(String database) throws UnsupportedOperationException, NullPointerException {
-        return new DefaultCassandraColumnFamilyManagerAsync(cluster.connect(database), executor, database);
-    }
-
     @Override
     public void close() {
         cluster.close();

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

@@ -19,7 +19,6 @@
 import com.datastax.driver.core.Cluster;
 import jakarta.nosql.Settings;
 import jakarta.nosql.column.ColumnConfiguration;
-import jakarta.nosql.column.ColumnConfigurationAsync;
 import org.eclipse.jnosql.diana.driver.ConfigurationReader;
 
 import java.util.HashMap;
@@ -29,7 +28,7 @@
 import static java.util.Objects.requireNonNull;
 
 /**
- * The Cassandra implementation to {@link ColumnConfiguration} and {@link ColumnConfigurationAsync} that returns
+ * The Cassandra implementation to {@link ColumnConfiguration}  that returns
  * {@link CassandraColumnFamilyManagerFactory}
  * This configuration reads "diana-cassandra.properties" files and has the following configuration:
  * <p>cassandra.host-: The Cassandra host as prefix, you can set how much you want just setting the number order,
@@ -44,7 +43,7 @@
  * @see CassandraConfigurations
  * @see OldCassandraConfigurations
  */
-public final class CassandraConfiguration implements ColumnConfiguration, ColumnConfigurationAsync {
+public final class CassandraConfiguration implements ColumnConfiguration {
 
     static final String CASSANDRA_FILE_CONFIGURATION = "diana-cassandra.properties";
 

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

@@ -17,19 +17,16 @@
 
 import com.datastax.driver.core.BoundStatement;
 import com.datastax.driver.core.ResultSet;
-import com.datastax.driver.core.ResultSetFuture;
 import com.datastax.driver.core.Session;
-import jakarta.nosql.ExecuteAsyncQueryException;
 import jakarta.nosql.column.ColumnEntity;
 
 import java.util.concurrent.Executor;
-import java.util.function.Consumer;
 import java.util.stream.Stream;
 
 /**
  * The Diana wrapper to {@link com.datastax.driver.core.PreparedStatement}
  */
-public class CassandraPrepareStatment {
+public class CassandraPreparedStatement {
 
     private final com.datastax.driver.core.PreparedStatement prepare;
 
@@ -39,7 +36,7 @@ public class CassandraPrepareStatment {
 
     private BoundStatement boundStatement;
 
-    CassandraPrepareStatment(com.datastax.driver.core.PreparedStatement prepare, Executor executor, Session session) {
+    CassandraPreparedStatement(com.datastax.driver.core.PreparedStatement prepare, Executor executor, Session session) {
         this.prepare = prepare;
         this.executor = executor;
         this.session = session;
@@ -51,27 +48,14 @@ public Stream<ColumnEntity> executeQuery() {
         return resultSet.all().stream().map(CassandraConverter::toDocumentEntity);
     }
 
-    /**
-     * Executes and call the callback with the result
-     *
-     * @param consumer the callback
-     * @throws ExecuteAsyncQueryException when has async error
-     * @throws NullPointerException       when consumer is null
-     */
-    public void executeQueryAsync(Consumer<Stream<ColumnEntity>> consumer) throws ExecuteAsyncQueryException, NullPointerException {
-        loadBoundStatment();
-        ResultSetFuture resultSet = session.executeAsync(boundStatement);
-        CassandraReturnQueryAsync executeAsync = new CassandraReturnQueryAsync(resultSet, consumer);
-        resultSet.addListener(executeAsync, executor);
-    }
 
     /**
      * Bind
      *
      * @param values the values
      * @return this instance
      */
-    public CassandraPrepareStatment bind(Object... values) {
+    public CassandraPreparedStatement bind(Object... values) {
         boundStatement = prepare.bind(values);
         return this;
     }