手搭手Mybatis-Plus多数据源异构数据迁移案例

环境介绍

技术栈

springboot+mybatis-plus+druid+baomidou+mysql+oracle+dm

软件

版本

mysql

8

IDEA

IntelliJ IDEA 2022.2.1

JDK

1.8

Spring Boot

2.7.13

mybatis

2.3.1

pom.xml所需依赖

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.3.2</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>3.5.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.14</version></dependency><dependency><groupId>com.mysql</groupId><artifactId>mysql-connector-j</artifactId><scope>runtime</scope></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.2.15</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>com.dameng</groupId><artifactId>Dm8JdbcDriver18</artifactId><version>8.1.1.49</version></dependency><dependency><groupId>com.oracle.database.jdbc</groupId><artifactId>ojdbc8</artifactId><scope>runtime</scope></dependency>
</dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><excludes><exclude><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></exclude></excludes></configuration></plugin></plugins>
</build>

MybatisX逆向工程

逆向工程：通过数据库表接口，逆向生成java工程结构

实体类、mapper接口、mapper映射文件、Service接口、service实现类

application.yml

spring:datasource:dynamic:primary:  #设置默认的数据源或者数据源组,默认值即为masterstrict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源datasource:mysql1:username: rootpassword: PWDurl: jdbc:mysql://IP:3306/mysql?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8driver-class-name: com.mysql.cj.jdbc.Driver#          driver-class-name: com.mysql.jdbc.Drivermysql2:url: jdbc:mysql://IP:3306/sys?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8username: rootpassword: PWDdriver-class-name: com.mysql.cj.jdbc.Driveroracle:username: systempassword: PWDurl: jdbc:oracle:thin:@IP:1521:orcldriver-class-name: oracle.jdbc.driver.OracleDriver#          driver-class-name: com.mysql.jdbc.Driverdm:url: jdbc:dm://127.0.0.1:5236/demo?username: SYSDBApassword: SYSDBAdriver-class-name: dm.jdbc.driver.DmDriver#          driver-class-name: com.mysql.jdbc.Driverserver:port: 8089mybatis-plus:configuration:#输出日志log-impl: org.apache.ibatis.logging.stdout.StdOutImpl#配置映射规则map-underscore-to-camel-case: true #表示支持下划线到驼蜂的映射#隐藏mybatis图标global-config:banner: falsedb-config:logic-delete-field: statuslogic-not-delete-value: 1logic-delete-value: 0

spy.properties

#3.2.1以上使用
modulelist=com.baomidou.mybatisplus.extension.p6spy.MybatisPlusLogFactory,com.p6spy.engine.outage.P6OutageFactory
#3.2.1以下使用或者不配置
#modulelist=com.p6spy.engine.logging.P6LogFactory,com.p6spy.engine.outage.P6OutageFactory
# 自定义日志打印
logMessageFormat=com.baomidou.mybatisplus.extension.p6spy.P6SpyLogger
#日志输出到控制台
appender=com.baomidou.mybatisplus.extension.p6spy.StdoutLogger
# 使用日志系统记录 sql
#appender=com.p6spy.engine.spy.appender.Slf4JLogger
# 设置 p6spy driver 代理
deregisterdrivers=true
# 取消JDBC URL前缀
useprefix=true
# 配置记录 Log 例外,可去掉的结果集有error,info,batch,debug,statement,commit,rollback,result,resultset.
excludecategories=info,debug,result,commit,resultset
# 日期格式
dateformat=yyyy-MM-dd HH:mm:ss
# 实际驱动可多个
#driverlist=org.h2.Driver
# 是否开启慢SQL记录
outagedetection=true
# 慢SQL记录标准 2 秒
outagedetectioninterval=2

MybatisX逆向工程只是一个便携的工具，自定义接口和实现类还是要自己写

mapper(dao层)

@Mapper
public interface UserMapper extends BaseMapper<User> {
}

@Mapper
public interface TUserMapper extends BaseMapper<TUser> {
}

@Mapper
public interface TestMapper extends BaseMapper<Test> {List<Test> selectTestAll();
}

@Mapper
public interface DmuserMapper extends BaseMapper<Dmuser> {List<Dmuser> selectDmUserAll();Integer addDmUser(Dmuser dmuser);
}

