drill java && spring jdbc 连接使用

 原生 jdbc 连接

 

1. maven 包

1. <dependency>
2. <groupId>org.apache.drill.exec</groupId>
3. <artifactId>drill-jdbc-all</artifactId>
4. <version>1.10.0</version>
5. </dependency>

2. 代码

2. Class.forName("org.apache.drill.jdbc.Driver");
3. Connection connection =DriverManager.getConnection("jdbc:drill:zk=10.10.5.18:2181/drill/demo");
4. Statement st = connection.createStatement();
5. ResultSet rs = st.executeQuery("select * from dfs.`/root/drill/drill/sample-data/user.json`");
6. while(rs.next()){
7. System.out.println(rs.getString(1));
8. }

3. 查询结果

 

 

使用spring boot  jdbc

1. spring boot maven 

1. <dependency>
2. <groupId>org.springframework.boot</groupId>
3. <artifactId>spring-boot-starter-web</artifactId>
4. </dependency>
5. <dependency>
6. <groupId>org.apache.drill.exec</groupId>
7. <artifactId>drill-jdbc-all</artifactId>
8. <version>1.10.0</version>
9. </dependency>

2. 代码

1. a.DataSourceBean定义
2. @Bean(name="dataSource2")
3. publicDataSource dataSource2(){
4. BasicDataSource dataSource =newBasicDataSource();
5. dataSource.setUrl("jdbc:drill:zk=10.10.5.18:2181/drill/demo");
6. dataSource.setDriverClassName("org.apache.drill.jdbc.Driver");
7. dataSource.setInitialSize(2);
8. dataSource.setMaxActive(20);
9. dataSource.setMinIdle(0);
10. dataSource.setPoolPreparedStatements(true);
11. dataSource.setMaxWait(60000);
12. dataSource.setTestOnBorrow(false);
13. dataSource.setTestWhileIdle(true);
14. return dataSource;
15. }
16. b. jdbctempalte
17. @Bean
18. publicJdbcTemplate jdbcTemplate2(@Qualifier("dataSource2")DataSource dataSource2){
19. JdbcTemplate oracle =newJdbcTemplate();
20. oracle.setDataSource(dataSource2);
21. return oracle;
22. }
23. c.查询使用
24. @RestController
25. publicclassDrillController{
27. @Autowired
29. privateJdbcTemplate jdbcTemplate2;
31. @RequestMapping(value="/drill",method=RequestMethod.GET)
32. publicObject getUser3(){
34. return jdbcTemplate2.queryForList("select * from dfs.`/root/drill/drill/sample-data/user.json`");
36. }
37. }

3. 查询结果