### Question:
JdbcPipeline extends AbstractPipeline { @Override public AbstractPipeline asTempTable(String tempTableName) { assert (procedure instanceof PreparedExtractProcedure.JdbcExtractor) : "Only support MySQL as temporary table"; try { statement.execute("CREATE TEMPORARY TABLE " + tempTableName + " AS " + ((ExtractProcedure) procedure).toRecognizedQuery()); } catch (SQLException ex) { throw new RuntimeException(ex); } return this; } JdbcPipeline(QueryProcedure procedure,
        List<String> tableNames,
        SqlRunner.Builder builder); @Override void run(); static Connection createSpecificConnection(String json, List<String> parsedTables); static Connection createSpecificConnection(List<SchemaAssembler> assemblers); static Connection createCsvConnection(); @Override Object collect(); @Override void show(); @Override PipelineResult asTextFile(String clusterPath, String deliminator); @Override PipelineResult asJsonFile(String clusterPath); @Override AbstractPipeline asTempTable(String tempTableName); @Override void shutdown(); static final String CSV_DEFAULT_SCHEMA; }### Answer:
@Test public void testTempTable() { String sql = "select * from edu_manage.department"; SqlRunner.Builder.RunnerType runnerType = RunnerType.DEFAULT; SqlRunner runner = SqlRunner.builder() .setTransformRunner(runnerType) .setSchemaPath(SqlUtil.getSchemaPath(SqlUtil.parseTableName(sql).tableNames)) .setAppName("test virtual") .setAcceptedResultsNum(2000) .ok(); try { runner.sql(sql).asTempTable("test"); } catch (Exception ex) { Assert.assertTrue(true); } }