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.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
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 }