org.apache.metamodel.couchdb

Class CouchDbDataContext

java.lang.Object

org.apache.metamodel.AbstractDataContext

org.apache.metamodel.QueryPostprocessDataContext

org.apache.metamodel.couchdb.CouchDbDataContext

All Implemented Interfaces:

HasReadTypeConverters, DataContext, DocumentSourceProvider, UpdateableDataContext

public class CouchDbDataContext
extends QueryPostprocessDataContext
implements UpdateableDataContext, DocumentSourceProvider

DataContext implementation for CouchDB

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_PORT
static String	FIELD_ID
static String	FIELD_REV
static String	SCHEMA_NAME

Fields inherited from class org.apache.metamodel.QueryPostprocessDataContext

INFORMATION_SCHEMA_NAME, SYSTEM_PROPERTY_CREATE_DEFAULT_TABLE_ALIAS

Constructor Summary

Constructors

Constructor and Description
CouchDbDataContext(org.ektorp.CouchDbInstance couchDbInstance)
CouchDbDataContext(org.ektorp.CouchDbInstance couchDbInstance, SimpleTableDef... tableDefs)
CouchDbDataContext(org.ektorp.CouchDbInstance couchDbInstance, String... databaseNames)
CouchDbDataContext(org.ektorp.http.HttpClient httpClient)
CouchDbDataContext(org.ektorp.http.HttpClient httpClient, SimpleTableDef... tableDefs)
CouchDbDataContext(org.ektorp.http.StdHttpClient.Builder httpClientBuilder)
CouchDbDataContext(org.ektorp.http.StdHttpClient.Builder httpClientBuilder, SimpleTableDef... tableDefs)

Method Summary

Modifier and Type	Method and Description
protected Number	executeCountQuery(Table table, List<FilterItem> whereItems, boolean functionApproximationAllowed) Executes a simple count query, if possible.
protected Row	executePrimaryKeyLookupQuery(Table table, List<SelectItem> selectItems, Column primaryKeyColumn, Object keyValue) Executes a query which obtains a row by primary key (as defined by Column.isPrimaryKey()).
UpdateSummary	executeUpdate(UpdateScript script) Submits an UpdateScript for execution on the DataContext.
org.ektorp.CouchDbInstance	getCouchDbInstance()
DocumentSource	getDocumentSourceForTable(String sourceCollectionName) Gets a DocumentSource for a particular source collection.
protected Schema	getMainSchema()
protected String	getMainSchemaName()
DocumentSource	getMixedDocumentSourceForSampling() Gets a DocumentSource containing documents of mixed origin and type.
protected DataSet	materializeMainSchemaTable(Table table, List<Column> columns, int maxRows) Executes a simple one-table query against a table in the main schema of the subclasses of this class.
protected DataSet	materializeMainSchemaTable(Table table, List<Column> columns, int firstRow, int maxRows) Executes a simple one-table query against a table in the main schema of the subclasses of this class.

Methods inherited from class org.apache.metamodel.QueryPostprocessDataContext

addConverter, executeQuery, getDefaultSchemaName, getSchemaByNameInternal, getSchemaNamesInternal, isMainSchemaTable, isScalarFunctionMaterialized, materializeFromItem, materializeMainSchemaTable, materializeMainSchemaTableSelect, materializeTable

Methods inherited from class org.apache.metamodel.AbstractDataContext

compileQuery, executeQuery, executeQuery, getColumnByQualifiedLabel, getDefaultSchema, getSchemaByName, getSchemaNames, getSchemas, getTableByQualifiedLabel, isQualifiedPathDelim, onSchemaCacheRefreshed, parseQuery, query, refreshSchemas

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.metamodel.DataContext

compileQuery, executeQuery, executeQuery, executeQuery, getColumnByQualifiedLabel, getDefaultSchema, getSchemaByName, getSchemaNames, getSchemas, getTableByQualifiedLabel, parseQuery, query, refreshSchemas

Field Detail

SCHEMA_NAME

public static final String SCHEMA_NAME

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

FIELD_ID

public static final String FIELD_ID

See Also:

Constant Field Values

FIELD_REV

public static final String FIELD_REV

See Also:

Constant Field Values

Constructor Detail

CouchDbDataContext

public CouchDbDataContext(org.ektorp.http.StdHttpClient.Builder httpClientBuilder,
                          SimpleTableDef... tableDefs)

CouchDbDataContext

public CouchDbDataContext(org.ektorp.http.StdHttpClient.Builder httpClientBuilder)

CouchDbDataContext

public CouchDbDataContext(org.ektorp.http.HttpClient httpClient,
                          SimpleTableDef... tableDefs)

CouchDbDataContext

public CouchDbDataContext(org.ektorp.http.HttpClient httpClient)

