com.ing.data.cassandra.jdbc.commands

Class SourceCommandExecutor

java.lang.Object

com.ing.data.cassandra.jdbc.commands.SourceCommandExecutor

All Implemented Interfaces:

SpecialCommandExecutor

public class SourceCommandExecutor
extends Object
implements SpecialCommandExecutor

Executor for special command executing a CQL script file.

SOURCE <filename>: where filename is the path of the file containing the CQL statements to execute. If not absolute, the path is interpreted relative to the current working directory. The tilde shorthand notation ('~/dir') is supported for referring to the home directory.

The documentation of the original SOURCE command is available:

• in the Apache Cassandra® documentation
• in the DataStax CQL reference documentation

Constructor Summary

Constructors

Constructor and Description
SourceCommandExecutor(String filename) Constructor.

Method Summary

Modifier and Type	Method and Description
com.datastax.oss.driver.api.core.cql.ResultSet	execute(CassandraStatement statement, String cql) Executes the given CQL statement as a special command not handled by the Java driver.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SourceCommandExecutor

public SourceCommandExecutor(@Nonnull
                             String filename)

Constructor.

Parameters:

filename - The parameter filename of the command.

Method Detail

execute

public com.datastax.oss.driver.api.core.cql.ResultSet execute(CassandraStatement statement,
                                                              String cql)
                                                       throws SQLException

Executes the given CQL statement as a special command not handled by the Java driver.

Specified by:

execute in interface SpecialCommandExecutor

Parameters:

statement - The Cassandra statement.

cql - The CQL statement to execute.

Returns:

The result set corresponding to the CQL special command or an empty result set (see SpecialCommandsUtil.buildEmptyResultSet()) if the command is not expected to return some results.

Throws:

SQLException - if something went wrong with the Cassandra statement.