【Kotlin Spring Boot 4 从零到架构师】第 50 篇多数据源集成本系列定位零基础入门从 Kotlin 语法一路到 Spring Boot 4 高级架构DDD Modulith适合 Java 开发者转型也适合纯新手系统学习。本篇你将学到多数据源的应用场景多数据源配置策略Primary/Qualifier的使用主库PostgreSQL 分析库ClickHouse的双数据源实战学完本篇你将能让 mini-shop 同时连接多个数据库各司其职。一、为什么需要多数据源1.1 典型场景场景数据源 A数据源 B读写分离主库写从库读业务 分析PostgreSQL业务ClickHouse统计分析多租户主租户库独立租户库迁移过渡旧数据库新数据库1.2 mini-shop 场景PostgreSQL主库商品、订单、用户 —— 高频读写 ClickHouse分析库订单统计、销量报表 —— 低频大量查询下面是 mini-shop 多数据源架构总览ClickHouse 分析库PostgreSQL 主库mini-shop 应用JPA / PrimaryNamedParameterJdbcTemplate / Qualifier业务 Service分析 AnalyticsService订单表商品表用户表订单统计销量报表二、配置两个数据源2.1 添加依赖dependencies{implementation(org.springframework.boot:spring-boot-starter-data-jpa)runtimeOnly(org.postgresql:postgresql)runtimeOnly(com.clickhouse:clickhouse-jdbc:0.7.0)}2.2 application.ymlspring:datasource:# 主数据源PostgreSQL—— 业务数据url:jdbc:postgresql://localhost:5432/mini_shopusername:postgrespassword:postgres123driver-class-name:org.postgresql.Driverhikari:pool-name:PrimaryPool# 自定义分析数据源配置analytics:datasource:url:jdbc:clickhouse://localhost:8123/mini_shop_analyticsusername:defaultpassword:driver-class-name:com.clickhouse.jdbc.ClickHouseDriverhikari:pool-name:AnalyticsPoolmaximum-pool-size:52.3 主数据源配置packagecom.example.minishop.configimportorg.springframework.boot.autoconfigure.jdbc.DataSourcePropertiesimportorg.springframework.boot.context.properties.ConfigurationPropertiesimportorg.springframework.boot.jdbc.autoconfigure.DataSourcePropertiesasBootDataSourcePropertiesimportorg.springframework.context.annotation.Beanimportorg.springframework.context.annotation.Configurationimportorg.springframework.context.annotation.Primaryimportorg.springframework.data.jpa.repository.config.EnableJpaRepositoriesimportjavax.sql.DataSourceConfigurationEnableJpaRepositories(basePackages[com.example.minishop.product,com.example.minishop.order,com.example.minishop.user],entityManagerFactoryRefprimaryEntityManagerFactory,transactionManagerRefprimaryTransactionManager)classPrimaryDataSourceConfig{BeanPrimaryConfigurationProperties(spring.datasource)funprimaryDataSourceProperties():DataSourceProperties{returnDataSourceProperties()}BeanPrimaryfunprimaryDataSource():DataSource{returnprimaryDataSourceProperties().initializeDataSourceBuilder().build()}}2.4 分析数据源配置packagecom.example.minishop.configimportorg.springframework.boot.context.properties.ConfigurationPropertiesimportorg.springframework.context.annotation.Beanimportorg.springframework.context.annotation.Configurationimportorg.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplateimportjavax.sql.DataSourceConfigurationclassAnalyticsDataSourceConfig{BeanConfigurationProperties(spring.analytics.datasource)funanalyticsDataSourceProperties():DataSourceProperties{returnDataSourceProperties()}Bean(analyticsDataSource)funanalyticsDataSource():DataSource{returnanalyticsDataSourceProperties().initializeDataSourceBuilder().build()}Bean(analyticsJdbcTemplate)funanalyticsJdbcTemplate(Qualifier(analyticsDataSource)dataSource:DataSource):NamedParameterJdbcTemplate{returnNamedParameterJdbcTemplate(dataSource)}}2.5 使用分析数据源ServiceclassAnalyticsService(Qualifier(analyticsJdbcTemplate)privatevalanalyticsJdbc:NamedParameterJdbcTemplate){/** * 查询每日销售统计 */fungetDailySalesStats(startDate:String,endDate:String):ListDailySalesStat{valsql SELECT toDate(created_at) AS date, count() AS order_count, sum(total_amount) AS total_revenue, avg(total_amount) AS avg_order_value FROM orders WHERE created_at BETWEEN :start AND :end AND status PAID GROUP BY date ORDER BY date .trimIndent()valparamsmapOf(starttostartDate,endtoendDate)returnanalyticsJdbc.query(sql,params){rs,_-DailySalesStat(daters.getString(date),orderCountrs.getLong(order_count),totalRevenuers.getBigDecimal(total_revenue),avgOrderValuers.getBigDecimal(avg_order_value))}}}dataclassDailySalesStat(valdate:String,valorderCount:Long,valtotalRevenue:BigDecimal,valavgOrderValue:BigDecimal)下面是双数据源配置与注入的完整流程Service 层Repository 层Bean 定义配置层application.ymlspring.datasource (PG)spring.analytics.datasource (CH)PrimaryDataSourceConfigConfigurationPropertiesPrimaryAnalyticsDataSourceConfigConfigurationPropertiesprimaryDataSource (PG)PrimaryanalyticsDataSource (CH)analyticsJdbcTemplateNamedParameterJdbcTemplateEnableJpaRepositoriesproduct / order / userOrderService自动注入 PrimaryAnalyticsServiceQualifier 指定三、关键注意事项3.1 Primary 的作用当 Spring 容器中有多个DataSourceBean 时Primary标记的 Bean 是默认选择。Liquibase、Spring Data JPA 自动配置默认会用Primary的数据源。BeanPrimary// ← 主数据源Spring Boot 自动配置用这个funprimaryDataSource():DataSource{...}3.2 Qualifier 精确指定// 不用 Primary 时必须用 Qualifier 指定ServiceclassAnalyticsService(Qualifier(analyticsDataSource)// ← 精确指定分析数据源privatevalanalyticsDataSource:DataSource)3.3 ClickHouse autoCommit 陷阱ClickHouse 的 JDBC 驱动要求autoCommit true与 PostgreSQL 不同spring:analytics:datasource:hikari:auto-commit:true# ClickHouse 必须为 true3.4 Liquibase 只在主数据源spring:liquibase:change-log:classpath:db/changelog/db.changelog-master.yaml# Liquibase 默认用 Primary 数据源不需要额外配置四、Primary vs Qualifier 决策方式特点场景Primary全局默认选择主数据源90% 用这个Qualifier(name)精确指定分析数据源、特定场景原则主数据源用Primary其他数据源用Qualifier显式注入。下面是数据源选择决策流程图是否是否是否需要注入 DataSource只有一个 DataSource BeanSpring 自动注入无需额外注解该数据源是主业务数据源标记 Primary全局默认选择注入点明确知道要哪个数据源使用 Qualifier(beanName)精确指定编译报错NoUniqueBeanDefinitionExceptionLiquibase / JPA 自动配置默认使用 Primary手动指定注入如 analyticsDataSource本篇小结知识点核心内容多数据源业务库 分析库 / 读写分离Primary标记主数据源默认选择Qualifier精确指定注入哪个数据源ConfigurationProperties绑定各数据源配置EnableJpaRepositories指定 Repository 用哪个数据源NamedParameterJdbcTemplate非 JPA 的数据源操作ClickHouse autoCommit必须为trueLiquibase只在主数据源下篇预告第 51 篇Kotlin 协程在 Spring Boot 中的应用Spring Boot 4 支持协程 Controller下一篇学习suspend函数在 Web 层、数据访问层的实际应用以及虚拟线程的对比。如果本篇内容对你有帮助欢迎点赞收藏有任何疑问欢迎在评论区交流。