• 采用springboot 2.7.10来操作clickhouse

    1、采用springboot与clickhouse结合，其实和操作mysql，oracle区别不大。直接上代码开干

    2、所采用的环境

    jdk1.8

    springboot 2.7.10

    clickhouse 22.8.3.13

    clickhouse 0.5.0

    3、项目的pom.xml文件

    1. <dependency>
    2. 				<groupId>com.clickhouse</groupId>
    3. 				<artifactId>clickhouse-jdbc</artifactId>
    4. 				<version>0.5.0</version>
    5. 			</dependency>
    6. 			<dependency>
    7. 				<groupId>com.clickhouse</groupId>
    8. 				<artifactId>clickhouse-client</artifactId>
    9. 				<version>0.5.0</version>
    10. 			</dependency>
    11. 			<dependency>
    12. 				<groupId>com.clickhouse</groupId>
    13. 				<artifactId>clickhouse-http-client</artifactId>
    14. 				<version>0.5.0</version>
    15. 			</dependency>
    16.  
    17. 			<dependency>
    18. 				<groupId>org.apache.httpcomponents.client5</groupId>
    19. 				<artifactId>httpclient5</artifactId>
    20. 				<version>5.2.1</version>
    21. 			</dependency>
    22. 			<dependency>
    23. 				<groupId>org.apache.httpcomponents.client5</groupId>
    24. 				<artifactId>httpclient5-fluent</artifactId>
    25. 				<version>5.1.3</version>
    26. 			</dependency>

    4、application.yml配置

    1. spring:
    2.   application:
    3.     name: demobigdata
    4.   profiles:
    5.     active: mybatis
    6.   datasource:
    7.     type: com.alibaba.druid.pool.DruidDataSource
    8.     druid:
    9.       # 数据源  clickhouse
    10.       clickhouse:
    11.         driverClassName: com.clickhouse.jdbc.ClickHouseDriver
    12.         url: jdbc:clickhouse://192.168.42.142:8123/bigdata
    13.         username: default
    14.         password: 123456
    15.         initialSize: 10
    16.         maxActive: 100
    17.         minIdle: 10
    18.         maxWait: 6000

    5、application-mybatis.yml配置

    1. #mybatis的相关配置
    2. mybatis:
    3.   #mapper配置文件
    4.   type-aliases-package: org.demoflowable.pojo
    5.   mapper-locations: classpath:META-INF/mapper/clickhouse/*.xml
    6.   config-location: classpath:META-INF/spring/mybatis-config.xml

    6、ClickHouseJdbcParamConfig

    1.  
    2. import org.springframework.boot.context.properties.ConfigurationProperties;
    3. import org.springframework.stereotype.Component;
    4.  
    5. @Component
    6. @ConfigurationProperties(prefix = "spring.datasource.druid.clickhouse")
    7. public class ClickHouseJdbcParamConfig {
    8.  
    9. 	private String driverClassName;
    10. 	private String url;
    11. 	private Integer initialSize;
    12. 	private Integer maxActive;
    13. 	private Integer minIdle;
    14. 	private Integer maxWait;
    15.  
    16. 	private String username;
    17. 	private String password;
    18.  
    19. 	public String getDriverClassName() {
    20. 		return driverClassName;
    21. 	}
    22.  
    23. 	public void setDriverClassName(String driverClassName) {
    24. 		this.driverClassName = driverClassName;
    25. 	}
    26.  
    27. 	public String getUrl() {
    28. 		return url;
    29. 	}
    30.  
    31. 	public void setUrl(String url) {
    32. 		this.url = url;
    33. 	}
    34.  
    35. 	public Integer getInitialSize() {
    36. 		return initialSize;
    37. 	}
    38.  
    39. 	public void setInitialSize(Integer initialSize) {
    40. 		this.initialSize = initialSize;
    41. 	}
    42.  
    43. 	public Integer getMaxActive() {
    44. 		return maxActive;
    45. 	}
    46.  
    47. 	public void setMaxActive(Integer maxActive) {
    48. 		this.maxActive = maxActive;
    49. 	}
    50.  
    51. 	public Integer getMinIdle() {
    52. 		return minIdle;
    53. 	}
    54.  
    55. 	public void setMinIdle(Integer minIdle) {
    56. 		this.minIdle = minIdle;
    57. 	}
    58.  
    59. 	public Integer getMaxWait() {
    60. 		return maxWait;
    61. 	}
    62.  
    63. 	public void setMaxWait(Integer maxWait) {
    64. 		this.maxWait = maxWait;
    65. 	}
    66.  
    67. 	public String getUsername() {
    68. 		return username;
    69. 	}
    70.  
    71. 	public void setUsername(String username) {
    72. 		this.username = username;
    73. 	}
    74.  
    75. 	public String getPassword() {
    76. 		return password;
    77. 	}
    78.  
    79. 	public void setPassword(String password) {
    80. 		this.password = password;
    81. 	}
    82. }

     7、ClickHouseConfig

    1.  
    2. import javax.sql.DataSource;
    3.  
    4. import org.springframework.context.annotation.Bean;
    5. import org.springframework.context.annotation.Configuration;
    6.  
    7. import com.alibaba.druid.pool.DruidDataSource;
    8.  
    9. @Configuration
    10. public class ClickHouseConfig {
    11.  
    12. 	@javax.annotation.Resource
    13. 	private ClickHouseJdbcParamConfig jdbcParamConfig;
    14.  
    15. 	@Bean
    16. 	public DataSource dataSource() {
    17. 		DruidDataSource datasource = new DruidDataSource();
    18. 		datasource.setUrl(jdbcParamConfig.getUrl());
    19. 		datasource.setDriverClassName(jdbcParamConfig.getDriverClassName());
    20. 		datasource.setInitialSize(jdbcParamConfig.getInitialSize());
    21. 		datasource.setMinIdle(jdbcParamConfig.getMinIdle());
    22. 		datasource.setMaxActive(jdbcParamConfig.getMaxActive());
    23. 		datasource.setMaxWait(jdbcParamConfig.getMaxWait());
    24. 		datasource.setUsername(jdbcParamConfig.getUsername());
    25. 		datasource.setPassword(jdbcParamConfig.getPassword());
    26. 		return datasource;
    27. 	}
    28.  
    29. }

    8、UserInfo 

    1.  
    2. public class UserInfo {
    3.  
    4. 	private Integer id;
    5.  
    6. 	private String userName;
    7.  
    8. 	private String passWord;
    9.  
    10. 	private String phone;
    11.  
    12. 	private String createDay;
    13.  
    14. 	public Integer getId() {
    15. 		return id;
    16. 	}
    17.  
    18. 	public void setId(Integer id) {
    19. 		this.id = id;
    20. 	}
    21.  
    22. 	public String getUserName() {
    23. 		return userName;
    24. 	}
    25.  
    26. 	public void setUserName(String userName) {
    27. 		this.userName = userName;
    28. 	}
    29.  
    30. 	public String getPassWord() {
    31. 		return passWord;
    32. 	}
    33.  
    34. 	public void setPassWord(String passWord) {
    35. 		this.passWord = passWord;
    36. 	}
    37.  
    38. 	public String getPhone() {
    39. 		return phone;
    40. 	}
    41.  
    42. 	public void setPhone(String phone) {
    43. 		this.phone = phone;
    44. 	}
    45.  
    46. 	public String getCreateDay() {
    47. 		return createDay;
    48. 	}
    49.  
    50. 	public void setCreateDay(String createDay) {
    51. 		this.createDay = createDay;
    52. 	}
    53. }

     

    9、UserInfoMapper

    1.  
    2. import java.util.List;
    3.  
    4. import org.apache.ibatis.annotations.Param;
    5. import org.demoflowable.pojo.user.po.UserInfo;
    6.  
    7. public interface UserInfoMapper {
    8.  
    9. 	void saveData(UserInfo userInfo);
    10.  
    11. 	UserInfo selectById(@Param("id") Integer id);
    12.  
    13. 	List selectList();
    14. }

    10、UserInfoService 

    1.  
    2. import java.util.List;
    3.  
    4. import javax.annotation.Resource;
    5.  
    6. import org.demoflowable.clickhouse.dao.user.UserInfoMapper;
    7. import org.demoflowable.pojo.user.po.UserInfo;
    8. import org.springframework.stereotype.Service;
    9.  
    10. @Service
    11. public class UserInfoService {
    12.  
    13. 	@Resource
    14. 	private UserInfoMapper userInfoMapper;
    15.  
    16. 	public void saveData(UserInfo userInfo) {
    17. 		userInfoMapper.saveData(userInfo);
    18. 	}
    19.  
    20. 	public UserInfo selectById(Integer id) {
    21. 		return userInfoMapper.selectById(id);
    22. 	}
    23.  
    24. 	public List<UserInfo> selectList() {
    25. 		return userInfoMapper.selectList();
    26. 	}
    27.  
    28. }

    11、UserInfoController

    1.  
    2. import java.util.List;
    3.  
    4. import javax.annotation.Resource;
    5.  
    6. import org.demoflowable.pojo.user.po.UserInfo;
    7. import org.demoflowable.service.user.UserInfoService;
    8. import org.springframework.web.bind.annotation.GetMapping;
    9. import org.springframework.web.bind.annotation.RestController;
    10.  
    11. @RestController
    12. public class UserInfoController {
    13.  
    14. 	@Resource
    15. 	private UserInfoService userInfoService;
    16.  
    17. 	/**
    18. 	 * 保存
    19. 	 * @return
    20. 	 */
    21. 	@GetMapping("/saveUser")
    22. 	public String saveUser() {
    23. 		UserInfo userInfo = new UserInfo();
    24. 		userInfo.setId(4);
    25. 		userInfo.setUserName("xiaolin");
    26. 		userInfo.setPassWord("54321");
    27. 		userInfo.setPhone("18500909876");
    28. 		userInfo.setCreateDay("2022-02-06");
    29. 		userInfoService.saveData(userInfo);
    30. 		return "success";
    31. 	}
    32.  
    33. 	/**
    34. 	 * 根据id查询
    35. 	 * @param id
    36. 	 * @return
    37. 	 */
    38. 	@GetMapping("/getById")
    39. 	public UserInfo getById(int id) {
    40. 		return userInfoService.selectById(id);
    41. 	}
    42.  
    43. 	/**
    44. 	 * 查询所有
    45. 	 * @return
    46. 	 */
    47. 	@GetMapping("/getList")
    48. 	public List getList() {
    49. 		return userInfoService.selectList();
    50. 	}
    51. }

    12、Application

    1. import org.mybatis.spring.annotation.MapperScan;
    2. import org.springframework.boot.SpringApplication;
    3. import org.springframework.boot.autoconfigure.SpringBootApplication;
    4. import org.springframework.context.annotation.ComponentScan;
    5. import org.springframework.web.bind.annotation.GetMapping;
    6. import org.springframework.web.bind.annotation.RequestParam;
    7. import org.springframework.web.bind.annotation.RestController;
    8.  
    9. /**
    10.  * @Description: 启动类
    11.  */
    12. @SpringBootApplication
    13. @ComponentScan({ "org.demoflowable" })
    14. @MapperScan(basePackages = "org.demoflowable.*.dao")
    15. public class Application {
    16.  
    17. 	/**
    18. 	 * @Title: main
    19. 	 * @Description: 启动类
    20. 	 * @param args
    21. 	 * @date 2023-11-08 23:49:23
    22. 	 */
    23. 	public static void main(String[] args) {
    24. 		SpringApplication.run(Application.class, args);
    25. 	}
    26. }

    启动代码成功

    12、查看接口数据

    数据对应上了，springboot与clickhouse集成成功

  • 相关阅读:
    淘宝官方开放平台API接口获得店铺的所有商品、商品id、商品标题、销量参数调用示例
    python基本知识-第一周
    #安装es 常见报错#
    20220809NOI模拟赛
    用 50 张游戏显卡检测癌症，这是“业余”程序员？
    动态内存申请
    OSPF高级特性1(重发布，虚链路）
    rabbitmq 消费者报错 ListenerExecutionFailedException NullPointerException
    粉末冶金5G智能工厂工业物联数字孪生平台，推进制造业数字化转型
    春秋云镜 CVE-2017-5638
  • 原文地址：https://blog.csdn.net/itorac/article/details/134298680