com.tmobile.opensource.casquatch

Class AbstractStatementFactory<E extends AbstractCasquatchEntity>

java.lang.Object

com.tmobile.opensource.casquatch.AbstractStatementFactory<E>

Direct Known Subclasses:

NodeMetaData_StatementFactory

public abstract class AbstractStatementFactory<E extends AbstractCasquatchEntity>
extends Object

Abstract Statement Factory to generate statements

Field Summary

Fields

Modifier and Type	Field and Description
protected com.datastax.oss.driver.api.querybuilder.delete.DeleteSelection	deleteStart
protected Class<E>	entityClass
protected com.datastax.oss.driver.api.querybuilder.insert.InsertInto	insertStart
protected com.datastax.oss.driver.api.querybuilder.select.Select	selectAllStart
protected com.datastax.oss.driver.api.querybuilder.select.Select	selectCountStart
protected com.datastax.oss.driver.api.querybuilder.select.Select	selectSolrCountStart
protected com.datastax.oss.driver.api.querybuilder.select.Select	selectSolrStart
protected com.datastax.oss.driver.api.core.CqlSession	session

Constructor Summary

Constructors

Constructor and Description
AbstractStatementFactory(Class<E> entityClass, com.datastax.oss.driver.api.core.CqlSession session) Query Factory Constructor

Method Summary

Modifier and Type	Method and Description
protected Boolean	allowQueryByType(Class clazz) Wrapper to filter out classes which cannot be queried
protected <T> com.datastax.oss.driver.api.core.cql.BoundStatementBuilder	bindIfMarked(com.datastax.oss.driver.api.core.cql.BoundStatementBuilder boundStatementBuilder, String field, T value, Class<T> fieldClass) Wrapper to bind a variable if it is marked
protected com.datastax.oss.driver.api.core.cql.BoundStatementBuilder	bindObject(com.datastax.oss.driver.api.core.cql.BoundStatementBuilder boundStatementBuilder, com.tmobile.opensource.casquatch.AbstractStatementFactory.SolrQueryEntity obj, QueryOptions queryOptions) Populate bind values of query using the provided object
protected abstract com.datastax.oss.driver.api.core.cql.BoundStatementBuilder	bindObject(com.datastax.oss.driver.api.core.cql.BoundStatementBuilder boundStatementBuilder, E obj, QueryOptions queryOptions) Populate bind values of query using the provided object
protected com.datastax.oss.driver.api.core.cql.BoundStatement	buildBoundStatement(com.datastax.oss.driver.api.querybuilder.BuildableQuery buildableQuery, Object obj, QueryOptions queryOptions, com.datastax.oss.driver.api.core.CqlSession bindToSession) Produce a bound statement while applying object and query options
com.datastax.oss.driver.api.core.cql.BoundStatement	count(E obj, QueryOptions queryOptions) Create a count statement for an object Example: select count(*) from TABLE where KEY=?
com.datastax.oss.driver.api.core.cql.BoundStatement	countSolr(String solrQuery, QueryOptions queryOptions) Create a count statement for a solr query Example: select count(*) from TABLE where solr_query=?
com.datastax.oss.driver.api.core.cql.BoundStatement	delete(E obj, QueryOptions queryOptions) Create a delete statement for an object Example: delete from TABLE where KEY=?
protected abstract com.datastax.oss.driver.api.querybuilder.delete.Delete	deleteObject(E obj, QueryOptions queryOptions) Create delete statement for object
com.datastax.oss.driver.api.core.cql.BoundStatement	get(E obj, QueryOptions queryOptions) Create a get statement for an object Example: select [COL1...COLN] from TABLE where KEY=?
com.datastax.oss.driver.api.core.cql.BoundStatement	getSolr(String solrQuery, QueryOptions queryOptions) Create a get statement for a solr query Example: select [COL1...COLN] from TABLE where solr_query=?
abstract com.datastax.oss.driver.api.core.CqlIdentifier	getTableName() Get the table name
protected abstract com.datastax.oss.driver.api.querybuilder.insert.RegularInsert	insertObject(E obj, QueryOptions queryOptions) Create insert statement for object
protected abstract E	map(com.datastax.oss.driver.api.core.data.GettableByName source) Map a source to an object
com.datastax.oss.driver.api.core.cql.BoundStatement	save(E obj, QueryOptions queryOptions) Create a save statement for an object Example: INSERE INTO TABLE ([COL1..COLN]) VALUES([?..?])
protected abstract com.datastax.oss.driver.api.querybuilder.select.Select	selectWhereObject(com.datastax.oss.driver.api.querybuilder.select.Select select, E obj, QueryOptions queryOptions) Append a where clause to a select query using non-null fields found in the provided object

Methods inherited from class java.lang.Object

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

Field Detail

deleteStart

protected final com.datastax.oss.driver.api.querybuilder.delete.DeleteSelection deleteStart

insertStart

protected final com.datastax.oss.driver.api.querybuilder.insert.InsertInto insertStart

selectAllStart

protected final com.datastax.oss.driver.api.querybuilder.select.Select selectAllStart

selectCountStart

protected final com.datastax.oss.driver.api.querybuilder.select.Select selectCountStart

selectSolrStart

protected final com.datastax.oss.driver.api.querybuilder.select.Select selectSolrStart

selectSolrCountStart

protected final com.datastax.oss.driver.api.querybuilder.select.Select selectSolrCountStart

session

protected final com.datastax.oss.driver.api.core.CqlSession session

entityClass

protected final Class<E extends AbstractCasquatchEntity> entityClass

Constructor Detail

AbstractStatementFactory

public AbstractStatementFactory(Class<E> entityClass,
                                com.datastax.oss.driver.api.core.CqlSession session)

Query Factory Constructor

