SpringBoot系列Mysql、Sqlserver双数据源配置

Z时代
2024-01-10
分类：综合

application.properties配置文件

spring.datasource.mysql.username=root spring.datasource.mysql.password=123456 spring.datasource.mysql.driver-class-name=com.mysql.jdbc.Driver spring.datasource.mysql.url=jdbc:mysql://localhost:3306/test spring.datasource.sqlserver.username=root spring.datasource.sqlserver.password=123456 spring.datasource.sqlserver.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver spring.datasource.sqlserver.url=jdbc:sqlserver://localhost:1433;DatabaseName=test

连接池配置

package com.tcwong.demo.config;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
	[@Primary](https://my.oschina.net/primary)
	[@Bean](https://my.oschina.net/bean)
	@ConditionalOnProperty(prefix = "spring.datasource.mysql")
	public DataSource mysqlDataSource() {
		return DruidDataSourceBuilder.create().build();
	}
	[@Bean](https://my.oschina.net/bean)
	@ConditionalOnProperty(prefix = "spring.datasource.sqlserver")
	public DataSource sqlserverDataSource() {
		return DruidDataSourceBuilder.create().build();
	}
}

或者

package com.tcwong.demo.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import javax.sql.DataSource;
@Configuration
public class DataSourceConfig1 {
	@Value("${spring.datasource.mysql.username}")
	private String mysqlUserName;
	@Value("${spring.datasource.mysql.password}")
	private String mysqlPassword;
	@Value("${spring.datasource.mysql.url}")
	private String mysqlUrl;
	@Value("${spring.datasource.mysql.driver-class-name}")
	private String mysqlDriverClass;
	@Value("${spring.datasource.sqlserver.username}")
	private String sqlserverPassword;
	@Value("${spring.datasource.sqlserver.password}")
	private String sqlserverUserName;
	@Value("${spring.datasource.sqlserver.url}")
	private String sqlserverUrl;
	@Value("${spring.datasource.sqlserver.driver-class-name}")
	private String sqlserverDriverClass;
	@Primary
	@Bean
	public DataSource mysqlDataSource() {
		DruidDataSource druidDataSource = new DruidDataSource();
		druidDataSource.setUsername(mysqlUserName);
		druidDataSource.setPassword(mysqlPassword);
		druidDataSource.setUrl(mysqlUrl);
		druidDataSource.setDriverClassName(mysqlDriverClass);
		return druidDataSource;
	}
	@Bean
	public DataSource sqlserverDataSource() {
		DruidDataSource druidDataSource = new DruidDataSource();
		druidDataSource.setUsername(sqlserverUserName);
		druidDataSource.setPassword(sqlserverPassword);
		druidDataSource.setUrl(sqlserverUrl);
		druidDataSource.setDriverClassName(sqlserverDriverClass);
		return druidDataSource;
	}
}

MyBatis配置

Mysql配置

package com.tcwong.demo.config;
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.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import javax.annotation.Resource;
import javax.sql.DataSource;
@Configuration
@MapperScan(basePackages = "com.tcwong.demo.dao.mysql"
		,sqlSessionFactoryRef = "mysqlSqlSessionFactory",sqlSessionTemplateRef = "mysqlSqlSessionTemplate")
public class MysqlMapperConfig {
	@Resource
	private DataSource mysqlDataSource;
	@Primary
	@Bean
	SqlSessionFactory mysqlSqlSessionFactory() {
		SqlSessionFactory sqlSessionFactory = null;
		try {
			SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
			sqlSessionFactoryBean.setDataSource(mysqlDataSource);
			sqlSessionFactoryBean.setTypeAliasesPackage("com.tcwong.demo.bean");
			sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
					.getResource("classpath*:mapper/**/*.xml"));
			sqlSessionFactory = sqlSessionFactoryBean.getObject();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return sqlSessionFactory;
	}
	@Primary
	@Bean
	SqlSessionTemplate mysqlSqlSessionTemplate() {
		return new SqlSessionTemplate(mysqlSqlSessionFactory());
	}
}

Sqlserver配置

package com.tcwong.demo.config;
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.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import javax.annotation.Resource;
import javax.sql.DataSource;
@Configuration
@MapperScan(basePackages = "com.tcwong.demo.dao.sqlserver"
		,sqlSessionFactoryRef = "sqlserverSqlSessionFactory", sqlSessionTemplateRef = "sqlserverSqlSessionTemplate")
public class sqlserverMapperConfig {
	@Resource
	private DataSource sqlserverDataSource;
	@Bean
	SqlSessionFactory sqlserverSqlSessionFactory() {
		SqlSessionFactory sqlSessionFactory = null;
		try {
			SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
			sqlSessionFactoryBean.setDataSource(sqlserverDataSource);
			sqlSessionFactoryBean.setTypeAliasesPackage("com.tcwong.demo.bean");
			sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver()
					.getResource("classpath*:mapper/**/*.xml"));
			sqlSessionFactory = sqlSessionFactoryBean.getObject();
		} catch (Exception e) {
			e.printStackTrace();
		}
		return sqlSessionFactory;
	}
	@Bean
	SqlSessionTemplate sqlserverSqlSessionTemplate() {
		return new SqlSessionTemplate(sqlserverSqlSessionFactory());
	}
}