test_class.file: shardingsphere-jdbc/shardingsphere-jdbc-core/src/test/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatementTest.java
test_class.identifier: ShardingSphereStatementTest
test_class.superclass: extends AbstractShardingSphereDataSourceForShardingTest
test_case.body: @Test(expected = SQLException.class)
      public void assertQueryWithNull() throws SQLException {
          try (Statement statement = getShardingSphereDataSource().getConnection().createStatement()) {
              statement.executeQuery(null);
          }
      }
test_case.class_method_signature: ShardingSphereStatementTest.assertQueryWithNull()
test_case.full_signature: @Test(expected = SQLException.class) public void assertQueryWithNull()
test_case.identifier: assertQueryWithNull
test_case.invocations: createStatement getConnection getShardingSphereDataSource executeQuery
test_case.modifiers: @Test(expected = SQLException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertQueryWithNull()
focal_class.declarator: connection
focal_class.modifier: @Getter
      private final
focal_class.original_string: @Getter
      private final ShardingSphereConnection connection;
focal_class.type: ShardingSphereConnection
focal_class.var_name: connection
focal_class.declarator: schemaContexts
focal_class.modifier: private final
focal_class.original_string: private final SchemaContexts schemaContexts;
focal_class.type: SchemaContexts
focal_class.var_name: schemaContexts
focal_class.declarator: statements
focal_class.modifier: private final
focal_class.original_string: private final List<Statement> statements;
focal_class.type: List<Statement>
focal_class.var_name: statements
focal_class.declarator: statementOption
focal_class.modifier: private final
focal_class.original_string: private final StatementOption statementOption;
focal_class.type: StatementOption
focal_class.var_name: statementOption
focal_class.declarator: statementExecutor
focal_class.modifier: private final
focal_class.original_string: private final StatementExecutor statementExecutor;
focal_class.type: StatementExecutor
focal_class.var_name: statementExecutor
focal_class.declarator: rawExecutor
focal_class.modifier: private final
focal_class.original_string: private final RawJDBCExecutor rawExecutor;
focal_class.type: RawJDBCExecutor
focal_class.var_name: rawExecutor
focal_class.declarator: returnGeneratedKeys
focal_class.modifier: private
focal_class.original_string: private boolean returnGeneratedKeys;
focal_class.type: boolean
focal_class.var_name: returnGeneratedKeys
focal_class.declarator: executionContext
focal_class.modifier: private
focal_class.original_string: private ExecutionContext executionContext;
focal_class.type: ExecutionContext
focal_class.var_name: executionContext
focal_class.declarator: currentResultSet
focal_class.modifier: private
focal_class.original_string: private ResultSet currentResultSet;
focal_class.type: ResultSet
focal_class.var_name: currentResultSet
focal_class.file: shardingsphere-jdbc/shardingsphere-jdbc-core/src/main/java/org/apache/shardingsphere/driver/jdbc/core/statement/ShardingSphereStatement.java
focal_class.identifier: ShardingSphereStatement
focal_class.class_method_signature: ShardingSphereStatement.ShardingSphereStatement(final ShardingSphereConnection connection)
focal_class.full_signature: public  ShardingSphereStatement(final ShardingSphereConnection connection)
focal_class.identifier: ShardingSphereStatement
focal_class.modifiers: public
focal_class.parameters: (final ShardingSphereConnection connection)
focal_class.signature:  ShardingSphereStatement(final ShardingSphereConnection connection)
focal_class.class_method_signature: ShardingSphereStatement.ShardingSphereStatement(final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency)
focal_class.full_signature: public  ShardingSphereStatement(final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency)
focal_class.identifier: ShardingSphereStatement
focal_class.modifiers: public
focal_class.parameters: (final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency)
focal_class.signature:  ShardingSphereStatement(final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency)
focal_class.class_method_signature: ShardingSphereStatement.ShardingSphereStatement(final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
focal_class.full_signature: public  ShardingSphereStatement(final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
focal_class.identifier: ShardingSphereStatement
focal_class.modifiers: public
focal_class.parameters: (final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
focal_class.signature:  ShardingSphereStatement(final ShardingSphereConnection connection, final int resultSetType, final int resultSetConcurrency, final int resultSetHoldability)
focal_class.class_method_signature: ShardingSphereStatement.executeQuery(final String sql)
focal_class.full_signature: @Override public ResultSet executeQuery(final String sql)
focal_class.identifier: executeQuery
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql)
focal_class.return: ResultSet
focal_class.signature: ResultSet executeQuery(final String sql)
focal_class.class_method_signature: ShardingSphereStatement.executeUpdate(final String sql)
focal_class.full_signature: @Override public int executeUpdate(final String sql)
focal_class.identifier: executeUpdate
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql)
focal_class.return: int
focal_class.signature: int executeUpdate(final String sql)
focal_class.class_method_signature: ShardingSphereStatement.executeUpdate(final String sql, final int autoGeneratedKeys)
focal_class.full_signature: @Override public int executeUpdate(final String sql, final int autoGeneratedKeys)
focal_class.identifier: executeUpdate
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql, final int autoGeneratedKeys)
focal_class.return: int
focal_class.signature: int executeUpdate(final String sql, final int autoGeneratedKeys)
focal_class.class_method_signature: ShardingSphereStatement.executeUpdate(final String sql, final int[] columnIndexes)
focal_class.full_signature: @Override public int executeUpdate(final String sql, final int[] columnIndexes)
focal_class.identifier: executeUpdate
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql, final int[] columnIndexes)
focal_class.return: int
focal_class.signature: int executeUpdate(final String sql, final int[] columnIndexes)
focal_class.class_method_signature: ShardingSphereStatement.executeUpdate(final String sql, final String[] columnNames)
focal_class.full_signature: @Override public int executeUpdate(final String sql, final String[] columnNames)
focal_class.identifier: executeUpdate
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql, final String[] columnNames)
focal_class.return: int
focal_class.signature: int executeUpdate(final String sql, final String[] columnNames)
focal_class.class_method_signature: ShardingSphereStatement.execute(final String sql)
focal_class.full_signature: @Override public boolean execute(final String sql)
focal_class.identifier: execute
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql)
focal_class.return: boolean
focal_class.signature: boolean execute(final String sql)
focal_class.class_method_signature: ShardingSphereStatement.execute(final String sql, final int autoGeneratedKeys)
focal_class.full_signature: @Override public boolean execute(final String sql, final int autoGeneratedKeys)
focal_class.identifier: execute
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql, final int autoGeneratedKeys)
focal_class.return: boolean
focal_class.signature: boolean execute(final String sql, final int autoGeneratedKeys)
focal_class.class_method_signature: ShardingSphereStatement.execute(final String sql, final int[] columnIndexes)
focal_class.full_signature: @Override public boolean execute(final String sql, final int[] columnIndexes)
focal_class.identifier: execute
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql, final int[] columnIndexes)
focal_class.return: boolean
focal_class.signature: boolean execute(final String sql, final int[] columnIndexes)
focal_class.class_method_signature: ShardingSphereStatement.execute(final String sql, final String[] columnNames)
focal_class.full_signature: @Override public boolean execute(final String sql, final String[] columnNames)
focal_class.identifier: execute
focal_class.modifiers: @Override public
focal_class.parameters: (final String sql, final String[] columnNames)
focal_class.return: boolean
focal_class.signature: boolean execute(final String sql, final String[] columnNames)
focal_class.class_method_signature: ShardingSphereStatement.createExecutionContext(final String sql)
focal_class.full_signature: private ExecutionContext createExecutionContext(final String sql)
focal_class.identifier: createExecutionContext
focal_class.modifiers: private
focal_class.parameters: (final String sql)
focal_class.return: ExecutionContext
focal_class.signature: ExecutionContext createExecutionContext(final String sql)
focal_class.class_method_signature: ShardingSphereStatement.clearStatements()
focal_class.full_signature: private void clearStatements()
focal_class.identifier: clearStatements
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void clearStatements()
focal_class.class_method_signature: ShardingSphereStatement.logSQL(final LogicSQL logicSQL, final ConfigurationProperties props, final ExecutionContext executionContext)
focal_class.full_signature: private void logSQL(final LogicSQL logicSQL, final ConfigurationProperties props, final ExecutionContext executionContext)
focal_class.identifier: logSQL
focal_class.modifiers: private
focal_class.parameters: (final LogicSQL logicSQL, final ConfigurationProperties props, final ExecutionContext executionContext)
focal_class.return: void
focal_class.signature: void logSQL(final LogicSQL logicSQL, final ConfigurationProperties props, final ExecutionContext executionContext)
focal_class.class_method_signature: ShardingSphereStatement.createLogicSQL(final String sql)
focal_class.full_signature: private LogicSQL createLogicSQL(final String sql)
focal_class.identifier: createLogicSQL
focal_class.modifiers: private
focal_class.parameters: (final String sql)
focal_class.return: LogicSQL
focal_class.signature: LogicSQL createLogicSQL(final String sql)
focal_class.class_method_signature: ShardingSphereStatement.getInputGroups()
focal_class.full_signature: private Collection<InputGroup<StatementExecuteUnit>> getInputGroups()
focal_class.identifier: getInputGroups
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Collection<InputGroup<StatementExecuteUnit>>
focal_class.signature: Collection<InputGroup<StatementExecuteUnit>> getInputGroups()
focal_class.class_method_signature: ShardingSphereStatement.getRawInputGroups()
focal_class.full_signature: private Collection<InputGroup<RawSQLExecuteUnit>> getRawInputGroups()
focal_class.identifier: getRawInputGroups
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Collection<InputGroup<RawSQLExecuteUnit>>
focal_class.signature: Collection<InputGroup<RawSQLExecuteUnit>> getRawInputGroups()
focal_class.class_method_signature: ShardingSphereStatement.cacheStatements(final Collection<InputGroup<StatementExecuteUnit>> inputGroups)
focal_class.full_signature: private void cacheStatements(final Collection<InputGroup<StatementExecuteUnit>> inputGroups)
focal_class.identifier: cacheStatements
focal_class.modifiers: private
focal_class.parameters: (final Collection<InputGroup<StatementExecuteUnit>> inputGroups)
focal_class.return: void
focal_class.signature: void cacheStatements(final Collection<InputGroup<StatementExecuteUnit>> inputGroups)
focal_class.class_method_signature: ShardingSphereStatement.getResultSet()
focal_class.full_signature: @Override public ResultSet getResultSet()
focal_class.identifier: getResultSet
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ResultSet
focal_class.signature: ResultSet getResultSet()
focal_class.class_method_signature: ShardingSphereStatement.getResultSet(final Statement statement)
focal_class.full_signature: private ResultSet getResultSet(final Statement statement)
focal_class.identifier: getResultSet
focal_class.modifiers: private
focal_class.parameters: (final Statement statement)
focal_class.return: ResultSet
focal_class.signature: ResultSet getResultSet(final Statement statement)
focal_class.class_method_signature: ShardingSphereStatement.getResultSets()
focal_class.full_signature: private List<ResultSet> getResultSets()
focal_class.identifier: getResultSets
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: List<ResultSet>
focal_class.signature: List<ResultSet> getResultSets()
focal_class.class_method_signature: ShardingSphereStatement.getQueryResults(final List<ResultSet> resultSets)
focal_class.full_signature: private List<QueryResult> getQueryResults(final List<ResultSet> resultSets)
focal_class.identifier: getQueryResults
focal_class.modifiers: private
focal_class.parameters: (final List<ResultSet> resultSets)
focal_class.return: List<QueryResult>
focal_class.signature: List<QueryResult> getQueryResults(final List<ResultSet> resultSets)
focal_class.class_method_signature: ShardingSphereStatement.mergeQuery(final List<QueryResult> queryResults)
focal_class.full_signature: private MergedResult mergeQuery(final List<QueryResult> queryResults)
focal_class.identifier: mergeQuery
focal_class.modifiers: private
focal_class.parameters: (final List<QueryResult> queryResults)
focal_class.return: MergedResult
focal_class.signature: MergedResult mergeQuery(final List<QueryResult> queryResults)
focal_class.class_method_signature: ShardingSphereStatement.getResultSetType()
focal_class.full_signature: @SuppressWarnings("MagicConstant") @Override public int getResultSetType()
focal_class.identifier: getResultSetType
focal_class.modifiers: @SuppressWarnings("MagicConstant") @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getResultSetType()
focal_class.class_method_signature: ShardingSphereStatement.getResultSetConcurrency()
focal_class.full_signature: @SuppressWarnings("MagicConstant") @Override public int getResultSetConcurrency()
focal_class.identifier: getResultSetConcurrency
focal_class.modifiers: @SuppressWarnings("MagicConstant") @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getResultSetConcurrency()
focal_class.class_method_signature: ShardingSphereStatement.getResultSetHoldability()
focal_class.full_signature: @Override public int getResultSetHoldability()
focal_class.identifier: getResultSetHoldability
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getResultSetHoldability()
focal_class.class_method_signature: ShardingSphereStatement.isAccumulate()
focal_class.full_signature: @Override public boolean isAccumulate()
focal_class.identifier: isAccumulate
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isAccumulate()
focal_class.class_method_signature: ShardingSphereStatement.getRoutedStatements()
focal_class.full_signature: @Override public Collection<Statement> getRoutedStatements()
focal_class.identifier: getRoutedStatements
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<Statement>
focal_class.signature: Collection<Statement> getRoutedStatements()
focal_class.class_method_signature: ShardingSphereStatement.getGeneratedKeys()
focal_class.full_signature: @Override public ResultSet getGeneratedKeys()
focal_class.identifier: getGeneratedKeys
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: ResultSet
focal_class.signature: ResultSet getGeneratedKeys()
focal_class.class_method_signature: ShardingSphereStatement.findGeneratedKey()
focal_class.full_signature: private Optional<GeneratedKeyContext> findGeneratedKey()
focal_class.identifier: findGeneratedKey
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Optional<GeneratedKeyContext>
focal_class.signature: Optional<GeneratedKeyContext> findGeneratedKey()
focal_class.superclass: extends AbstractStatementAdapter
focal_method.body: @Override
      public ResultSet executeQuery(final String sql) throws SQLException {
          if (Strings.isNullOrEmpty(sql)) {
              throw new SQLException(SQLExceptionConstant.SQL_STRING_NULL_OR_EMPTY);
          }
          ResultSet result;
          try {
              executionContext = createExecutionContext(sql);
              List<QueryResult> queryResults;
              if (ExecutorConstant.MANAGED_RESOURCE) {
                  Collection<InputGroup<StatementExecuteUnit>> inputGroups = getInputGroups();
                  cacheStatements(inputGroups);
                  queryResults = statementExecutor.executeQuery(inputGroups);
              } else {
                  queryResults = rawExecutor.executeQuery(getRawInputGroups(), new RawSQLExecutorCallback());
              }
              MergedResult mergedResult = mergeQuery(queryResults);
              result = new ShardingSphereResultSet(statements.stream().map(this::getResultSet).collect(Collectors.toList()), mergedResult, this, executionContext);
          } finally {
              currentResultSet = null;
          }
          currentResultSet = result;
          return result;
      }
focal_method.class_method_signature: ShardingSphereStatement.executeQuery(final String sql)
focal_method.full_signature: @Override public ResultSet executeQuery(final String sql)
focal_method.identifier: executeQuery
focal_method.invocations: isNullOrEmpty createExecutionContext getInputGroups cacheStatements executeQuery executeQuery getRawInputGroups mergeQuery collect map stream toList
focal_method.modifiers: @Override public
focal_method.parameters: (final String sql)
focal_method.return: ResultSet
focal_method.signature: ResultSet executeQuery(final String sql)