springboot-配置多个数据源

1、创建一个datasource包，新建DataSource1，DataSource2两个文件，通过注解来配置数据源

DataSource1：

DataSource2：

2、在application.properties文件配置两个数据源

3、两个测试的Service&Mapper

4、Controller调用

这位朋友，根据您的问题解答如下，如有不明之处可以继续补充:

你在web.xml里这么配置没问题啊，我加载两个spring的配置文件都是用逗号分割的，这个逗号是半角的，不是全角的。一般都是配置多个，dao放一个，services放一个。

场景描述：有多个数据库，每个数据库可能分布在不同的mysql instance上面，有多个存储过程，每个存储过程可能分布在不同的数据库中，需要有两个配置文件。

1. mysql 数据库映射：

A.driverClassName=com.mysql.jdbc.Driver

A.url=jdbc:mysql://172.20.7.51:3308/blog

A.username=trappuser

A.password=Opera1!

B.driverClassName=com.mysql.jdbc.Driver

B.url=jdbc:mysql://localhost:3306/wedding

B.username=root

B.password=opera

上面定义的A、B为两个mysql instance的缩写。

2. 存储过程与mysql instance的映射关系：

SP_Get_User=A

GetStocks=B

定义两个模拟存储过程，第一个数据库“SP_Get_User“是在数据库A下面，第二个数据库”GetStocks“是在数据库B下面。

3. 建立自定义的sessionFactory

3.1 xml配置的datasource及sessionFactory如下：

<bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" id="dataSource">

<property name="driverClassName" value="${database.driverClassName}"/>

<property name="url" value="${database.url}"/>

<property name="username" value="${database.username}"/>

<property name="password" value="${database.password}"/>

</bean>

<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">

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

<property name="packagesToScan" value="com.xx.assetcommander">

</property>

<property name="hibernateProperties">

<props>

<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>

<prop key="hibernate.show_sql">true</prop>

</props>

</property>

</bean>

此处我们定义的sessionFactory的类型为LocalSessionFactoryBean，它是一个工厂对象，与我们再需要的 SessionFactory不是一回事，我们需要的sessionfactory是org.hibernate.SessionFactory，这个对象可以被第一个sessionFactory的getObject()方法生成。

3.2 由于我们连接的是多个mysql instance， 不方便在xml中配置多个datasource和多个sessionFactory，故可以通过纯java的形式开发，可以使用map来存储存储过程与mysql database的关系，将存储过程的名字和数据库建议关系，这样通过存储过程的名称就能得到数据库的缩写名，通过数据库的缩写名能够找到对应的mysql instance，使用纯java开发的过程类似于xml配置，如下：

ds.setDriverClassName(getDriver())

ds.setUrl(getUrl())

ds.setUsername(getUsername())

ds.setPassword(getPassword())

LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean()

sessionFactory.setDataSource(ds)

sessionFactory.setPackagesToScan("com.xx.assetcommander")

Properties params = new Properties()

params.setProperty("hibernate.dialect",

"org.hibernate.dialect.MySQLDialect")

params.setProperty("hibernate.show_sql", "true")

sessionFactory.setHibernateProperties(params)

当我们获得可以使用的LocalSessionFactoryBean时候，在调用getObject()获得SessionFactory之前，必须要调用afterPropertiesSet()方法，否则得到的sessionFactory为空。

public Session getDsBySp(String spName) throws IOException {

//get the corresponding mysql database shortname by sp name

String dbName = getDbForSP(str)

//get the corresponding mysql instance connection by mysql database shortname

LocalSessionFactoryBean fB = getDsByDb(dbName)

// don't forget this line or null will be returned when you call getObject() method.

fB.afterPropertiesSet()

return fB.getObject().openSession()

}

注：在tomcat启动时，如果没有配置任何datasource，会出现如下错误：

org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type [javax.persistence.EntityManagerFactory] is defined

故需要配置默认的datasource.

这种方式需要做到不同的数据库instance直接业务的完全独立，不可以出现跨数据库的表join，否则处理难度会增加。

还有就是对于多数据库直接的事务管理如何去处理？

---