info.archinnov.achilles.script

Class ScriptExecutor

java.lang.Object

info.archinnov.achilles.script.ScriptExecutor

public class ScriptExecutor
extends Object

Facility class to execute a CQL script file or a plain CQL statement

Constructor Summary

Constructors

Constructor and Description
ScriptExecutor(com.datastax.driver.core.Session session)

Method Summary

Modifier and Type	Method and Description
protected List<com.datastax.driver.core.SimpleStatement>	buildStatements(List<String> lines)
com.datastax.driver.core.ResultSet	execute(com.datastax.driver.core.Statement statement) Execute a CQL statement
com.datastax.driver.core.ResultSet	execute(String statement) Execute a plain CQL string statement
AchillesFuture<com.datastax.driver.core.ResultSet>	executeAsync(com.datastax.driver.core.Statement statement) Execute a CQL statement asynchronously
AchillesFuture<com.datastax.driver.core.ResultSet>	executeAsync(String statement) Execute a plain CQL string statement asynchronously
void	executeScript(String scriptLocation) Execute a CQL script file located in the class path
protected List<String>	loadScriptAsLines(String scriptLocation)

Methods inherited from class java.lang.Object

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

Constructor Detail

ScriptExecutor

public ScriptExecutor(com.datastax.driver.core.Session session)

Method Detail

executeScript

public void executeScript(String scriptLocation)

Execute a CQL script file located in the class path

Parameters:

scriptLocation - the location of the script file in the class path

execute

public com.datastax.driver.core.ResultSet execute(String statement)

Execute a plain CQL string statement

Parameters:

statement - plain CQL string statement

Returns:

the resultSet

execute

public com.datastax.driver.core.ResultSet execute(com.datastax.driver.core.Statement statement)

Execute a CQL statement

Parameters:

statement - CQL statement

Returns:

the resultSet

executeAsync

public AchillesFuture<com.datastax.driver.core.ResultSet> executeAsync(String statement)

Execute a plain CQL string statement asynchronously

Parameters:

statement - the CQL string statement

Returns:

AchillesFuture<ResultSet>

executeAsync

public AchillesFuture<com.datastax.driver.core.ResultSet> executeAsync(com.datastax.driver.core.Statement statement)

Execute a CQL statement asynchronously

Parameters:

statement - CQL statement

Returns:

AchillesFuture<ResultSet>

loadScriptAsLines

protected List<String> loadScriptAsLines(String scriptLocation)

buildStatements

protected List<com.datastax.driver.core.SimpleStatement> buildStatements(List<String> lines)