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

Class MockRiverSource

java.lang.Object

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

All Implemented Interfaces:

RiverSource<MockRiverContext>

public class MockRiverSource
extends Object
implements RiverSource<MockRiverContext>

Author:

Piotr Śliwa

Constructor Summary

Constructors

Constructor and Description
MockRiverSource()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterFetch()
void	afterRows(ResultSet result, KeyValueStreamListener listener)
void	afterRows(SQLCommand command, ResultSet result, KeyValueStreamListener listener)
void	beforeFetch()
void	beforeRows(ResultSet result, KeyValueStreamListener listener)
void	beforeRows(SQLCommand command, ResultSet result, KeyValueStreamListener listener)
RiverSource	bind(PreparedStatement statement, List<Object> values)
RiverSource	close(ResultSet result)
RiverSource	close(Statement statement)
RiverSource	closeReading()
RiverSource	closeWriting()
ResultSet	executeQuery(PreparedStatement statement)
ResultSet	executeQuery(Statement statement, String sql)
RiverSource	executeUpdate(PreparedStatement statement)
RiverSource	executeUpdate(Statement statement, String sql)
void	fetch()
Connection	getConnectionForReading()
Connection	getConnectionForWriting()
Locale	getLocale()
TimeZone	getTimeZone()
RiverSource<MockRiverContext>	newInstance()
boolean	nextRow(ResultSet result, KeyValueStreamListener listener)
boolean	nextRow(SQLCommand command, ResultSet result, KeyValueStreamListener listener)
Object	parseType(ResultSet result, Integer num, int type, Locale locale)
PreparedStatement	prepareQuery(String sql)
PreparedStatement	prepareUpdate(String sql)
RiverSource	register(CallableStatement statement, Map<String,Object> values)
void	resume()
RiverSource	setLocale(Locale locale)
RiverSource	setPassword(String password)
RiverSource	setRiverContext(MockRiverContext context)
RiverSource	setTimeZone(TimeZone timezone)
RiverSource	setUrl(String url)
RiverSource	setUser(String user)
void	shutdown()
String	strategy()
void	suspend()

Methods inherited from class java.lang.Object

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

Constructor Detail

MockRiverSource

public MockRiverSource()

Method Detail

strategy

public String strategy()

Specified by:

strategy in interface RiverSource<MockRiverContext>

newInstance

public RiverSource<MockRiverContext> newInstance()

Specified by:

newInstance in interface RiverSource<MockRiverContext>

setRiverContext

public RiverSource setRiverContext(MockRiverContext context)

Specified by:

setRiverContext in interface RiverSource<MockRiverContext>

beforeFetch

public void beforeFetch()
                 throws Exception

Specified by:

beforeFetch in interface RiverSource<MockRiverContext>

Throws:

Exception

afterFetch

public void afterFetch()
                throws Exception

Specified by:

afterFetch in interface RiverSource<MockRiverContext>

Throws:

Exception

fetch

public void fetch()
           throws SQLException,
                  IOException

Specified by:

fetch in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

setUrl

public RiverSource setUrl(String url)

Specified by:

setUrl in interface RiverSource<MockRiverContext>

setUser

public RiverSource setUser(String user)

Specified by:

setUser in interface RiverSource<MockRiverContext>

setPassword

public RiverSource setPassword(String password)

Specified by:

setPassword in interface RiverSource<MockRiverContext>

getConnectionForReading

public Connection getConnectionForReading()
                                   throws SQLException

Specified by:

getConnectionForReading in interface RiverSource<MockRiverContext>

Throws:

SQLException

getConnectionForWriting

public Connection getConnectionForWriting()
                                   throws SQLException

Specified by:

getConnectionForWriting in interface RiverSource<MockRiverContext>

Throws:

SQLException

prepareQuery

public PreparedStatement prepareQuery(String sql)
                               throws SQLException

Specified by:

prepareQuery in interface RiverSource<MockRiverContext>

Throws:

SQLException

prepareUpdate

public PreparedStatement prepareUpdate(String sql)
                                throws SQLException

Specified by:

