自建网站如何上传视频,今天军事新闻最新消息详细,网上教学网站建设,包头天亿网站建设公司文章目录 Springboot 整合多动态数据源 这里有mysql#xff08;分为master 和 slave#xff09; 和oracle1. 引入相关的依赖2. 创建相关配置文件3. 在相关目录下进行编码#xff0c;不同路径会使用不同数据源 Springboot 整合多动态数据源 这里有mysql#xff08;分为maste… 文章目录 Springboot 整合多动态数据源 这里有mysql分为master 和 slave 和oracle1. 引入相关的依赖2. 创建相关配置文件3. 在相关目录下进行编码不同路径会使用不同数据源 Springboot 整合多动态数据源 这里有mysql分为master 和 slave 和oracle
1. 引入相关的依赖 !--动态数据源--dependencygroupIdcom.baomidou/groupIdartifactIddynamic-datasource-spring-boot-starter/artifactIdversion${dynamic-datasource.version}/version/dependency!-- mysql --dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdscoperuntime/scope/dependency!-- oracle --dependencygroupIdcom.oracle.database.jdbc/groupIdartifactIdojdbc6/artifactIdversion${ojdbc.version}/version/dependency
2. 创建相关配置文件
package com.aspire.sc.base.data.config;import javax.sql.DataSource;import org.springframework.beans.factory.annotation.Qualifier;//import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;Configuration
public class DataSourceConfig {Bean(name master)Qualifier(master)PrimaryConfigurationProperties(prefixspring.datasource.dynamic.datasource.master)public DataSource primaryDataSource(){return DataSourceBuilder.create().build();}Bean(name slave)Qualifier(slave)ConfigurationProperties(prefixspring.datasource.dynamic.datasource.slave)public DataSource slave(){return DataSourceBuilder.create().build();}Bean(name oracleDataSource)Qualifier(oracleDataSource)ConfigurationProperties(prefix spring.datasource.dynamic.datasource.oracle)public DataSource oracleDataSource(){return DataSourceBuilder.create().build();}}
package com.aspire.sc.base.data.config;import com.aspire.common.dictenum.DictBaseEnum;
import com.aspire.common.dictenum.DictBaseItem;
import com.baomidou.mybatisplus.core.MybatisConfiguration;
import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.type.JdbcType;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;/*** 数据库leadnews_article*/
Configuration
public class MysqlDataSourceConfig {BeanPrimarypublic SqlSessionFactory mysqlSqlSessionFactory(Qualifier(master) DataSource dataSource) throws Exception {return createSqlSessionFactory(dataSource);}Beanpublic SqlSessionFactory mysqlSlaveSqlSessionFactory(Qualifier(slave) DataSource dataSource) throws Exception {return createSqlSessionFactory(dataSource);}private SqlSessionFactory createSqlSessionFactory(DataSource dataSource) throws Exception {MybatisSqlSessionFactoryBean sqlSessionFactory new MybatisSqlSessionFactoryBean();sqlSessionFactory.setDataSource(dataSource);MybatisConfiguration configuration new MybatisConfiguration();configuration.setJdbcTypeForNull(JdbcType.NULL);configuration.setMapUnderscoreToCamelCase(true);configuration.setCacheEnabled(false);// 添加分页功能PaginationInterceptor paginationInterceptor new PaginationInterceptor();sqlSessionFactory.setPlugins(new Interceptor[]{paginationInterceptor});sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(classpath:mapper/*/*.xml));sqlSessionFactory.setTypeHandlersPackage(com.aspire.common.constant);sqlSessionFactory.setTypeEnumsPackage(com.aspire.common.constant, com.aspire.sc.base.data.domain.*.pojo, com.aspire.sc.base.data.constant);return sqlSessionFactory.getObject();}BeanPrimarypublic SqlSessionTemplate mysqlSqlSessionTemplate(Qualifier(mysqlSqlSessionFactory) SqlSessionFactory sqlSessionFactory) throws Exception {return new SqlSessionTemplate(sqlSessionFactory);}Bean(name masterTransactionManager)Primarypublic DataSourceTransactionManager masterTransactionManager(Qualifier(master) DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}Bean(name slaveTransactionManager)public DataSourceTransactionManager slaveTransactionManager(Qualifier(slave) DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}
}
package com.aspire.sc.base.data.config;import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;Configuration
//MapperScan(basePackages com.aspire.sc.base.data.oracledomain.*, sqlSessionFactoryRef oracleSqlSessionFactory)
public class OracleDataSourceConfig {Bean(name oracleSqlSessionFactory)public SqlSessionFactory oracleSqlSessionFactory(Qualifier(oracleDataSource) DataSource dataSource) throws Exception {MybatisSqlSessionFactoryBean sqlSessionFactory new MybatisSqlSessionFactoryBean();sqlSessionFactory.setDataSource(dataSource);sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(classpath:oraclemapper/*.xml));return sqlSessionFactory.getObject();}Beanpublic SqlSessionTemplate oracleSqlSessionTemplate(Qualifier(oracleSqlSessionFactory) SqlSessionFactory sqlSessionFactory) throws Exception {return new SqlSessionTemplate(sqlSessionFactory);}Bean(name oracleTransactionManager)public DataSourceTransactionManager oracleTransactionManager(Qualifier(oracleDataSource) DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}
}
启动文件加上
import com.baomidou.dynamic.datasource.plugin.MasterSlaveAutoRoutingPlugin;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.boot.web.servlet.ServletComponentScan;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.transaction.annotation.EnableTransactionManagement;/*** author wanggh*/
EnableConfigurationProperties
ComponentScan({com.aspire})
EnableTransactionManagement(proxyTargetClass true)MapperScan(basePackages {com.aspire.sc.base.data.domain.*.mapper}, sqlSessionFactoryRef mysqlSqlSessionFactory)
MapperScan(basePackages {com.aspire.sc.base.data.oracledomain.mapper}, sqlSessionFactoryRef oracleSqlSessionFactory)
SpringBootApplication(exclude {DataSourceAutoConfiguration.class})
ServletComponentScan
EnableCaching
public class MsBaseDataApplication {public static void main(String[] args) {SpringApplication.run(MsBaseDataApplication.class, args);}/*** 纯的读写分离环境写操作全部是master读操作全部是slave* 默认主库名称master,从库名称slave。* 不用加DS注解*/Beanpublic MasterSlaveAutoRoutingPlugin masterSlaveAutoRoutingPlugin() {return new MasterSlaveAutoRoutingPlugin();}}
3. 在相关目录下进行编码不同路径会使用不同数据源
