#默认使用 tomcat-jdbc spring.datasource.type=org.apache.tomcat.jdbc.pool.datasource spring.datasource.data1.url=jdbc:mysql://127.0.0.1:3306/mysql-boot spring.datasource.data1.username=root spring.datasource.data1.password=123123 spring.datasource.data1.driver-class-name=com.mysql.jdbc.driver spring.datasource.data2.url=jdbc:mysql://127.0.0.1:3306/mysql-confswh spring.datasource.data2.username=root spring.datasource.data2.password=123123 spring.datasource.data2.driver-class-name=com.mysql.jdbc.driver
datasource1
package com.springboot.datasource; 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.autoconfigure.jdbc.datasourcebuilder; import org.springframework.boot.context.properties.configurationproperties; import org.springframework.context.annotation.bean; import org.springframework.context.annotation.configuration; import org.springframework.context.annotation.primary; import org.springframework.jdbc.datasource.datasourcetransactionmanager; import javax.sql.datasource; @configuration//注解到spring容器中 @mapperscan(basepackages = "com.springboot.data1.mapper",sqlsessionfactoryref = "data1sqlsessionfactory") public class datasource1 { /** * 返回data1数据库的数据源 * @return */ @bean(name="data1source") @primary//主数据源 @configurationproperties(prefix = "spring.datasource.data1") public datasource datasource(){ return datasourcebuilder.create().build(); } /** * 返回data1数据库的会话工厂 * @param ds * @return * @throws exception */ @bean(name = "data1sqlsessionfactory") @primary public sqlsessionfactory sqlsessionfactory(@qualifier("data1source") datasource ds) throws exception{ sqlsessionfactorybean bean = new sqlsessionfactorybean(); bean.setdatasource(ds); return bean.getobject(); } /** * 返回data1数据库的会话模板 * @param sessionfactory * @return * @throws exception */ @bean(name = "data1sqlsessiontemplate") @primary public sqlsessiontemplate sqlsessiontemplate(@qualifier("data1sqlsessionfactory") sqlsessionfactory sessionfactory) throws exception{ return new sqlsessiontemplate(sessionfactory); } /** * 返回data1数据库的事务 * @param ds * @return */ @bean(name = "data1transactionmanager") @primary public datasourcetransactionmanager transactionmanager(@qualifier("data1source") datasource ds){ return new datasourcetransactionmanager(ds); } }
datasource2:
package com.springboot.datasource; 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.autoconfigure.jdbc.datasourcebuilder; import org.springframework.boot.context.properties.configurationproperties; import org.springframework.context.annotation.bean; import org.springframework.context.annotation.configuration; import org.springframework.jdbc.datasource.datasourcetransactionmanager; import javax.sql.datasource; @configuration//注解到spring容器中 @mapperscan(basepackages = "com.springboot.data2.mapper",sqlsessionfactoryref = "data2sqlsessionfactory") public class datasource2 { /** * 返回data2数据库的数据源 * @return */ @bean(name="data2source") @configurationproperties(prefix = "spring.datasource.data2") public datasource datasource(){ return datasourcebuilder.create().build(); } /** * 返回data2数据库的会话工厂 * @param ds * @return * @throws exception */ @bean(name = "data2sqlsessionfactory") public sqlsessionfactory sqlsessionfactory(@qualifier("data2source") datasource ds) throws exception{ sqlsessionfactorybean bean = new sqlsessionfactorybean(); bean.setdatasource(ds); return bean.getobject(); } /** * 返回data2数据库的会话模板 * @param sessionfactory * @return * @throws exception */ @bean(name = "data2sqlsessiontemplate") public sqlsessiontemplate sqlsessiontemplate(@qualifier("data2sqlsessionfactory") sqlsessionfactory sessionfactory) throws exception{ return new sqlsessiontemplate(sessionfactory); } /** * 返回data2数据库的事务 * @param ds * @return */ @bean(name = "data2transactionmanager") public datasourcetransactionmanager transactionmanager(@qualifier("data2source") datasource ds){ return new datasourcetransactionmanager(ds); } }
3、测试 service&mapper
@requestmapping("gettopiclist") public list<map<string,object>> gettopiclist(){ list<map<string,object>> list1 = userservicedata1.gettopiclistdata1(); list<map<string,object>> list2 = userservicedata2.gettopiclistdata2(); return list1; }
附:
如对本文有疑问, 点击进行留言回复!!
(已解决)宝塔面板SSL失败|无法启动,提示 nginx: configuration file /www/server/nginx/conf/nginx.conf test failed
JAVAWEB第六天——JQuery速成(2)【表单校验优化,美观可视化升级,Validation插件,省市二级联动升级】
Flutter Navigator路由,返回,替换路由及返回指定页面
springboot插入时间出现 at [Source: (PushbackInputStream); line: 9, column: 12]的问题。
使用Spring Cloud Bus自动动态刷新配置文件的流程总结
网友评论