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