service接口层

public interface UserService extends IService<User> {
}
public interface TUserService extends IService<TUser> {
}
public interface TestService extends IService<Test> {List<Test> selectTestAll();
}
public interface DmuserService extends IService<Dmuser> {List<Dmuser> selectDmUserAll();Integer addDmUser(Dmuser dmuser);
}

mapper映射文件

<mapper namespace="com.example.mapper.UserMapper"><resultMap id="BaseResultMap" type="com.example.domain.User"><id property="id" column="id" jdbcType="VARCHAR"/><result property="name" column="name" jdbcType="VARCHAR"/><result property="age" column="age" jdbcType="INTEGER"/><result property="email" column="email" jdbcType="VARCHAR"/><result property="status" column="status" jdbcType="INTEGER"/><result property="gender" column="gender" jdbcType="INTEGER"/><result property="contact" column="contact" jdbcType="VARCHAR"/><result property="createTime" column="create_time" jdbcType="TIMESTAMP"/><result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/></resultMap><sql id="Base_Column_List">id,name,age,email,status,gender,contact,create_time,update_time</sql>
</mapper>

<mapper namespace="com.example.mapper.TUserMapper"><resultMap id="BaseResultMap" type="com.example.domain.TUser"><id property="id" column="id" jdbcType="BIGINT"/><result property="name" column="name" jdbcType="VARCHAR"/><result property="age" column="age" jdbcType="INTEGER"/><result property="email" column="email" jdbcType="VARCHAR"/></resultMap><sql id="Base_Column_List">id,name,age,email</sql>
</mapper>

<mapper namespace="com.example.mapper.TestMapper"><resultMap id="BaseResultMap" type="com.example.domain.Test"><id property="id" column="id" jdbcType="DECIMAL"/><result property="name" column="name" jdbcType="VARCHAR"/></resultMap><sql id="Base_Column_List">id,name</sql><select id="selectTestAll" resultType="com.example.domain.Test">select * from "test"</select>
</mapper>

