springboot 中druid怎么连接多个数据库

spring动态配置多数据源，即在大型应用中对数据进行切分，并且采用多个数据库实例进行管理，这样可以有效提高系统的水平伸缩性。

而这样的方案就会不同于常见的单一数据实例的方案，这就要程序在运行时根据当时的请求及系统状态来动态的决定将数据存储在哪个数据库实例中，以及从哪个数据库提取数据。

本人最近接到一个任务，将一个系统改成同时兼容Oracle和PostgreSQL(原来是仅支持Oracle)。虽然大部分的sql语句通用，但是还有许多语法存在差异，所以我们可以通过mybatis自身提供的databaseIdProvider解决这个问题，这里记录一下过程。

通过配置文件开启mysql支持或者postgresql支持

其他主从方式配置模板

@DS 可以注解在方法上和类上，同时存在方法注解优先于类上注解。

强烈建议只注解在service实现上。

某些springBoot的版本上面可能无法排除（尝试使用以下方式排除）

为什么需要多数据库？

默认情况下，Spring Boot使用的是单数据库配置（通过springdatasource配置具体数据库连接信息）。

对于绝大多数Spring Boot应用，这是符合其使用场景的，因为Spring Boot提倡的是微服务理念，每个应用对应一个单独的业务领域。但在某些特殊情况下，一个应用对应多个数据库又是无法避免的，例如实施数据库分库后原本单个数据库变为多个数据库。本文就结合实际代码介绍如何在单个Boot应用中配置多数据库，以及与之相关的Druid，jOOQ，Flyway等数据服务框架的配置改造。

配置示例

DB1，DB2: 两个示例数据库

ServiceA, ServiceB: 分别使用DB1和DB2的服务类

连接池Druid

Druid是阿里巴巴开源的数据库连接池，提供了强大的监控支持，号称Java语言中最好的连接池。

创建两个配置类分别注册对应DB1和DB2的DataSource Bean和TransactionManager Bean。以DB1为例：

Tip: 可以把其中一个配置类中注册的DataSource Bean和DataSourceTransactionManager Bean加上@Primary注解，作为默认装配实例。

// DB1

@Configuration

public class Db1Config {

@Bean(initMethod = "init", destroyMethod = "close")

@ConfigurationProperties(prefix = "dbdb1")

public DataSource dataSource1() {

return new DruidDataSource();

}

@Bean

public DataSourceTransactionManager transactionManager1() {

DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();

transactionManagersetDataSource(dataSource1());

return transactionManager;

}

}

applicationconf中的配置：

# DB1

dbdb1url=jdbc:mysql://127001:3306/db1useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true

dbdb1username=root

dbdb1password=

ORM框架jOOQ

jOOQ是一个开源ORM框架，最大特点是提供类型安全的流式API，支持代码生成。

参照Boot自带的JooqAutoConfiguration，不难写出如下配置类：

@Configuration

public class JooqConfig {

// DB1

@Bean

public DataSourceConnectionProvider dataSourceConnectionProvider1(

@Qualifier("dataSource1") DataSource dataSource1) {

return new DataSourceConnectionProvider(

new TransactionAwareDataSourceProxy(dataSource1));

}

@Bean

public SpringTransactionProvider transactionProvider1(

@Qualifier("transactionManager1") DataSourceTransactionManager txManager1) {

return new SpringTransactionProvider(txManager1);

}

// DB2

//

@Configuration

public static class DslContextConfig {

@Autowired(required = false)

private RecordMapperProvider recordMapperProvider;

@Autowired(required = false)

private Settings settings;

@Autowired(required = false)

private RecordListenerProvider[] recordListenerProviders;

@Autowired

private ExecuteListenerProvider[] executeListenerProviders;

@Autowired(required = false)

private VisitListenerProvider[] visitListenerProviders;

// DSLContext for DB1

@Bean

public DefaultDSLContext dslContext1(@Qualifier("dataSourceConnectionProvider1") DataSourceConnectionProvider connectionProvider1,

@Qualifier("transactionProvider1") SpringTransactionProvider transactionProvider1) {

return new DefaultDSLContext(configuration(connectionProvider1, transactionProvider1));

}

// DSLContext for DB2

//

private DefaultConfiguration configuration(ConnectionProvider connectionProvider, TransactionProvider transactionProvider) {

DefaultConfiguration configuration = new DefaultConfiguration();

configurationsetSQLDialect(SQLDialectMYSQL);

configurationset(connectionProvider);

configurationset(transactionProvider);

if (thisrecordMapperProvider != null) {

configurationset(thisrecordMapperProvider);

}

if (thissettings != null) {

configurationset(thissettings);

}

configurationset(thisrecordListenerProviders);

configurationset(thisexecuteListenerProviders);

configurationset(thisvisitListenerProviders);

return configuration;

}

}

}

