Skip to content

Commit db5a227

Browse files
author
Otavio Santana
committed
Adds prepare statment to async method
1 parent f9f52d5 commit db5a227

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

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

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -313,6 +313,19 @@ public void execute(Statement statement, Consumer<List<ColumnEntity>> consumer)
313313
resultSet.addListener(executeAsync, executor);
314314
}
315315

316+
/**
317+
* Executes an query and uses as {@link CassandraPrepareStatment}
318+
*
319+
* @param query the query
320+
* @return the CassandraPrepareStatment instance
321+
* @throws NullPointerException when query is null
322+
*/
323+
public CassandraPrepareStatment nativeQueryPrepare(String query) throws NullPointerException {
324+
Objects.requireNonNull(query, "query is required");
325+
com.datastax.driver.core.PreparedStatement prepare = session.prepare(query);
326+
return new CassandraPrepareStatment(prepare, executor, session);
327+
}
328+
316329
@Override
317330
public void close() {
318331
session.close();

0 commit comments

Comments
 (0)