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