服务类

配置好DataSource，TransacationManager和DSLContext之后，服务类的配置就比较简单了，直接引用即可。注意由于存在多套Beans，需要通过@Qualifier注解指定装配实例。

@Transactional("TransactionManager1")//每个事务指定 tx

public class ServiceA {

@Autowired

@Qualifier("dslContext1")

protected DSLContext dsl;

}

数据库迁移框架Flyway

Flyway是一个轻量级的开源数据库迁移框架，使用非常广泛。

参照Boot自带的FlywayAutoConfiguration，同样可以写出如下配置类：

@Configuration

public class FlywayConfig {

@Bean(initMethod = "migrate")

@ConfigurationProperties(prefix = "fwdb1")

public Flyway flyway(@Qualifier("dataSource1") DataSource dataSource1) {

Flyway clinic = new Flyway();

clinicsetDataSource(dataSource1);

return clinic;

}

// DB2

//

/

@see FlywayAutoConfiguration

/

@Bean

@ConfigurationPropertiesBinding

public StringOrNumberToMigrationVersionConverter stringOrNumberMigrationVersionConverter() {

return new StringOrNumberToMigrationVersionConverter();

}

/

Convert a String or Number to a {@link MigrationVersion}

@see FlywayAutoConfiguration

/

private static class StringOrNumberToMigrationVersionConverter

implements GenericConverter {

private static final Set<ConvertiblePair> CONVERTIBLE_TYPES;

static {

Set<ConvertiblePair> types = new HashSet<ConvertiblePair>(2);

typesadd(new ConvertiblePair(Stringclass, MigrationVersionclass));

typesadd(new ConvertiblePair(Numberclass, MigrationVersionclass));

CONVERTIBLE_TYPES = CollectionsunmodifiableSet(types);

}

@Override

public Set<ConvertiblePair> getConvertibleTypes() {

return CONVERTIBLE_TYPES;

}

@Override

public Object convert(Object source, TypeDescriptor sourceType,

TypeDescriptor targetType) {

String value = ObjectUtilsnullSafeToString(source);

return MigrationVersionfromVersion(value);

}

}

}

applicationconf中的配置：

# DB1

fwdb1enabled=true

在DAO的实现类层你可以看到你implements的方法的名称，这个名称就是你配置数据源名称的地方，通过数据源名称查询你的WEB-INF/项目名称/config/Contextxml文件里配置的数据源信息。再通过WebLogic控制台找到你配置信息的具体数据源及各种信息。

一个项目中使用多个数据源的需求，我们在日常工作中时常会遇到。

以商城系统为例，有一个 MySQL 的数据库负责存储交易数据。公司还有一套 ERP 企业信息化管理系统，要求订单信息同步录入 ERP 数据库，便于公司统一管理，而该 ERP 系统采用的数据库为 SQL Server 。

此时，就可以在 Spring Boot 项目中配置多个数据源。另外，使用多数据源后，需要采用分布式事务来保持数据的完整性。

本小节我们使用 Spring Boot 开发一个商城系统的订单生成功能，订单信息同时进入 MySQL 与 SQL Server 数据库。

首先创建 MySQL 数据库 shop ，并新建订单表 order ，表结构如下：

order 表结构

然后创建 SQL Server 数据库 erpshop ，并新建订单表 erp_order ，表结构如下。注意 id 是自增长的唯一标识，out_id 是对应订单在 MySQL 数据库中的唯一标识，以便在两个库中比对订单。

erp_order 结构

接下来，我们开始实现 Spring Boot 后端项目，数据持久层采用 MyBatis 框架，同时访问两个数据源。

