org.xbib.elasticsearch.river.jdbc.strategy.mock

Class MockRiverContext

java.lang.Object

org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

All Implemented Interfaces:

RiverContext

public class MockRiverContext
extends Object
implements RiverContext

Constructor Summary

Constructors

Constructor and Description
MockRiverContext()

Method Summary

Methods

Modifier and Type	Method and Description
Map<String,Object>	getDefinition()
org.elasticsearch.common.metrics.MeterMetric	getMetric()
RiverMouth	getRiverMouth()
RiverSource	getRiverSource()
RiverState	getRiverState()
RiverContext	release()
RiverContext	setAutoCommit(boolean autocommit)
RiverContext	setColumnNameMap(Map<String,Object> columnNameMap)
RiverContext	setConnectionProperties(Map<String,Object> connectionProperties)
RiverContext	setDefinition(Map<String,Object> definition)
RiverContext	setFetchSize(int fetchSize)
RiverContext	setMaxRetryWait(org.elasticsearch.common.unit.TimeValue maxretrywait)
RiverContext	setMaxRows(int maxRows)
RiverContext	setMetric(org.elasticsearch.common.metrics.MeterMetric metric)
RiverContext	setQueryTimeout(int queryTimeout)
RiverContext	setResultSetConcurrency(String resultSetConcurrency)
RiverContext	setResultSetType(String resultSetType)
RiverContext	setRetries(int retries)
RiverContext	setRiverMouth(RiverMouth riverMouth)
RiverContext	setRiverSource(RiverSource riverSource)
RiverContext	setRiverState(RiverState riverState)
RiverContext	setRounding(String rounding)
RiverContext	setScale(int scale)
RiverContext	setStatements(List<SQLCommand> sql)
RiverContext	shouldIgnoreNull(boolean shouldIgnoreNull)
RiverContext	shouldPrepareDatabaseMetadata(boolean shouldPrepareDatabaseMetadata)
RiverContext	shouldPrepareResultSetMetadata(boolean shouldPrepareResultSetMetadata)
RiverContext	shouldTreatBinaryAsString(boolean shouldTreatBinaryAsString)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockRiverContext

public MockRiverContext()

Method Detail

setDefinition

public RiverContext setDefinition(Map<String,Object> definition)

Specified by:

setDefinition in interface RiverContext

getDefinition

public Map<String,Object> getDefinition()

Specified by:

getDefinition in interface RiverContext

setRiverState

public RiverContext setRiverState(RiverState riverState)

Specified by:

setRiverState in interface RiverContext

getRiverState

public RiverState getRiverState()

Specified by:

getRiverState in interface RiverContext

setRiverSource

public RiverContext setRiverSource(RiverSource riverSource)

Specified by:

setRiverSource in interface RiverContext

getRiverSource

public RiverSource getRiverSource()

Specified by:

getRiverSource in interface RiverContext

setRiverMouth

public RiverContext setRiverMouth(RiverMouth riverMouth)

Specified by:

setRiverMouth in interface RiverContext

getRiverMouth

public RiverMouth getRiverMouth()

Specified by:

getRiverMouth in interface RiverContext

setMetric

public RiverContext setMetric(org.elasticsearch.common.metrics.MeterMetric metric)

Specified by:

setMetric in interface RiverContext

getMetric

public org.elasticsearch.common.metrics.MeterMetric getMetric()

Specified by:

getMetric in interface RiverContext

setScale

public RiverContext setScale(int scale)

Specified by:

setScale in interface RiverContext

setRounding

public RiverContext setRounding(String rounding)

Specified by:

setRounding in interface RiverContext

setStatements

public RiverContext setStatements(List<SQLCommand> sql)

Specified by:

setStatements in interface RiverContext

setAutoCommit

public RiverContext setAutoCommit(boolean autocommit)

Specified by:

setAutoCommit in interface RiverContext

setMaxRows

public RiverContext setMaxRows(int maxRows)

Specified by:

setMaxRows in interface RiverContext

setFetchSize

public RiverContext setFetchSize(int fetchSize)

Specified by:

setFetchSize in interface RiverContext

setRetries

public RiverContext setRetries(int retries)

Specified by:

setRetries in interface RiverContext

setMaxRetryWait

public RiverContext setMaxRetryWait(org.elasticsearch.common.unit.TimeValue maxretrywait)

Specified by:

setMaxRetryWait in interface RiverContext

setResultSetType

public RiverContext setResultSetType(String resultSetType)

Specified by:

setResultSetType in interface RiverContext

setResultSetConcurrency

public RiverContext setResultSetConcurrency(String resultSetConcurrency)

Specified by:

setResultSetConcurrency in interface RiverContext

shouldIgnoreNull

public RiverContext shouldIgnoreNull(boolean shouldIgnoreNull)

Specified by:

shouldIgnoreNull in interface RiverContext

shouldPrepareResultSetMetadata

public RiverContext shouldPrepareResultSetMetadata(boolean shouldPrepareResultSetMetadata)

Specified by:

shouldPrepareResultSetMetadata in interface RiverContext

shouldPrepareDatabaseMetadata

public RiverContext shouldPrepareDatabaseMetadata(boolean shouldPrepareDatabaseMetadata)

Specified by:

shouldPrepareDatabaseMetadata in interface RiverContext

setQueryTimeout

public RiverContext setQueryTimeout(int queryTimeout)

Specified by:

setQueryTimeout in interface RiverContext

setConnectionProperties

public RiverContext setConnectionProperties(Map<String,Object> connectionProperties)

Specified by:

setConnectionProperties in interface RiverContext

setColumnNameMap

public RiverContext setColumnNameMap(Map<String,Object> columnNameMap)

Specified by:

setColumnNameMap in interface RiverContext

shouldTreatBinaryAsString

public RiverContext shouldTreatBinaryAsString(boolean shouldTreatBinaryAsString)

Specified by:

shouldTreatBinaryAsString in interface RiverContext

release

public RiverContext release()

Specified by:

release in interface RiverContext