test_class.file: core/src/test/java/com/qihoo/qsql/exec/JdbcPipelineTest.java
test_class.identifier: JdbcPipelineTest
test_case.body: @Test
      public void testJdbc() {
          String sql = "select 1";
          SqlRunner.Builder.RunnerType runnerType = RunnerType.DEFAULT;
          SqlRunner runner = SqlRunner.builder()
              .setTransformRunner(runnerType)
              .setSchemaPath(SqlUtil.getSchemaPath(SqlUtil.parseTableName(sql).tableNames))
              .setAppName("test mysql")
              .setAcceptedResultsNum(2000)
              .ok();
  
          runner.sql(sql).show();
      }
test_case.class_method_signature: JdbcPipelineTest.testJdbc()
test_case.full_signature: @Test public void testJdbc()
test_case.identifier: testJdbc
test_case.invocations: ok setAcceptedResultsNum setAppName setSchemaPath setTransformRunner builder getSchemaPath parseTableName show sql
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testJdbc()
focal_class.declarator: CSV_DEFAULT_SCHEMA = "inline:"
          + "{\n"
          + "  version: '1.0',\n"
          + "  defaultSchema: 'SALES',\n"
          + "  schemas: [\n"
          + "    {\n"
          + "      name: 'SALES',\n"
          + "      type: 'custom',\n"
          + "      factory: 'com.qihoo.qsql.org.apache.calcite.adapter.csv.CsvSchemaFactory',\n"
          + "      operand: {\n"
          + "        directory: 'sales'\n"
          + "      }\n"
          + "    }\n"
          + "  ]\n"
          + "}"
focal_class.modifier: public static final
focal_class.original_string: public static final String CSV_DEFAULT_SCHEMA = "inline:"
          + "{\n"
          + "  version: '1.0',\n"
          + "  defaultSchema: 'SALES',\n"
          + "  schemas: [\n"
          + "    {\n"
          + "      name: 'SALES',\n"
          + "      type: 'custom',\n"
          + "      factory: 'com.qihoo.qsql.org.apache.calcite.adapter.csv.CsvSchemaFactory',\n"
          + "      operand: {\n"
          + "        directory: 'sales'\n"
          + "      }\n"
          + "    }\n"
          + "  ]\n"
          + "}";