Spring Boot 版本选择 225 ，Group 为 comimooc ， Artifact 为 spring-boot-multidb，生成项目后导入 Eclipse 开发环境。

我们引入热部署依赖、 Web 依赖、数据库访问相关依赖及测试相关依赖，具体如下：

实例：

由于我们要同时访问两个数据库，所以需要在配置文件中添加两个数据源的配置信息。注意配置多数据源时， url 配置需要使用 springdatasourcedb1jdbc-url=xxx 的形式。

实例：

多个数据源的情况下， 我们需要通过配置类，将数据源注册为组件放入 Spring 容器中。

实例：

通过这个配置类， Spring 容器中就有两个数据源组件，这两个组件分别采用 springdatasourcedb1 和 springdatasourcedb2 开头的配置信息。所以通过这两个组件，就能分别 *** 作 MySQL 数据源 1 和 SQL Sever 数据源 2 。

多数据源情况下， MyBatis 中的关键组件 SqlSessionFactory 和 SqlSessionTemplate 也需要单独配置，我们需要为两个数据源分别配置一套组件。

实例：

通过上面的配置类， comimoocspringbootmultidbmapper1 包中的 DAO 数据访问接口会自动调用 sqlSessionTemplate1 组件实现具体数据库 *** 作，而 sqlSessionTemplate1 *** 作的数据源已经通过配置类设置为 db1 。同时， DAO 数据访问接口对应的映射文件已经指定到 classpath:mapper1/ 目录去寻找。这样数据源 – DAO 数据访问接口 – 映射文件三者的对应关系就建立起来了。

数据源 2 的配置方法是一样的， comimoocspringbootmultidbmapper2 包中的 DAO 数据访问接口会自动调用 sqlSessionTemplate2 组件，其 *** 作的数据源即为 db2 ，其对应的映射文件指定到 classpath:mapper2/ 目录去寻找。

实例：

数据访问接口的位置已经在配置类指定，首先在 comimoocspringbootmultidbmapper1 创建 OrderDao ， *** 作的是数据源 1 中的 order 表。

实例：

然后在 comimoocspringbootmultidbmapper2 创建 ErpOrderDao ， *** 作的是数据源 2 中的 erporder 表。

实例：

这两个接口中使用的数据对象比较简单，代码如下：

实例：

分别针对 OrderDao 、 ErpOrderDao 编写对应的映射文件，然后按照配置类指定的位置，两个文件分别放到 resources/mapper1 和 resources/mapper2 目录下。

实例：

实例：

数据 *** 作接口与对应的映射文件均已编写完毕，现在可以通过测试类进行多数据源测试了，我们在测试类中同时向两个库插入记录。

实例：

运行测试方法后，两个数据库表中均新增数据成功，这样我们就成功的使用 Spring Boot 同时 *** 作了两个数据源。

采用多数据源之后，事务的实现方式也随之发生变化。当某个数据源 *** 作出现异常时，该数据源和其他数据源的事务都需要回滚。这种涉及多个数据源的事务，称为分布式事务，接来下我们就来具体实现一下。

在 pomxml 引入 Atomikos 事务管理器相关的依赖项， Atomikos 是一个开源的事务管理器，支持分布式事务。

实例：

需要将默认的数据源更换为支持分布式事务的数据源， MySQL 对应的数据源为 MysqlXADataSource ， SQL Server 对应的数据源为 SQLServerXADataSource 。

实例：

继续修改 DataSourceConfig 类，在其中配置分布式事务管理器组件。当项目中使用事务时，会通过配置的分布式事务管理器管理分布式事务 *** 作。

实例：

在测试方法上添加 @Transactional 开启事务，然后在两个数据源 *** 作中间模拟抛出异常。

实例：

此时运行测试类，可以发现数据源 1 的事务已回滚，验证成功！

在开发 Spring Boot 项目时，如果默认配置满足不了我们的需求，可以通过手工配置组件实现我们需要的功能。这些组件可能是各个公司提供的，我们根据相应文档，为其配置各个属性即可。

a直接配置2套数据源就像下面最EASY

@Configuration

