net.sf.jkniv.whinstone.cassandra.statement

Class CassandraStatementAdapter<T,R>

java.lang.Object

net.sf.jkniv.whinstone.cassandra.statement.CassandraStatementAdapter<T,R>

All Implemented Interfaces:

StatementAdapter<T,com.datastax.driver.core.Row>

public class CassandraStatementAdapter<T,R>
extends Object
implements StatementAdapter<T,com.datastax.driver.core.Row>

Constructor Summary

Constructors

Constructor and Description
CassandraStatementAdapter(com.datastax.driver.core.Session session, com.datastax.driver.core.Statement stmt, Queryable queryable, RegisterType registerType)

Method Summary

Modifier and Type	Method and Description
StatementAdapter<T,com.datastax.driver.core.Row>	bind(Param... values) Bind the varargs parameters to statement
StatementAdapter<T,com.datastax.driver.core.Row>	bind(Param value) Bind an argument to a position parameter.
StatementAdapter<T,com.datastax.driver.core.Row>	bind(String name, Object value) Bind an argument to a named parameter.
void	bindKey() bind the keys generated
void	close()
int	execute()
int	reset() reset the internal index position parameter to zero.
List<T>	rows()
void	setFetchSize(int rows) Set the number of rows that should be fetched when the statement hit the database.
StatementAdapter<T,com.datastax.driver.core.Row>	with(AutoKey generateKey)
StatementAdapter<T,com.datastax.driver.core.Row>	with(ResultRow<T,com.datastax.driver.core.Row> resultRow) result row

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraStatementAdapter

public CassandraStatementAdapter(com.datastax.driver.core.Session session,
                                 com.datastax.driver.core.Statement stmt,
                                 Queryable queryable,
                                 RegisterType registerType)

Method Detail

with

public StatementAdapter<T,com.datastax.driver.core.Row> with(ResultRow<T,com.datastax.driver.core.Row> resultRow)

Description copied from interface: StatementAdapter

result row

Specified by:

with in interface StatementAdapter<T,com.datastax.driver.core.Row>

Parameters:

resultRow - how to process the rows

Returns:

instance of this object

bind

public StatementAdapter<T,com.datastax.driver.core.Row> bind(String name,
                                                             Object value)

Description copied from interface: StatementAdapter

Bind an argument to a named parameter.

Specified by:

bind in interface StatementAdapter<T,com.datastax.driver.core.Row>

Parameters:

name - of parameter

value - of parameter

Returns:

instance of this object

bind

public StatementAdapter<T,com.datastax.driver.core.Row> bind(Param value)

Description copied from interface: StatementAdapter

Bind an argument to a position parameter.

Specified by:

bind in interface StatementAdapter<T,com.datastax.driver.core.Row>

Parameters:

value - of parameter

Returns:

instance of this object

bind

public StatementAdapter<T,com.datastax.driver.core.Row> bind(Param... values)

Description copied from interface: StatementAdapter

Bind the varargs parameters to statement

Specified by:

bind in interface StatementAdapter<T,com.datastax.driver.core.Row>

Parameters:

values - of parameters as arbitrary number

Returns:

instance of this object

rows

public List<T> rows()

Specified by:

rows in interface StatementAdapter<T,com.datastax.driver.core.Row>

bindKey

public void bindKey()

Description copied from interface: StatementAdapter

bind the keys generated

Specified by:

bindKey in interface StatementAdapter<T,com.datastax.driver.core.Row>

with

public StatementAdapter<T,com.datastax.driver.core.Row> with(AutoKey generateKey)

Specified by:

with in interface StatementAdapter<T,com.datastax.driver.core.Row>

execute

public int execute()

Specified by:

execute in interface StatementAdapter<T,com.datastax.driver.core.Row>

reset

public int reset()

Description copied from interface: StatementAdapter

reset the internal index position parameter to zero.

Specified by:

reset in interface StatementAdapter<T,com.datastax.driver.core.Row>

Returns:

return current index position before reset

close

public void close()

Specified by:

close in interface StatementAdapter<T,com.datastax.driver.core.Row>

setFetchSize

public void setFetchSize(int rows)

Description copied from interface: StatementAdapter

Set the number of rows that should be fetched when the statement hit the database.

Specified by:

setFetchSize in interface StatementAdapter<T,com.datastax.driver.core.Row>

Parameters:

rows - the number of rows to fetch