1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.driver.executor.callback.impl;
19
20 import org.apache.shardingsphere.driver.executor.callback.ExecuteQueryCallback;
21 import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
22 import org.apache.shardingsphere.infra.metadata.database.resource.ResourceMetaData;
23 import org.apache.shardingsphere.sql.parser.sql.common.statement.SQLStatement;
24
25 import java.sql.ResultSet;
26 import java.sql.SQLException;
27 import java.sql.Statement;
28
29
30
31
32 public final class StatementExecuteQueryCallback extends ExecuteQueryCallback {
33
34 public StatementExecuteQueryCallback(final DatabaseType protocolType, final ResourceMetaData resourceMetaData, final SQLStatement sqlStatement, final boolean isExceptionThrown) {
35 super(protocolType, resourceMetaData, sqlStatement, isExceptionThrown);
36 }
37
38 @Override
39 protected ResultSet executeQuery(final String sql, final Statement statement) throws SQLException {
40 return statement.executeQuery(sql);
41 }
42 }