前言
前几天有个需求，需要使用不同的 数据源 ，例如某业务要用a数据源，另一个业务要用b数据源。我上网收集了一些资料整合了一下，虽然最后这个需求不了了之了，但是多数据源动态切换还是蛮好用的，所以记录一下，或许以后有用呢？或者自己感兴趣又想玩呢！
下面话不多说了，随着小编来一起看看详细的介绍吧
方法如下：
1.加个依赖
|
1 2 3 4 5 |
<dependency> <groupid>org. mybatis .spring.boot</groupid> <artifactid>mybatis-spring-boot-starter</artifactid> <version> 1.3 . 1 </version> </dependency> |
2.application.properties配置文件
|
1 2 3 4 5 6 7 8 9 10 11 12 |
#主从数据库 master.db.driverclassname=com.mysql.jdbc.driver master.db.url=jdbc:mysql: //localhost:3306/cbd?characterencoding=utf-8&useunicode=true&usessl=false master.db.username=root master.db.password=admin slave.db.driverclassname=com.mysql.jdbc.driver slave.db.url=jdbc:mysql: //localhost:3306/cbd_test?characterencoding=utf-8&useunicode=true&usessl=false slave.db.username=root slave.db.password=admin
mybatis.config-location= classpath:config/mybatis-config.xml mybatis.mapper-locations=classpath:mapper /**/ *.xml |
3.禁用 springboot 默认加载数据源配置
|
1 2 3 4 5 6 7 |
@springbootapplication (exclude = {datasourceautoconfiguration. class }) public class application {
public static void main(string[] args) throws exception { springapplication.run(application. class , args); } } |
4.数据源配置类
|
1 2 3 4 5 6 7 8 9 10 11 |
/** * 主数据源 */ @configuration @configurationproperties (prefix = "master.db" ) public class masterdatasourceconfig { private string url; private string username; private string password; private string driverclassname; } |
|
1 2 3 4 5 6 7 8 9 10 11 |
/** * 从数据源配置 */ @configuration @configurationproperties (prefix = "slave.db" ) public class slavedatasourceconfig { private string url; private string username; private string password; private string driverclassname; } |
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
/** * 数据源配置类 */ @configuration public class datasourcecomponent {
@resource private masterdatasourceconfig masterdatasourceconfig;
@resource private slavedatasourceconfig slavedatasourceconfig;
@bean (name = "master" ) public datasource masterdatasource() { datasource datasource = new datasource(); datasource.seturl(masterdatasourceconfig.geturl()); datasource.setusername(masterdatasourceconfig.getusername()); datasource.setpassword(masterdatasourceconfig.getpassword()); datasource.setdriverclassname(masterdatasourceconfig.getdriverclassname()); return datasource; }
@bean (name = "slave" ) public datasource slavedatasource() { datasource datasource = new datasource(); datasource.seturl(slavedatasourceconfig.geturl()); datasource.setusername(slavedatasourceconfig.getusername()); datasource.setpassword(slavedatasourceconfig.getpassword()); datasource.setdriverclassname(slavedatasourceconfig.getdriverclassname()); return datasource; }
@primary //不加这个会报错。 @bean (name = "multidatasource" ) public multiroutedatasource exampleroutedatasource() { multiroutedatasource multidatasource = new multiroutedatasource(); map<object, object> targetdatasources = new hashmap<>(); targetdatasources.put( "master" , masterdatasource()); targetdatasources.put( "slave" , slavedatasource()); multidatasource.settargetdatasources(targetdatasources); multidatasource.setdefaulttargetdatasource(masterdatasource()); return multidatasource; } } |
5.数据源上下文
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
/** * 数据源上下文 */ public class datasourcecontext { private static final threadlocal<string> contextholder = new threadlocal<>();
public static void setdatasource(string value) { contextholder.set(value); }
public static string getdatasource() { return contextholder.get(); }
public static void cleardatasource() { contextholder.remove(); } } |
6.datasource路由类
|
1 2 3 4 5 6 7 8 9 10 11 12 |
/* * 重写的函数决定了最后选择的datasource */ public class multiroutedatasource extends abstractroutingdatasource {
@override protected object determinecurrentlookupkey() { //通过绑定线程的数据源上下文实现多数据源的动态切换,有兴趣的可以去查阅资料或源码 return datasourcecontext.getdatasource(); }
} |
7.使用，修改上下文中的数据源就可以切换自己想要使用的数据源了。
|
1 2 3 4 5 6 |
public uservo finduser(string username) { datasourcecontext.setdatasource( "slave" ); uservo uservo = usermapper.findbyvo(username); system.out.println(uservo.getname()+ "=====================" ); return null ; } |
这种是在业务中使用代码设置数据源的方式，也可以使用aop+注解的方式实现控制，方法多多！
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对的支持。
原文链接：http://HdhCmsTestcnblogs测试数据/tinyj/p/9864128.html
查看更多关于spring boot + mybatis实现动态切换数据源实例代码的详细内容...