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.unsupported.AbstractUnsupportedOperationStatement;
21  import org.apache.shardingsphere.driver.state.circuit.connection.CircuitBreakerConnection;
22  
23  import java.sql.Connection;
24  import java.sql.ResultSet;
25  import java.sql.SQLException;
26  import java.sql.SQLWarning;
27  
28  /**
29   * Circuit breaker statement.
30   */
31  public final class CircuitBreakerStatement extends AbstractUnsupportedOperationStatement {
32      
33      @Override
34      public void close() {
35      }
36      
37      @Override
38      public int getMaxFieldSize() {
39          return 0;
40      }
41      
42      @Override
43      public void setMaxFieldSize(final int max) {
44      }
45      
46      @Override
47      public int getMaxRows() {
48          return 0;
49      }
50      
51      @Override
52      public void setMaxRows(final int max) {
53      }
54      
55      @Override
56      public void setEscapeProcessing(final boolean enable) {
57      }
58      
59      @Override
60      public int getQueryTimeout() {
61          return 0;
62      }
63      
64      @Override
65      public void setQueryTimeout(final int seconds) {
66      }
67      
68      @Override
69      public void cancel() {
70      }
71      
72      @Override
73      public SQLWarning getWarnings() {
74          return null;
75      }
76      
77      @Override
78      public void clearWarnings() {
79      }
80      
81      @Override
82      public ResultSet getResultSet() {
83          return null;
84      }
85      
86      @Override
87      public int getUpdateCount() {
88          return 0;
89      }
90      
91      @Override
92      public void setFetchSize(final int rows) {
93      }
94      
95      @Override
96      public int getFetchSize() {
97          return 0;
98      }
99      
100     @Override
101     public int getFetchDirection() {
102         return ResultSet.FETCH_FORWARD;
103     }
104     
105     @Override
106     public void setFetchDirection(final int direction) {
107     }
108     
109     @Override
110     public int getResultSetConcurrency() {
111         return ResultSet.CONCUR_READ_ONLY;
112     }
113     
114     @Override
115     public int getResultSetType() {
116         return ResultSet.TYPE_FORWARD_ONLY;
117     }
118     
119     @Override
120     public void addBatch(final String sql) {
121     }
122     
123     @Override
124     public void clearBatch() {
125     }
126     
127     @Override
128     public int[] executeBatch() throws SQLException {
129         return new int[0];
130     }
131     
132     @Override
133     public Connection getConnection() {
134         return new CircuitBreakerConnection();
135     }
136     
137     @Override
138     public boolean getMoreResults() {
139         return false;
140     }
141     
142     @Override
143     public boolean getMoreResults(final int current) {
144         return false;
145     }
146     
147     @Override
148     public ResultSet getGeneratedKeys() {
149         return null;
150     }
151     
152     @Override
153     public ResultSet executeQuery(final String sql) {
154         return null;
155     }
156     
157     @Override
158     public int executeUpdate(final String sql) {
159         return 0;
160     }
161     
162     @Override
163     public int executeUpdate(final String sql, final int autoGeneratedKeys) {
164         return 0;
165     }
166     
167     @Override
168     public int executeUpdate(final String sql, final int[] columnIndexes) {
169         return 0;
170     }
171     
172     @Override
173     public int executeUpdate(final String sql, final String[] columnNames) {
174         return 0;
175     }
176     
177     @Override
178     public boolean execute(final String sql) {
179         return false;
180     }
181     
182     @Override
183     public boolean execute(final String sql, final int autoGeneratedKeys) {
184         return false;
185     }
186     
187     @Override
188     public boolean execute(final String sql, final int[] columnIndexes) {
189         return false;
190     }
191     
192     @Override
193     public boolean execute(final String sql, final String[] columnNames) {
194         return false;
195     }
196     
197     @Override
198     public int getResultSetHoldability() {
199         return 0;
200     }
201     
202     @Override
203     public boolean isClosed() {
204         return false;
205     }
206     
207     @Override
208     public void setPoolable(final boolean poolable) {
209     }
210     
211     @Override
212     public boolean isPoolable() {
213         return false;
214     }
215 }