Parameters:

entityClass - Class for table object

session - bind to session

Method Detail

bindObject

protected abstract com.datastax.oss.driver.api.core.cql.BoundStatementBuilder bindObject(com.datastax.oss.driver.api.core.cql.BoundStatementBuilder boundStatementBuilder,
                                                                                         E obj,
                                                                                         QueryOptions queryOptions)

Populate bind values of query using the provided object

Parameters:

boundStatementBuilder - bound statement to bind to

obj - partially populated object

queryOptions - query options to apply

Returns:

bound statement builder containing bound values

deleteObject

protected abstract com.datastax.oss.driver.api.querybuilder.delete.Delete deleteObject(E obj,
                                                                                       QueryOptions queryOptions)

Create delete statement for object

Parameters:

obj - populated object

queryOptions - query options to apply

Returns:

delete statement containing object

getTableName

public abstract com.datastax.oss.driver.api.core.CqlIdentifier getTableName()

Get the table name

Returns:

table name reference

insertObject

protected abstract com.datastax.oss.driver.api.querybuilder.insert.RegularInsert insertObject(E obj,
                                                                                              QueryOptions queryOptions)

Create insert statement for object

Parameters:

obj - populated object

queryOptions - query options to apply

Returns:

insert statement containing object

map

protected abstract E map(com.datastax.oss.driver.api.core.data.GettableByName source)

Map a source to an object

Parameters:

source - source, generally a row from a resultset

Returns:

populated object

selectWhereObject

protected abstract com.datastax.oss.driver.api.querybuilder.select.Select selectWhereObject(com.datastax.oss.driver.api.querybuilder.select.Select select,
                                                                                            E obj,
                                                                                            QueryOptions queryOptions)

Append a where clause to a select query using non-null fields found in the provided object

Parameters:

select - select to append to

obj - partially populated object

queryOptions - query options to apply

Returns:

select object containing where clause

allowQueryByType

protected Boolean allowQueryByType(Class clazz)

Wrapper to filter out classes which cannot be queried

Parameters:

clazz - class to check

Returns:

boolean indicating if class can be mapped

bindIfMarked

protected <T> com.datastax.oss.driver.api.core.cql.BoundStatementBuilder bindIfMarked(com.datastax.oss.driver.api.core.cql.BoundStatementBuilder boundStatementBuilder,
                                                                                      String field,
                                                                                      T value,
                                                                                      Class<T> fieldClass)

Wrapper to bind a variable if it is marked

Type Parameters:

T - generic for field

Parameters:

boundStatementBuilder - bound statement builder reference

field - field to bind

value - value to bind

fieldClass - class of field

Returns:

bound statement builder with object bound

bindObject

protected com.datastax.oss.driver.api.core.cql.BoundStatementBuilder bindObject(com.datastax.oss.driver.api.core.cql.BoundStatementBuilder boundStatementBuilder,
                                                                                com.tmobile.opensource.casquatch.AbstractStatementFactory.SolrQueryEntity obj,
                                                                                QueryOptions queryOptions)

Populate bind values of query using the provided object

Parameters:

boundStatementBuilder - bound statement to bind to

obj - partially populated object

queryOptions - query options to apply

Returns:

bound statement builder containing bound values

buildBoundStatement

protected com.datastax.oss.driver.api.core.cql.BoundStatement buildBoundStatement(com.datastax.oss.driver.api.querybuilder.BuildableQuery buildableQuery,
                                                                                  Object obj,
                                                                                  QueryOptions queryOptions,
                                                                                  com.datastax.oss.driver.api.core.CqlSession bindToSession)

Produce a bound statement while applying object and query options

Parameters:

buildableQuery - buildable query

obj - populated object

queryOptions - query options to apply

bindToSession - override session

Returns:

bound statement

count

public com.datastax.oss.driver.api.core.cql.BoundStatement count(E obj,
                                                                 QueryOptions queryOptions)

Create a count statement for an object Example: select count(*) from TABLE where KEY=?

Parameters:

obj - partially populated object

queryOptions - query options to apply

Returns:

bound statement for the query

countSolr

public com.datastax.oss.driver.api.core.cql.BoundStatement countSolr(String solrQuery,
                                                                     QueryOptions queryOptions)

Create a count statement for a solr query Example: select count(*) from TABLE where solr_query=?

Parameters:

solrQuery - solrQuery to search

queryOptions - query options to apply

Returns:

bound statement for the query

delete

public com.datastax.oss.driver.api.core.cql.BoundStatement delete(E obj,
                                                                  QueryOptions queryOptions)

Create a delete statement for an object Example: delete from TABLE where KEY=?

Parameters:

obj - partially populated object

queryOptions - query options to apply

Returns:

bound statement for the query

get

public com.datastax.oss.driver.api.core.cql.BoundStatement get(E obj,
                                                               QueryOptions queryOptions)

Create a get statement for an object Example: select [COL1...COLN] from TABLE where KEY=?

Parameters:

obj - partially populated object

queryOptions - query options to apply

Returns:

bound statement for the query

getSolr

public com.datastax.oss.driver.api.core.cql.BoundStatement getSolr(String solrQuery,
                                                                   QueryOptions queryOptions)

Create a get statement for a solr query Example: select [COL1...COLN] from TABLE where solr_query=?

Parameters:

solrQuery - solr query

queryOptions - query options to apply

Returns:

bound statement for the query

save

public com.datastax.oss.driver.api.core.cql.BoundStatement save(E obj,
                                                                QueryOptions queryOptions)

Create a save statement for an object Example: INSERE INTO TABLE ([COL1..COLN]) VALUES([?..?])

Parameters:

obj - partially populated object

queryOptions - query options to apply

Returns:

simple statement for the query