prepareUpdate in interface RiverSource<MockRiverContext>

Throws:

SQLException

bind

public RiverSource bind(PreparedStatement statement,
               List<Object> values)
                 throws SQLException

Specified by:

bind in interface RiverSource<MockRiverContext>

Throws:

SQLException

register

public RiverSource register(CallableStatement statement,
                   Map<String,Object> values)
                     throws SQLException

Specified by:

register in interface RiverSource<MockRiverContext>

Throws:

SQLException

executeQuery

public ResultSet executeQuery(PreparedStatement statement)
                       throws SQLException

Specified by:

executeQuery in interface RiverSource<MockRiverContext>

Throws:

SQLException

executeQuery

public ResultSet executeQuery(Statement statement,
                     String sql)
                       throws SQLException

Specified by:

executeQuery in interface RiverSource<MockRiverContext>

Throws:

SQLException

executeUpdate

public RiverSource executeUpdate(PreparedStatement statement)
                          throws SQLException

Specified by:

executeUpdate in interface RiverSource<MockRiverContext>

Throws:

SQLException

executeUpdate

public RiverSource executeUpdate(Statement statement,
                        String sql)
                          throws SQLException

Specified by:

executeUpdate in interface RiverSource<MockRiverContext>

Throws:

SQLException

beforeRows

public void beforeRows(ResultSet result,
              KeyValueStreamListener listener)
                throws SQLException,
                       IOException

Specified by:

beforeRows in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

beforeRows

public void beforeRows(SQLCommand command,
              ResultSet result,
              KeyValueStreamListener listener)
                throws SQLException,
                       IOException

Specified by:

beforeRows in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

nextRow

public boolean nextRow(ResultSet result,
              KeyValueStreamListener listener)
                throws SQLException,
                       IOException

Specified by:

nextRow in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

nextRow

public boolean nextRow(SQLCommand command,
              ResultSet result,
              KeyValueStreamListener listener)
                throws SQLException,
                       IOException

Specified by:

nextRow in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

afterRows

public void afterRows(ResultSet result,
             KeyValueStreamListener listener)
               throws SQLException,
                      IOException

Specified by:

afterRows in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

afterRows

public void afterRows(SQLCommand command,
             ResultSet result,
             KeyValueStreamListener listener)
               throws SQLException,
                      IOException

Specified by:

afterRows in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

parseType

public Object parseType(ResultSet result,
               Integer num,
               int type,
               Locale locale)
                 throws SQLException,
                        IOException,
                        ParseException

Specified by:

parseType in interface RiverSource<MockRiverContext>

Throws:

SQLException

IOException

ParseException

close

public RiverSource close(ResultSet result)
                  throws SQLException

Specified by:

close in interface RiverSource<MockRiverContext>

Throws:

SQLException

close

public RiverSource close(Statement statement)
                  throws SQLException

Specified by:

close in interface RiverSource<MockRiverContext>

Throws:

SQLException

closeReading

public RiverSource closeReading()

Specified by:

closeReading in interface RiverSource<MockRiverContext>

closeWriting

public RiverSource closeWriting()

Specified by:

closeWriting in interface RiverSource<MockRiverContext>

setLocale

public RiverSource setLocale(Locale locale)

Specified by:

setLocale in interface RiverSource<MockRiverContext>

getLocale

public Locale getLocale()

Specified by:

getLocale in interface RiverSource<MockRiverContext>

setTimeZone

public RiverSource setTimeZone(TimeZone timezone)

Specified by:

setTimeZone in interface RiverSource<MockRiverContext>

getTimeZone

public TimeZone getTimeZone()

Specified by:

getTimeZone in interface RiverSource<MockRiverContext>

suspend

public void suspend()
             throws Exception

Specified by:

suspend in interface RiverSource<MockRiverContext>

Throws:

Exception

resume

public void resume()
            throws Exception

Specified by:

resume in interface RiverSource<MockRiverContext>

Throws:

Exception

shutdown

public void shutdown()
              throws IOException

Specified by:

shutdown in interface RiverSource<MockRiverContext>

Throws:

IOException