本文共 3130 字,大约阅读时间需要 10 分钟。
dynamic-datasource-spring-boot-starter 是一个基于springboot的快速集成多数据源的启动器。
其支持 Jdk 1.7+, SpringBoot 1.4.x 1.5.x 2.x.x。
步骤1、引入依赖(myabits plus依赖 、jdbc 或者mysql connector 依赖等另行按需引入)
com.baomidou dynamic-datasource-spring-boot-starter 2.5.4
步骤2:配置数据源
spring: application: name: data-provider jackson: date-format: yyyy-MM-dd HH:mm:ss time-zone: GMT+8 servlet: multipart: maxFileSize: 5MB #单位必须大写MB或不写(即为B) maxRequestSize: 10MB datasource: dynamic: primary: erp #设置默认的数据源或者数据源组,默认值即为master strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源. p6spy: false datasource: erp: url: jdbc:sqlserver://XXX.XXX.XXX.XXX:XXX;DatabaseName=XXX username: XX password: XXX driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver initialSize: 5 minIdle: 5 maxActive: 20 ipos: url: jdbc:mysql://XXX.XXX.XXX.XXX:XXX/XXX?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8 username: XX password: XXX driver-class-name: com.mysql.jdbc.Driver initialSize: 5 minIdle: 5 maxActive: 20# mybatis-plusmybatis-plus: type-aliases-package: com.hieasy mapper-locations: classpath*:mappers/**/*Mapper.xml check-config-location: true configuration: #是否开启自动驼峰命名规则(camel case)映射 map-underscore-to-camel-case: true #全局地开启或关闭配置文件中的所有映射器已经配置的任何缓存 cache-enabled: false call-setters-on-nulls: true #配置JdbcTypeForNull, oracle数据库必须配置 jdbc-type-for-null: 'null' #MyBatis 自动映射时未知列或未知属性处理策略 NONE:不做任何处理 (默认值), WARNING:以日志的形式打印相关警告信息, FAILING:当作映射失败处理,并抛出异常和详细信息 auto-mapping-unknown-column-behavior: warning global-config: banner: false db-config: #主键类型 0:"数据库ID自增", 1:"未设置主键类型",2:"用户输入ID (该类型可以通过自己注册自动填充插件进行填充)", 3:"全局唯一ID (idWorker), 4:全局唯一ID (UUID), 5:字符串全局唯一ID (idWorker 的字符串表示)"; id-type: UUID #字段验证策略 IGNORED:"忽略判断", NOT_NULL:"非NULL判断", NOT_EMPTY:"非空判断", DEFAULT 默认的,一般只用于注解里(1. 在全局里代表 NOT_NULL,2. 在注解里代表 跟随全局) field-strategy: NOT_EMPTY #数据库大写下划线转换 capital-mode: true #逻辑删除值 logic-delete-value: 0 #逻辑未删除值 logic-not-delete-value: 1
步骤3:实现类方法上切换数据源
不是默认的数据源的打上注解@DS("")
@DS("ipos") @Override public IPageselectPage() { return qtlsdMapper.selectPage(new Page<>(1,10),new QueryWrapper<>()); }
默认的数据源的直接不用做注解
@Override public IPageselectPage() { return spkcbMapper.selectPage(new Page<>(1,10),new QueryWrapper<>()); }
经过3个步骤到这里动态的数据源就已经配置好了
下面来编写测试控制层
@GetMapping("test") @ApiOperation(value = "测试IPOSDB", notes = "") public R testIposDb() { IPageiPage=qtlsdService.selectPage(); return R.data(iPage); } @GetMapping("test2") @ApiOperation(value = "测试ERPDB", notes = "") public R testERPDB() { IPage iPage=spkcbService.selectPage(); return R.data(iPage); }
结果:
2个数据源均能够响应相应的数据。
至此告一段落。
转载地址:http://hjnab.baihongyu.com/