View Javadoc
1   /*
2    * Licensed to the Apache Software Foundation (ASF) under one or more
3    * contributor license agreements.  See the NOTICE file distributed with
4    * this work for additional information regarding copyright ownership.
5    * The ASF licenses this file to You under the Apache License, Version 2.0
6    * (the "License"); you may not use this file except in compliance with
7    * the License.  You may obtain a copy of the License at
8    *
9    *     http://www.apache.org/licenses/LICENSE-2.0
10   *
11   * Unless required by applicable law or agreed to in writing, software
12   * distributed under the License is distributed on an "AS IS" BASIS,
13   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   * See the License for the specific language governing permissions and
15   * limitations under the License.
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   * Circuit breaker preparedStatement.
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 }