focal_class.type: String
focal_class.var_name: CSV_DEFAULT_SCHEMA
focal_class.declarator: LOGGER = LoggerFactory.getLogger(JdbcPipeline.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOGGER = LoggerFactory.getLogger(JdbcPipeline.class);
focal_class.type: Logger
focal_class.var_name: LOGGER
focal_class.declarator: connection
focal_class.modifier: private
focal_class.original_string: private Connection connection;
focal_class.type: Connection
focal_class.var_name: connection
focal_class.declarator: statement
focal_class.modifier: private
focal_class.original_string: private PreparedStatement statement;
focal_class.type: PreparedStatement
focal_class.var_name: statement
focal_class.declarator: tableNames
focal_class.modifier: private
focal_class.original_string: private List<String> tableNames;
focal_class.type: List<String>
focal_class.var_name: tableNames
focal_class.file: core/src/main/java/com/qihoo/qsql/exec/JdbcPipeline.java
focal_class.identifier: JdbcPipeline
focal_class.class_method_signature: JdbcPipeline.JdbcPipeline(QueryProcedure procedure,
          List<String> tableNames,
          SqlRunner.Builder builder)
focal_class.full_signature: public  JdbcPipeline(QueryProcedure procedure,
          List<String> tableNames,
          SqlRunner.Builder builder)
focal_class.identifier: JdbcPipeline
focal_class.modifiers: public
focal_class.parameters: (QueryProcedure procedure,
          List<String> tableNames,
          SqlRunner.Builder builder)
focal_class.signature:  JdbcPipeline(QueryProcedure procedure,
          List<String> tableNames,
          SqlRunner.Builder builder)
focal_class.class_method_signature: JdbcPipeline.run()
focal_class.full_signature: @Override public void run()
focal_class.identifier: run
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void run()
focal_class.class_method_signature: JdbcPipeline.createSpecificConnection(String json, List<String> parsedTables)
focal_class.full_signature: public static Connection createSpecificConnection(String json, List<String> parsedTables)
focal_class.identifier: createSpecificConnection
focal_class.modifiers: public static
focal_class.parameters: (String json, List<String> parsedTables)
focal_class.return: Connection
focal_class.signature: Connection createSpecificConnection(String json, List<String> parsedTables)
focal_class.class_method_signature: JdbcPipeline.createSpecificConnection(List<SchemaAssembler> assemblers)
focal_class.full_signature: public static Connection createSpecificConnection(List<SchemaAssembler> assemblers)
focal_class.identifier: createSpecificConnection
focal_class.modifiers: public static
focal_class.parameters: (List<SchemaAssembler> assemblers)
focal_class.return: Connection
focal_class.signature: Connection createSpecificConnection(List<SchemaAssembler> assemblers)
focal_class.class_method_signature: JdbcPipeline.createCalciteConnection(String json)
focal_class.full_signature: private static Connection createCalciteConnection(String json)
focal_class.identifier: createCalciteConnection
focal_class.modifiers: private static
focal_class.parameters: (String json)
focal_class.return: Connection
focal_class.signature: Connection createCalciteConnection(String json)
focal_class.class_method_signature: JdbcPipeline.createJdbcConnection(Map<String, String> conn)
focal_class.full_signature: private static Connection createJdbcConnection(Map<String, String> conn)
focal_class.identifier: createJdbcConnection
focal_class.modifiers: private static
focal_class.parameters: (Map<String, String> conn)
focal_class.return: Connection
focal_class.signature: Connection createJdbcConnection(Map<String, String> conn)
focal_class.class_method_signature: JdbcPipeline.checkConnectionInformation(SchemaAssembler prev, SchemaAssembler curr)
focal_class.full_signature: private static void checkConnectionInformation(SchemaAssembler prev, SchemaAssembler curr)
focal_class.identifier: checkConnectionInformation
focal_class.modifiers: private static
focal_class.parameters: (SchemaAssembler prev, SchemaAssembler curr)
focal_class.return: void
focal_class.signature: void checkConnectionInformation(SchemaAssembler prev, SchemaAssembler curr)
focal_class.class_method_signature: JdbcPipeline.parseJsonSchema(List<String> names, String uri)
focal_class.full_signature: private static JsonVisitor parseJsonSchema(List<String> names, String uri)
focal_class.identifier: parseJsonSchema
focal_class.modifiers: private static
focal_class.parameters: (List<String> names, String uri)
focal_class.return: JsonVisitor
focal_class.signature: JsonVisitor parseJsonSchema(List<String> names, String uri)
focal_class.class_method_signature: JdbcPipeline.createCsvConnection()
focal_class.full_signature: public static Connection createCsvConnection()
focal_class.identifier: createCsvConnection
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: Connection
focal_class.signature: Connection createCsvConnection()
focal_class.class_method_signature: JdbcPipeline.collect()
focal_class.full_signature: @Override public Object collect()
focal_class.identifier: collect
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Object
focal_class.signature: Object collect()
focal_class.class_method_signature: JdbcPipeline.show()
focal_class.full_signature: @Override public void show()
focal_class.identifier: show
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void show()
focal_class.class_method_signature: JdbcPipeline.asTextFile(String clusterPath, String deliminator)
focal_class.full_signature: @Override public PipelineResult asTextFile(String clusterPath, String deliminator)
focal_class.identifier: asTextFile
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterPath, String deliminator)
focal_class.return: PipelineResult
focal_class.signature: PipelineResult asTextFile(String clusterPath, String deliminator)
focal_class.class_method_signature: JdbcPipeline.asJsonFile(String clusterPath)
focal_class.full_signature: @Override public PipelineResult asJsonFile(String clusterPath)
focal_class.identifier: asJsonFile
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterPath)
focal_class.return: PipelineResult
focal_class.signature: PipelineResult asJsonFile(String clusterPath)
focal_class.class_method_signature: JdbcPipeline.asTempTable(String tempTableName)
focal_class.full_signature: @Override public AbstractPipeline asTempTable(String tempTableName)
focal_class.identifier: asTempTable
focal_class.modifiers: @Override public
focal_class.parameters: (String tempTableName)
focal_class.return: AbstractPipeline
focal_class.signature: AbstractPipeline asTempTable(String tempTableName)
focal_class.class_method_signature: JdbcPipeline.shutdown()
focal_class.full_signature: @Override public void shutdown()
focal_class.identifier: shutdown
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void shutdown()
focal_class.class_method_signature: JdbcPipeline.establishStatement()
focal_class.full_signature: private ResultSet establishStatement()
focal_class.identifier: establishStatement
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: ResultSet
focal_class.signature: ResultSet establishStatement()
focal_class.class_method_signature: JdbcPipeline.getConnection()
focal_class.full_signature: private Connection getConnection()
focal_class.identifier: getConnection
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Connection
focal_class.signature: Connection getConnection()
focal_class.superclass: extends AbstractPipeline
focal_method.body: @Override
      public void show() {
          ResultSet resultSet = establishStatement();
          if (resultSet != null) {
              JdbcResultSetIterator<Object> iterator = new JdbcResultSetIterator<>(resultSet);
              new JdbcPipelineResult.ShowPipelineResult(iterator).print();
              iterator.close();
          }
      }
focal_method.class_method_signature: JdbcPipeline.show()
focal_method.full_signature: @Override public void show()
focal_method.identifier: show
focal_method.invocations: establishStatement print close
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void show()