java连接kudu数据库

在网上看了很多资料,写的也没有很详细的,就很头疼,算了自己写一篇吧。

有问题,可以提提意见啥的哈,一起交流,我是程序员s。

1.导入相应的maven

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-jdbc</artifactId>
		</dependency>
        <--这个包是公司封装的-->
		<dependency>
			<groupId>owinfo</groupId>
			<artifactId>impalajdbc41</artifactId>
			<version>1.0.0</version>
		</dependency>
	   <dependency>
			<groupId>org.apache.kudu</groupId>
			<artifactId>kudu-client</artifactId>
			<version>1.7.1</version>
			<scope>test</scope>
		</dependency>

2.application.yml(我在这配置的)

impala:
  url: jdbc:impala://192.168.1.1       //ip
  port: 21050                          //端口
  schema: h2kyd_db                     //数据库
  user:   YD2000
  password:  1qaz!QAZ
  driverClass: org.apache.hive.jdbc.HiveDriver  //驱动

3.地址池

package com.xdl.service.entity;

import com.cloudera.impala.jdbc41.DataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;



@Configuration
public class ImpalaConfig {
    @Value("${impala.url}")
    private String impalaUrl;
    @Value("${impala.port}")
    private String impalaPort;
    @Value("${impala.schema}")
    private String impalaScheme;
    @Value("${impala.user}")
    private String impalaUser;
    @Value("${impala.password}")
    private String impalaPassword;

    @Bean(name = {"impalaJdbcTemplate"})
    public JdbcTemplate getImpalaJdbcTemplate() {
        String connUrl = this.impalaUrl + ":" + this.impalaPort + "/" + this.impalaScheme + ";auth=noSasl";
        DataSource dataSource = new DataSource();
        dataSource.setURL(connUrl);
        return new JdbcTemplate(dataSource);
    }
}

4.在启动类添加注解

@SpringBootApplication
//告诉Spring Boot开始添加基于类路径设置,其他bean和各种属性设置的bean。
@EnableAutoConfiguration(exclude = {DataSourceAutoConfiguration.class})  
public class ServiceApplication {

	public static void main(String[] args) {
		SpringApplication.run(ServiceApplication.class, args);
	}
}

猜你喜欢

转载自blog.csdn.net/u012448904/article/details/82587632