1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.driver.state.circuit.statement;
19
20 import org.apache.shardingsphere.driver.executor.DriverExecutor;
21 import org.apache.shardingsphere.driver.jdbc.core.statement.StatementManager;
22 import org.apache.shardingsphere.driver.jdbc.unsupported.AbstractUnsupportedOperationPreparedStatement;
23 import org.apache.shardingsphere.driver.state.circuit.connection.CircuitBreakerConnection;
24 import org.apache.shardingsphere.driver.state.circuit.resultset.CircuitBreakerResultSet;
25
26 import java.io.InputStream;
27 import java.io.Reader;
28 import java.math.BigDecimal;
29 import java.net.URL;
30 import java.sql.Array;
31 import java.sql.Blob;
32 import java.sql.Clob;
33 import java.sql.Connection;
34 import java.sql.Date;
35 import java.sql.ParameterMetaData;
36 import java.sql.ResultSet;
37 import java.sql.SQLXML;
38 import java.sql.Statement;
39 import java.sql.Time;
40 import java.sql.Timestamp;
41 import java.util.Calendar;
42 import java.util.Collection;
43 import java.util.Collections;
44
45
46
47
48 public final class CircuitBreakerPreparedStatement extends AbstractUnsupportedOperationPreparedStatement {
49
50 @Override
51 public void setNull(final int parameterIndex, final int sqlType) {
52 }
53
54 @Override
55 public void setNull(final int parameterIndex, final int sqlType, final String typeName) {
56 }
57
58 @Override
59 public void setBoolean(final int parameterIndex, final boolean x) {
60 }
61
62 @Override
63 public void setByte(final int parameterIndex, final byte x) {
64 }
65
66 @Override
67 public void setShort(final int parameterIndex, final short x) {
68 }
69
70 @Override
71 public void setInt(final int parameterIndex, final int x) {
72 }
73
74 @Override
75 public void setLong(final int parameterIndex, final long x) {
76 }
77
78 @Override
79 public void setFloat(final int parameterIndex, final float x) {
80 }
81
82 @Override
83 public void setDouble(final int parameterIndex, final double x) {
84 }
85
86 @Override
87 public void setBigDecimal(final int parameterIndex, final BigDecimal x) {
88 }
89
90 @Override
91 public void setString(final int parameterIndex, final String x) {
92 }
93
94 @Override
95 public void setBytes(final int parameterIndex, final byte[] x) {
96 }
97
98 @Override
99 public void setDate(final int parameterIndex, final Date x) {
100 }
101
102 @Override
103 public void setDate(final int parameterIndex, final Date x, final Calendar cal) {
104 }
105
106 @Override
107 public void setTime(final int parameterIndex, final Time x) {
108 }
109
110 @Override
111 public void setTime(final int parameterIndex, final Time x, final Calendar cal) {
112 }
113
114 @Override
115 public void setTimestamp(final int parameterIndex, final Timestamp x) {
116 }
117
118 @Override
119 public void setTimestamp(final int parameterIndex, final Timestamp x, final Calendar cal) {
120 }
121
122 @Override
123 public void setAsciiStream(final int parameterIndex, final InputStream x, final int length) {
124 }
125
126 @Override
127 public void setAsciiStream(final int parameterIndex, final InputStream x) {
128 }
129
130 @Override
131 public void setAsciiStream(final int parameterIndex, final InputStream x, final long length) {
132 }
133
134 @Override
135 public void setUnicodeStream(final int parameterIndex, final InputStream x, final int length) {
136 }
137
138 @Override
139 public void setBinaryStream(final int parameterIndex, final InputStream x, final int length) {
140 }
141
142 @Override
143 public void setBinaryStream(final int parameterIndex, final InputStream x, final long length) {
144 }
145
146 @Override
147 public void setBinaryStream(final int parameterIndex, final InputStream x) {
148 }
149
150 @Override
151 public void clearParameters() {
152 }
153
154 @Override
155 public void setObject(final int parameterIndex, final Object x) {
156 }
157
158 @Override
159 public void setObject(final int parameterIndex, final Object x, final int targetSqlType) {
160 }
161
162 @Override
163 public void setObject(final int parameterIndex, final Object x, final int targetSqlType, final int scaleOrLength) {
164 }
165
166 @Override
167 public boolean execute() {
168 return false;
169 }
170
171 @Override
172 public void clearBatch() {
173 }
174
175 @Override
176 public void addBatch() {
177 }
178
179 @Override
180 public void setCharacterStream(final int parameterIndex, final Reader reader, final int length) {
181 }
182
183 @Override
184 public void setCharacterStream(final int parameterIndex, final Reader reader, final long length) {
185 }
186
187 @Override
188 public void setCharacterStream(final int parameterIndex, final Reader reader) {
189 }
190
191 @Override
192 public void setBlob(final int parameterIndex, final Blob x) {
193 }
194
195 @Override
196 public void setBlob(final int parameterIndex, final InputStream inputStream, final long length) {
197 }
198
199 @Override
200 public void setBlob(final int parameterIndex, final InputStream inputStream) {
201 }
202
203 @Override
204 public void setClob(final int parameterIndex, final Clob x) {
205 }
206
207 @Override
208 public void setClob(final int parameterIndex, final Reader reader, final long length) {
209 }
210
211 @Override
212 public void setClob(final int parameterIndex, final Reader reader) {
213 }
214
215 @Override
216 public void setArray(final int parameterIndex, final Array x) {
217 }
218
219 @Override
220 public void setURL(final int parameterIndex, final URL x) {
221 }
222
223 @Override
224 public ParameterMetaData getParameterMetaData() {
225 return null;
226 }
227
228 @Override
229 public void setSQLXML(final int parameterIndex, final SQLXML xmlObject) {
230 }
231
232 @Override
233 public int[] executeBatch() {
234 return new int[]{-1};
235 }
236
237 @Override
238 public Connection getConnection() {
239 return new CircuitBreakerConnection();
240 }
241
242 @Override
243 public ResultSet getGeneratedKeys() {
244 return new CircuitBreakerResultSet();
245 }
246
247 @Override
248 public int getResultSetHoldability() {
249 return 0;
250 }
251
252 @Override
253 public ResultSet getResultSet() {
254 return new CircuitBreakerResultSet();
255 }
256
257 @Override
258 public int getResultSetConcurrency() {
259 return ResultSet.CONCUR_READ_ONLY;
260 }
261
262 @Override
263 public int getResultSetType() {
264 return ResultSet.TYPE_FORWARD_ONLY;
265 }
266
267 @Override
268 protected boolean isAccumulate() {
269 return false;
270 }
271
272 @Override
273 protected Collection<? extends Statement> getRoutedStatements() {
274 return Collections.emptyList();
275 }
276
277 @Override
278 protected DriverExecutor getExecutor() {
279 return null;
280 }
281
282 @Override
283 protected StatementManager getStatementManager() {
284 return null;
285 }
286
287 @Override
288 public ResultSet executeQuery() {
289 return new CircuitBreakerResultSet();
290 }
291
292 @Override
293 public int executeUpdate() {
294 return -1;
295 }
296 }