CouchDbDataContext

public CouchDbDataContext(org.ektorp.CouchDbInstance couchDbInstance)

CouchDbDataContext

public CouchDbDataContext(org.ektorp.CouchDbInstance couchDbInstance,
                          String... databaseNames)

CouchDbDataContext

public CouchDbDataContext(org.ektorp.CouchDbInstance couchDbInstance,
                          SimpleTableDef... tableDefs)

Method Detail

getCouchDbInstance

public org.ektorp.CouchDbInstance getCouchDbInstance()

getMainSchema

protected Schema getMainSchema()
                        throws MetaModelException

Specified by:

getMainSchema in class QueryPostprocessDataContext

Returns:

the main schema that subclasses of this class produce

Throws:

MetaModelException

getMainSchemaName

protected String getMainSchemaName()
                            throws MetaModelException

Specified by:

getMainSchemaName in class QueryPostprocessDataContext

Returns:

the name of the main schema that subclasses of this class produce

Throws:

MetaModelException

materializeMainSchemaTable

protected DataSet materializeMainSchemaTable(Table table,
                                             List<Column> columns,
                                             int firstRow,
                                             int maxRows)

Description copied from class: QueryPostprocessDataContext

Executes a simple one-table query against a table in the main schema of the subclasses of this class. This default implementation will delegate to QueryPostprocessDataContext.materializeMainSchemaTable(Table, List, int) and apply a FirstRowDataSet if necessary.

Overrides:

materializeMainSchemaTable in class QueryPostprocessDataContext

Returns:

materializeMainSchemaTable

protected DataSet materializeMainSchemaTable(Table table,
                                             List<Column> columns,
                                             int maxRows)

Description copied from class: QueryPostprocessDataContext

Executes a simple one-table query against a table in the main schema of the subclasses of this class.

Specified by:

materializeMainSchemaTable in class QueryPostprocessDataContext

Parameters:

table - the table to query

columns - the columns of the table to query

maxRows - the maximum amount of rows needed or -1 if all rows are wanted.

Returns:

a dataset with the raw table/column content.

executePrimaryKeyLookupQuery

protected Row executePrimaryKeyLookupQuery(Table table,
                                           List<SelectItem> selectItems,
                                           Column primaryKeyColumn,
                                           Object keyValue)

Description copied from class: QueryPostprocessDataContext

Executes a query which obtains a row by primary key (as defined by Column.isPrimaryKey()). This method is provided to allow subclasses to optimize lookup queries since they are quite common and often a datastore can retrieve the row using some specialized means which is much more performant than scanning all records manually.

Overrides:

executePrimaryKeyLookupQuery in class QueryPostprocessDataContext

Parameters:

table - the table on which the lookup is requested.

selectItems - the items to select from the lookup query.

primaryKeyColumn - the column that is the primary key

keyValue - the primary key value that is specified in the lookup query.

Returns:

the row if the particular table, or null if not available.

executeCountQuery

protected Number executeCountQuery(Table table,
                                   List<FilterItem> whereItems,
                                   boolean functionApproximationAllowed)

Description copied from class: QueryPostprocessDataContext

Executes a simple count query, if possible. This method is provided to allow subclasses to optimize count queries since they are quite common and often a datastore can retrieve the count using some specialized means which is much more performant than counting all records manually.

Overrides:

executeCountQuery in class QueryPostprocessDataContext

Parameters:

table - the table on which the count is requested.

whereItems - a (sometimes empty) list of WHERE items.

functionApproximationAllowed - whether approximation is allowed or not.

Returns:

the count of the particular table, or null if not available.

executeUpdate

public UpdateSummary executeUpdate(UpdateScript script)

Description copied from interface: UpdateableDataContext

Submits an UpdateScript for execution on the DataContext. Since implementations of the DataContext vary quite a lot, there is no golden rule as to how an update script will be executed. But the implementors should strive towards handling an UpdateScript as a single transactional change to the data store.

Specified by:

executeUpdate in interface UpdateableDataContext

Parameters:

script - the update script to execute

Returns:

a summary of the updates performed

getMixedDocumentSourceForSampling

public DocumentSource getMixedDocumentSourceForSampling()

Description copied from interface: DocumentSourceProvider

Gets a DocumentSource containing documents of mixed origin and type.

Specified by:

getMixedDocumentSourceForSampling in interface DocumentSourceProvider

Returns:

getDocumentSourceForTable

public DocumentSource getDocumentSourceForTable(String sourceCollectionName)

Description copied from interface: DocumentSourceProvider

Gets a DocumentSource for a particular source collection. See Document.getSourceCollectionName().

Specified by:

getDocumentSourceForTable in interface DocumentSourceProvider

Returns: