001package org.xbib.elasticsearch.river.jdbc.strategy.mock;
002
003import org.elasticsearch.common.metrics.MeterMetric;
004import org.elasticsearch.common.unit.TimeValue;
005import org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand;
006import org.xbib.elasticsearch.plugin.jdbc.state.RiverState;
007import org.xbib.elasticsearch.river.jdbc.RiverContext;
008import org.xbib.elasticsearch.river.jdbc.RiverMouth;
009import org.xbib.elasticsearch.river.jdbc.RiverSource;
010
011import java.util.List;
012import java.util.Map;
013
014public class MockRiverContext implements RiverContext {
015
016    @Override
017    public RiverContext setDefinition(Map<String, Object> definition) {
018        return this;
019    }
020
021    @Override
022    public Map<String, Object> getDefinition() {
023        return null;
024    }
025
026    @Override
027    public RiverContext setRiverState(RiverState riverState) {
028        return this;
029    }
030
031    @Override
032    public RiverState getRiverState() {
033        return null;
034    }
035
036    @Override
037    public RiverContext setRiverSource(RiverSource riverSource) {
038        return this;
039    }
040
041    @Override
042    public RiverSource getRiverSource() {
043        return null;
044    }
045
046    @Override
047    public RiverContext setRiverMouth(RiverMouth riverMouth) {
048        return this;
049    }
050
051    @Override
052    public RiverMouth getRiverMouth() {
053        return null;
054    }
055
056    @Override
057    public RiverContext setMetric(MeterMetric metric) {
058        return this;
059    }
060
061    @Override
062    public MeterMetric getMetric() {
063        return null;
064    }
065
066    @Override
067    public RiverContext setScale(int scale) {
068        return this;
069    }
070
071    @Override
072    public RiverContext setRounding(String rounding) {
073        return this;
074    }
075
076    @Override
077    public RiverContext setStatements(List<SQLCommand> sql) {
078        return this;
079    }
080
081    @Override
082    public RiverContext setAutoCommit(boolean autocommit) {
083        return this;
084    }
085
086    @Override
087    public RiverContext setMaxRows(int maxRows) {
088        return this;
089    }
090
091    @Override
092    public RiverContext setFetchSize(int fetchSize) {
093        return this;
094    }
095
096    @Override
097    public RiverContext setRetries(int retries) {
098        return this;
099    }
100
101    @Override
102    public RiverContext setMaxRetryWait(TimeValue maxretrywait) {
103        return this;
104    }
105
106    @Override
107    public RiverContext setResultSetType(String resultSetType) {
108        return this;
109    }
110
111    @Override
112    public RiverContext setResultSetConcurrency(String resultSetConcurrency) {
113        return this;
114    }
115
116    @Override
117    public RiverContext shouldIgnoreNull(boolean shouldIgnoreNull) {
118        return this;
119    }
120
121    @Override
122    public RiverContext shouldPrepareResultSetMetadata(boolean shouldPrepareResultSetMetadata) {
123        return this;
124    }
125
126    @Override
127    public RiverContext shouldPrepareDatabaseMetadata(boolean shouldPrepareDatabaseMetadata) {
128        return this;
129    }
130
131    @Override
132    public RiverContext setQueryTimeout(int queryTimeout) {
133        return this;
134    }
135
136    @Override
137    public RiverContext setConnectionProperties(Map<String, Object> connectionProperties) {
138        return this;
139    }
140
141    @Override
142    public RiverContext setColumnNameMap(Map<String, Object> columnNameMap) {
143        return this;
144    }
145
146    @Override
147    public RiverContext shouldTreatBinaryAsString(boolean shouldTreatBinaryAsString) {
148        return this;
149    }
150
151    @Override
152    public RiverContext release() {
153        return this;
154    }
155
156}