• SpringBoot实现mysql与clickhouse多数据源

    一、我们来实现一个mysql与clickhouse多数据源配置

    二、数据源配置

    1. # 指定服务名称
    2. spring:
    3.   application:
    4.     name: demobigdata
    5.   datasource:
    6.     driver-class-name: com.mysql.jdbc.Driver
    7.     url: jdbc:mysql://127.0.0.1:3306/db?createDatabaseIfNotExist=true&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=false&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useAffectedRows=true&allowPublicKeyRetrieval=true
    8.     username: root
    9.     password: 123456
    10.     type: com.alibaba.druid.pool.DruidDataSource
    11.     druid:
    12.       # 数据源  clickhouse
    13.       clickhouse:
    14.         driverClassName: com.clickhouse.jdbc.ClickHouseDriver
    15.         url: jdbc:clickhouse://192.168.42.142:8123/bigdata
    16.         username: default
    17.         password: 123456
    18.         initialSize: 10
    19.         maxActive: 100
    20.         minIdle: 10
    21.         maxWait: 6000

    三、MysqlDuridConfig

    1.  
    2. import javax.sql.DataSource;
    3.  
    4. import org.apache.ibatis.session.SqlSessionFactory;
    5. import org.mybatis.spring.SqlSessionFactoryBean;
    6. import org.mybatis.spring.annotation.MapperScan;
    7. import org.springframework.beans.factory.annotation.Qualifier;
    8. import org.springframework.context.annotation.Bean;
    9. import org.springframework.context.annotation.Configuration;
    10. import org.springframework.context.annotation.Primary;
    11. import org.springframework.core.io.Resource;
    12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    13. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    14.  
    15. import com.alibaba.druid.pool.DruidDataSource;
    16.  
    17. @Configuration
    18. @MapperScan(basePackages = "org.demoflowable.mysql.dao")
    19. public class MysqlDuridConfig {
    20.  
    21. 	@javax.annotation.Resource
    22. 	MysqlJdbcParamConfig mysqlJdbcParamConfig;
    23.  
    24. 	@Bean("mysqlDataSource")
    25. 	@Primary
    26. 	public DataSource mysqlDataSource() {
    27. 		DruidDataSource datasource = new DruidDataSource();
    28. 		datasource.setUrl(mysqlJdbcParamConfig.getUrl());
    29. 		datasource.setDriverClassName(mysqlJdbcParamConfig.getDriverClassName());
    30. 		datasource.setUsername(mysqlJdbcParamConfig.getUsername());
    31. 		datasource.setPassword(mysqlJdbcParamConfig.getPassword());
    32. 		return datasource;
    33. 	}
    34.  
    35. 	@Bean("mysqlTransactionManager")
    36. 	@Primary
    37. 	public DataSourceTransactionManager getDataSourceTransactionManager(
    38. 			@Qualifier("mysqlDataSource") DataSource dataSource) {
    39. 		return new DataSourceTransactionManager(dataSource);
    40. 	}
    41.  
    42. 	@Bean("sqlSessionFactory")
    43. 	@Primary
    44. 	public SqlSessionFactory getSqlSessionManager(@Qualifier("mysqlDataSource") DataSource dataSource)
    45. 			throws Exception {
    46. 		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    47. 		bean.setDataSource(dataSource);
    48. 		Resource[] resource = new PathMatchingResourcePatternResolver().getResources("classpath:META-INF/mapper/mysql/*.xml");
    49. 	    bean.setMapperLocations(resource);
    50. 	    Resource configLocation=new PathMatchingResourcePatternResolver().getResource("classpath:META-INF/spring/mybatis-config.xml");
    51. 	    bean.setConfigLocation(configLocation);
    52. 		return bean.getObject();
    53. 	}
    54. }

    四、MysqlJdbcParamConfig

    1.  
    2. import org.springframework.boot.context.properties.ConfigurationProperties;
    3. import org.springframework.stereotype.Component;
    4.  
    5. @Component
    6. @ConfigurationProperties(prefix = "spring.datasource")
    7. public class MysqlJdbcParamConfig {
    8. 	
    9. 	private String driverClassName;
    10. 	
    11. 	private String url;
    12. 	
    13. 	private String username;
    14. 	
    15. 	private String password;
    16.  
    17. 	public String getDriverClassName() {
    18. 		return driverClassName;
    19. 	}
    20.  
    21. 	public void setDriverClassName(String driverClassName) {
    22. 		this.driverClassName = driverClassName;
    23. 	}
    24.  
    25. 	public String getUrl() {
    26. 		return url;
    27. 	}
    28.  
    29. 	public void setUrl(String url) {
    30. 		this.url = url;
    31. 	}
    32.  
    33. 	public String getUsername() {
    34. 		return username;
    35. 	}
    36.  
    37. 	public void setUsername(String username) {
    38. 		this.username = username;
    39. 	}
    40.  
    41. 	public String getPassword() {
    42. 		return password;
    43. 	}
    44.  
    45. 	public void setPassword(String password) {
    46. 		this.password = password;
    47. 	}
    48. }

    五、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. }

    六、ClickHouseConfig 

    1.  
    2. import org.apache.ibatis.session.SqlSessionFactory;
    3. import org.mybatis.spring.SqlSessionFactoryBean;
    4. import org.mybatis.spring.annotation.MapperScan;
    5. import org.springframework.beans.factory.annotation.Qualifier;
    6. import org.springframework.boot.context.properties.ConfigurationProperties;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Configuration;
    9. import org.springframework.core.io.Resource;
    10. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    11. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    12.  
    13. import com.alibaba.druid.pool.DruidDataSource;
    14.  
    15. @Configuration
    16. @ConfigurationProperties
    17. @MapperScan(basePackages = "org.demoflowable.clickhouse.dao", sqlSessionFactoryRef = "clickhouseSqlSessionFactory")
    18. public class ClickHouseConfig {
    19.  
    20. 	@javax.annotation.Resource
    21. 	private ClickHouseJdbcParamConfig jdbcParamConfig;
    22.  
    23. 	@Bean("clickDataSource")
    24. 	public DataSource dataSource() {
    25. 		DruidDataSource datasource = new DruidDataSource();
    26. 		datasource.setUrl(jdbcParamConfig.getUrl());
    27. 		datasource.setDriverClassName(jdbcParamConfig.getDriverClassName());
    28. 		datasource.setInitialSize(jdbcParamConfig.getInitialSize());
    29. 		datasource.setMinIdle(jdbcParamConfig.getMinIdle());
    30. 		datasource.setMaxActive(jdbcParamConfig.getMaxActive());
    31. 		datasource.setMaxWait(jdbcParamConfig.getMaxWait());
    32. 		datasource.setUsername(jdbcParamConfig.getUsername());
    33. 		datasource.setPassword(jdbcParamConfig.getPassword());
    34. 		return datasource;
    35. 	}
    36.  
    37. 	@Bean("clickTransactionManager")
    38. 	public DataSourceTransactionManager getDataSourceTransactionManager(
    39. 			@Qualifier("clickDataSource") DataSource dataSource) {
    40. 		return new DataSourceTransactionManager(dataSource);
    41. 	}
    42.  
    43. 	@Bean("clickhouseSqlSessionFactory")
    44. 	public SqlSessionFactory getSqlSessionManager(@Qualifier("clickDataSource") DataSource dataSource)
    45. 			throws Exception {
    46. 		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    47. 		bean.setDataSource(dataSource);
    48. 		Resource[] resource = new PathMatchingResourcePatternResolver()
    49. 				.getResources("classpath:META-INF/mapper/clickhouse/*.xml");
    50. 		bean.setMapperLocations(resource);
    51. 		return bean.getObject();
    52. 	}
    53. }

    七、启动类Application

    1.  
    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. public class Application {
    15.  
    16. 	/**
    17. 	 * @Title: main
    18. 	 * @Description: 启动类
    19. 	 * @param args
    20. 	 * @date 2023-11-08 01:49:23
    21. 	 */
    22. 	public static void main(String[] args) {
    23. 		SpringApplication.run(Application.class, args);
    24. 	}
    25.  
    26. }

  • 相关阅读:
    【informix】解决启动报错大全，以及解决办法
    Netty高性能之Reactor模型
    EasyExcel 修改导出的文件属性
    【Three.js】第十二章 Materials 材质
    程序员的成长分岔路——技术管理和技术专家，怎么选？
    【Mycat】Mycat主从复制
    利用python写一个可视化的界面
    华为云文件上传（单个上传和分段上传）
    MXNet对GoogLeNet的实现(并行连结网络)
    MySQL系列——集群复制方式及原理
  • 原文地址：https://blog.csdn.net/itorac/article/details/134299234