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.PreparedStatement;
26 import java.sql.ResultSet;
27 import java.sql.SQLException;
28 import java.sql.Statement;
29
30
31
32
33 public final class PreparedStatementExecuteQueryCallback extends ExecuteQueryCallback {
34
35 public PreparedStatementExecuteQueryCallback(final DatabaseType protocolType, final ResourceMetaData resourceMetaData, final SQLStatement sqlStatement,
36 final boolean isExceptionThrown) {
37 super(protocolType, resourceMetaData, sqlStatement, isExceptionThrown);
38 }
39
40 @Override
41 protected ResultSet executeQuery(final String sql, final Statement statement) throws SQLException {
42 return ((PreparedStatement) statement).executeQuery();
43 }
44 }