<mapper namespace="com.example.mapper.DmuserMapper"><resultMap id="BaseResultMap" type="com.example.domain.Dmuser"><id property="id" column="id" jdbcType="INTEGER"/><result property="name" column="name" jdbcType="CHAR"/><result property="address" column="address" jdbcType="CHAR"/></resultMap><sql id="Base_Column_List">id,name,address</sql><select id="selectDmUserAll" resultType="com.example.domain.Dmuser">select "id","name","address"from "SYSDBA"."DMUser";</select><insert id="addDmUser">insert into "SYSDBA"."DMUser"("id", "name", "address") VALUES(#{id},#{name},#{address});</insert>
</mapper>

serviceimpl类

@Service
@DS("mysql2")
public class UserServiceImpl extends ServiceImpl<UserMapper, User>implements UserService{
}
@Service
@DS("mysql1")
public class TUserServiceImpl extends ServiceImpl<TUserMapper, TUser>implements TUserService{
}

@Service
@DS("oracle")
public class TestServiceImpl extends ServiceImpl<TestMapper, Test>implements TestService{@Autowiredprivate TestMapper testMapper;@Overridepublic List<Test> selectTestAll() {return testMapper.selectTestAll();}
}

@Service
@DS("dm")
public class DmuserServiceImpl extends ServiceImpl<DmuserMapper, Dmuser>implements DmuserService{@Autowiredprivate DmuserMapper dmuserMapper;@Overridepublic List<Dmuser> selectDmUserAll() {return dmuserMapper.selectDmUserAll();}@Overridepublic Integer addDmUser(Dmuser dmuser) {return dmuserMapper.addDmUser(dmuser);}
}

测试类

@SpringBootTest
class DatasourcesApplicationTests {@Autowiredprivate TUserService tUserService;@Autowiredprivate UserService userService;@Autowiredprivate TestService testService;@Autowiredprivate DmuserService dmuserService;@Testvoid sys(){userService.list();}@Testvoid oracleDemo(){testService.selectTestAll();}@Testvoid dmDemo(){dmuserService.selectDmUserAll();}@Testvoid oracleToDMTest(){List<com.example.domain.Test> oracles =testService.selectTestAll();for (com.example.domain.Test oracle : oracles) {Dmuser dmuser =new Dmuser();dmuser.setId(Math.toIntExact(oracle.getId()));dmuser.setName(oracle.getName());dmuser.setAddress("null");dmuserService.addDmUser(dmuser);System.out.println(""+oracle);}}@Testvoid mysqlToDMTest(){List<TUser> mysqls =tUserService.list();for (TUser mysql : mysqls) {Dmuser dmuser =new Dmuser();dmuser.setId(Math.toIntExact(mysql.getId()));dmuser.setName(mysql.getName());dmuser.setAddress(mysql.getEmail());dmuserService.addDmUser(dmuser);System.out.println(""+mysql);}}}

Mybatis-Plus介绍

https://baomidou.com/

为简化开发而生

MyBatis-Plus(opens new window)（简称 MP）是一个 MyBatis (opens new window) 的增强工具，在 MyBatis 的基础上只做增强不做改变，为简化开发、提高效率而生。

特性

  • 无侵入：只做增强不做改变，引入它不会对现有工程产生影响，如丝般顺滑
  • 损耗小：启动即会自动注入基本 CURD，性能基本无损耗，直接面向对象操作
  • 强大的 CRUD 操作：内置通用 Mapper、通用 Service，仅仅通过少量配置即可实现单表大部分 CRUD 操作，更有强大的条件构造器，满足各类使用需求
  • 支持 Lambda 形式调用：通过 Lambda 表达式，方便的编写各类查询条件，无需再担心字段写错
  • 支持主键自动生成：支持多达 4 种主键策略（内含分布式唯一 ID 生成器 - Sequence），可自由配置，完美解决主键问题
  • 支持 ActiveRecord 模式：支持 ActiveRecord 形式调用，实体类只需继承 Model 类即可进行强大的 CRUD 操作
  • 支持自定义全局通用操作：支持全局通用方法注入（ Write once, use anywhere ）
  • 内置代码生成器：采用代码或者 Maven 插件可快速生成 Mapper 、 Model 、 Service 、 Controller 层代码，支持模板引擎，更有超多自定义配置等您来使用
  • 内置分页插件：基于 MyBatis 物理分页，开发者无需关心具体操作，配置好插件之后，写分页等同于普通 List 查询
  • 分页插件支持多种数据库：支持 MySQL、MariaDB、Oracle、DB2、H2、HSQL、SQLite、Postgre、SQLServer 等多种数据库
  • 内置性能分析插件：可输出 SQL 语句以及其执行时间，建议开发测试时启用该功能，能快速揪出慢查询
  • 内置全局拦截插件：提供全表 delete 、 update 操作智能分析阻断，也可自定义拦截规则，预防误操作

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/125321.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

6轮面试阿里Android开发offer，薪资却从21k降到17k，在逗我？

6轮面试阿里Android开发offer，薪资却从21k降到17k，在逗我？

一小伙工作快3年了&#xff0c;拿到了阿里云Android开发岗位P6的offer&#xff0c;算HR面一起&#xff0c;加起来有6轮面试了&#xff0c;将近3个月的时间&#xff0c;1轮同级 1轮Android用人部门leader 1轮Android 组leader 1轮项目CTO 1轮HR 1轮HRBP。 一路上各种事件分…
阅读更多...
Vue中如何进行响应式图像与图片懒加载优化

Vue中如何进行响应式图像与图片懒加载优化

Vue中响应式图像与图片懒加载优化 在现代的Web开发中&#xff0c;图像在网站性能和用户体验方面扮演着至关重要的角色。然而&#xff0c;加载大量的图像可能会导致网页加载速度变慢&#xff0c;从而影响用户的满意度。为了解决这个问题&#xff0c;Vue.js提供了一些强大的工具…
阅读更多...
联想M7216NWA一体机连接WiFi及手机添加打印机方法

联想M7216NWA一体机连接WiFi及手机添加打印机方法

联想M7216NWA一体机连接WiFi方法&#xff1a; 1、首先按打印机操作面板上的“功能键”&#xff1b;【用“”&#xff08;上翻页&#xff09;“-”&#xff08;下翻页&#xff09;来选择菜单的内容】 2、下翻页键找到并选择“网络”&#xff0c;然后“确认键”&#xff1b; 3…
阅读更多...
【图像处理】使用各向异性滤波器和分割图像处理从MRI图像检测脑肿瘤（Matlab代码实现）

【图像处理】使用各向异性滤波器和分割图像处理从MRI图像检测脑肿瘤（Matlab代码实现）

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…
阅读更多...
讲讲项目里的仪表盘编辑器（二）

讲讲项目里的仪表盘编辑器（二）

应用场景 正常来说&#xff0c;编辑器应用场景应该包括&#xff1a; 编辑器-预览 编辑器 最终运行时 怎么去设计 上一篇推文&#xff0c;我们已经大概了解了编辑器场景。接下来&#xff0c;我们来看预览时的设计 编辑器-预览 点击预览按钮&#xff0c;执行以…
阅读更多...
番外--Task2:

番外--Task2:

任务&#xff1a;root与普通用户的互切&#xff08;区别&#xff09;&#xff0c;启动的多用户文本见面与图形界面的互切命令&#xff08;区别&#xff09;。 输入图示命令&#xff0c;重启后就由图形界面转成文本登录界面&#xff1b; 输入图示命令&#xff0c;重启后就由文本…
阅读更多...
图像分割中的色块的提取

图像分割中的色块的提取

一 色块提取方法&#xff1a; ①首先是色彩模型的转换 由RGB颜色空间转到HSV颜色空间 原因&#xff1a;RGB颜色空间适合显示系统&#xff0c;但是各分量间相关性很强&#xff0c;比如当图像亮度发生变化时&#xff0c;RGB三个分量都会发生相应改变 但是HSV颜色空间更能感知颜色…
阅读更多...
LeetCode 240. 搜索二维矩阵 II

LeetCode 240. 搜索二维矩阵 II

原题链接&#xff1a; 力扣&#xff08;LeetCode&#xff09;官网 - 全球极客挚爱的技术成长平台 题面&#xff1a; 编写一个高效的算法来搜索 m x n 矩阵 matrix 中的一个目标值 target 。该矩阵具有以下特性&#xff1a; 每行的元素从左到右升序排列。每列的元素从上到下升序…
阅读更多...
输入电压转化为电流性 5~20mA方案

输入电压转化为电流性 5~20mA方案

输入电压转化为电流性 5~20mA方案 方案一方案二方案三 方案一 XTR111是一款精密的电压-电流转换器是最广泛应用之一。原因有二&#xff1a;一是线性度非常好、二是价格便宜。总结成一点&#xff0c;就是性价比高。 典型电路 最终电路 Z1二极管处输出电流表达式&#xff1a;…
阅读更多...
QT商业播放器

QT商业播放器

QT商业播放器 总体架构图 架构优点&#xff1a;解耦&#xff0c;采用生产者消费者设计模式&#xff0c;各个线程各司其职&#xff0c;通过消息队列高效协作 这个项目是一个基于ijkplayer和ffplayer.c的QT商业播放器, 项目有5部分构成&#xff1a; 前端QT用户界面 后端是集成了…
阅读更多...
WEB3 创建React前端Dapp环境并整合solidity项目，融合项目结构便捷前端拿取合约 Abi

WEB3 创建React前端Dapp环境并整合solidity项目，融合项目结构便捷前端拿取合约 Abi

好 各位 经过我们上文 WEB3 solidity 带着大家编写测试代码 操作订单 创建/取消/填充操作 我们自己写了一个测试订单业务的脚本 没想到运行的还挺好的 那么 今天开始 我们就可以开始操作我们前端 Dapp 的一个操作了 在整个过程中 确实是没有我们后端的操作 或者说 我们自己就…
阅读更多...
C++设计模式-工厂模式（Factory Method）

C++设计模式-工厂模式（Factory Method）

目录 C设计模式-工厂模式&#xff08;Factory Method&#xff09; 一、意图 二、适用性 三、结构 四、参与者 五、代码 C设计模式-工厂模式&#xff08;Factory Method&#xff09; 一、意图 定义一个用于创建对象的接口&#xff0c;让子类决定实例化哪一个类。Factory…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023