public class SpringConfig {

@Bean

public DataSource dataSource(){

return new XXDataSource();

}

@Bean

public Counter dataSource2(){

return new XXDataSource();

}

}

b复合数据源只读分离库实现 complexds

<bean id="dataSource" class="comalibabadruidpoolDruidDataSource" init-method="init" destroy-method="close"

p:url="${jdbcurl}"

p:username="${jdbcusername}"

p:password="${jdbcpassword}"

p:initialSize="${druidinitialSize}"

p:minIdle="${druidminIdle}"

p:maxActive="${druidmaxActive}"

p:maxWait="${druidmaxWait}"

p:timeBetweenEvictionRunsMillis="${druidtimeBetweenEvictionRunsMillis}"

p:minEvictableIdleTimeMillis="${druidminEvictableIdleTimeMillis}"

p:validationQuery="${druidvalidationQuery}"

p:poolPreparedStatements="${druidpoolPreparedStatements}"

p:maxPoolPreparedStatementPerConnectionSize="${druidmaxPoolPreparedStatementPerConnectionSize}"/>

<bean id="slaveDataSource" class="comalibabadruidpoolDruidDataSource" init-method="init" destroy-method="close"

p:url="${slavejdbcurl}"

p:username="${slavejdbcusername}"

p:password="${slavejdbcpassword}"

p:initialSize="${slavedruidinitialSize}"

p:minIdle="${slavedruidminIdle}"

p:maxActive="${slavedruidmaxActive}"

p:maxWait="${slavedruidmaxWait}"

p:timeBetweenEvictionRunsMillis="${slavedruidtimeBetweenEvictionRunsMillis}"

p:minEvictableIdleTimeMillis="${slavedruidminEvictableIdleTimeMillis}"

p:validationQuery="${slavedruidvalidationQuery}"

p:poolPreparedStatements="${slavedruidpoolPreparedStatements}"

p:maxPoolPreparedStatementPerConnectionSize="${slavedruidmaxPoolPreparedStatementPerConnectionSize}"/>

<bean id="complexDataSource" class="comweghstpinecomplexdsComplexDataSource">

<constructor-arg index="0" ref="dataSource"/>

<constructor-arg index="1">

<map>

<entry key="#{T(comweghstpinecomplexdsNamedDS)DEFAULT_SLAVE_NAME}" value-ref="slaveDataSource"/>

</map>

</constructor-arg>

</bean>

<bean id="transactionManager" class="orgspringframeworkjdbcdatasourceDataSourceTransactionManager"

p:dataSource-ref="complexDataSource"/>

<tx:annotation-driven transaction-manager="transactionManager"/>

<!--

MyBatis 配置

-->

<bean id="sqlSessionFactory" class="orgmybatisspringSqlSessionFactoryBean">

<property name="dataSource" ref="complexDataSource"/>

<property name="configurationProperties">

<props>

<prop key="defaultScriptingLanguage">orgmybatisscriptingfreemarkerFreeMarkerLanguageDriver</prop>

</props>

</property>

<property name="mapperLocations" value="classpath:com/weghst/pine/repository/Mapperxml"/>

</bean>

<bean id="sqlSessionTemplate" class="comweghstpineutilFastSqlSessionTemplate"

c:sqlSessionFactory-ref="sqlSessionFactory"/>

<bean id="mapperScannerConfigurer" class="orgmybatisspringmapperMapperScannerConfigurer">

<property name="basePackage" value="comweghstpinerepository"/>

<property name="annotationClass" value="orgspringframeworkstereotypeRepository"/>

<property name="sqlSessionTemplateBeanName" value="sqlSessionTemplate"/>

</bean>

<bean id="complexDataSourceInterceptor" class="comweghstpinecomplexdsComplexDataSourceInterceptor"/>

<aop:config>

<aop:aspect ref="complexDataSourceInterceptor">

<aop:around method="invoke" pointcut="execution( comweghstpinerepository())"/>

</aop:aspect>

</aop:config>

以上就是关于springboot 中druid怎么连接多个数据库全部的内容，包括:springboot 中druid怎么连接多个数据库、SpringBoot+Mybatis 通过databaseIdProvider支持多数据库、SpringBoot整合MybatisPius实现数据库多数据源及读写分离等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！