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.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   * Circuit breaker preparedStatement.
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 }