网站优化的学习,网站建设项目设计的图片,电子上网站开发,四川建设培训网说明#xff1a;如果实现了docker部署mysql并完成主从复制的话再继续#xff0c;本篇文章主要说明springboot配置实现Shardingjdbc进行读写分离操作。
如果没实现docker部署mysql实现主从架构的话点击我 Shardingjdbc配置介绍#xff08;版本#xff1a;5.3.2#xff09;… 说明如果实现了docker部署mysql并完成主从复制的话再继续本篇文章主要说明springboot配置实现Shardingjdbc进行读写分离操作。
如果没实现docker部署mysql实现主从架构的话点击我 Shardingjdbc配置介绍版本5.3.2
application.yml配置设置连接池全局属性
spring:datasource:driver-class-name: org.apache.shardingsphere.driver.ShardingSphereDriverurl: jdbc:shardingsphere:classpath:qiyu-db-sharding.yamlhikari:pool-name: qiyu-user-poolminimum-idle: 15idle-timeout: 60000maximum-pool-size: 300connection-init-sql: select 1connection-timeout: 4000max-lifetime: 60000
shardingjdbc读写分离配置qiyu-db-sharding.yaml
dataSources:user_master: ##新表重建的分表dataSourceClassName: com.zaxxer.hikari.HikariDataSourcedriver-class-name: com.mysql.cj.jdbc.DriverjdbcUrl: jdbc:mysql://192.168.1.128:8808/qiyu_live_user?useUnicodetruecharacterEncodingutf8username: rootpassword: rootuser_slave0: ##新表重建的分表dataSourceClassName: com.zaxxer.hikari.HikariDataSourcedriver-class-name: com.mysql.cj.jdbc.DriverjdbcUrl: jdbc:mysql://192.168.1.128:8809/qiyu_live_user?useUnicodetruecharacterEncodingutf8username: rootpassword: rootrules:- !READWRITE_SPLITTINGdataSources:#读写分离配置user_ds:staticStrategy:writeDataSourceName: user_masterreadDataSourceNames:- user_slave0- !SINGLE# 不分表分分库的默认数据源defaultDataSource: user_ds- !SHARDINGtables:t_user:actualDataNodes: user_ds.t_user_${(0..04).collect(){it.toString().padLeft(2,0)}}tableStrategy:standard:#指定用于分表的列名。shardingColumn: user_idshardingAlgorithmName: t_user-inline#定义分表算法shardingAlgorithms:t_user-inline:type: INLINEprops:#根据user_id对5取模的结果将作为分表的后缀范围为00到04对应五个表并在左侧填充0。algorithm-expression: t_user_${(user_id % 5).toString().padLeft(2,0)}
props:sql-show: true
同时这个hikari的数据源有点小bug加个配置类
package com.laoyang.provider.config;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.ApplicationRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import javax.sql.DataSource;
import java.sql.Connection;/*** author:Kevin* create: 2023-07-29 21:30* Description:*/
Configuration
public class ShardingjdbcDatasourceAutoConnectionconfig {private static final Logger LOGGER LoggerFactory.getLogger(ShardingjdbcDatasourceAutoConnectionconfig.class);Beanpublic ApplicationRunner runner(DataSource dataSource) {return args - {LOGGER.info(dataSource: {},dataSource);//手动触发下连接池的连接创建Connection connection dataSource.getConnection();};}
}运行出现下图说明配置成功。
