java操作多数据源将oracle数据同步达梦数据库

简介: java操作多数据源将oracle数据同步达梦数据库

业务场景说明:

老系统使用的是大名鼎鼎的 ORACLE数据库,新系统由于公司 要走 【国产化】使用 达梦数据库,(达梦数据库使用起来真垃圾,不是一般的垃圾)。由于老系统数据表结构 与 新系统不能完全趋向一致,所以考虑使用接口或者定时任务处理业务数据。使用多数据源处理

1.application-druid.yml 配置

1.1maven 依赖

    <!--oracle驱动-->
    <dependency>
        <groupId>com.oracle.database.jdbc</groupId>
        <artifactId>ojdbc6</artifactId>
        <version>11.2.0.4</version>
    </dependency>

数据源配置

spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource

    #driverClassName: dm.jdbc.driver.DmDriver
    druid:
        # 主库数据源
        master:
            url: jdbc:dm://127.0.0.1:5237/AAAA?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
            username: PSMS
            password: 123456789
        # 从库数据源
        slave:
            # 从数据源开关/默认关闭
            enabled: true
            url: jdbc:oracle:thin:@111.111.111.111:111/BBB
            username: ROOT
            password: 123456
            driverClassName: oracle.jdbc.driver.OracleDriver

        # 初始连接数
        initialSize: 5
        # 最小连接池数量
        minIdle: 10
        # 最大连接池数量
        maxActive: 20
        # 配置获取连接等待超时的时间
        maxWait: 60000
        # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
        timeBetweenEvictionRunsMillis: 60000
        # 配置一个连接在池中最小生存的时间,单位是毫秒
        minEvictableIdleTimeMillis: 300000
        # 配置一个连接在池中最大生存的时间,单位是毫秒
        maxEvictableIdleTimeMillis: 900000
        # 配置检测连接是否有效
        validationQuery: SELECT 1 FROM DUAL
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        webStatFilter:
            enabled: true
        statViewServlet:
            enabled: true
            # 设置白名单,不填则允许所有访问
            allow:
            url-pattern: /druid/*
            # 控制台管理用户名和密码
            login-username:
            login-password:
        filter:
            stat:
                enabled: true
                # 慢SQL记录
                log-slow-sql: true
                slow-sql-millis: 1000
                merge-sql: true
            wall:
                config:
                    multi-statement-allow: true

2.DataSource注解

package com.aaaa.common.annotation;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Inherited;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import com.ruoyi.common.enums.DataSourceType;

/**

  • 自定义多数据源切换注解
    *
  • 优先级:先方法,后类,如果方法覆盖了类上的数据源类型,以方法的为准,否则以类上的为准
    *
  • @author wangwei
    /
    @Target({ ElementType.METHOD, ElementType.TYPE })
    @Retention(RetentionPolicy.RUNTIME)
    @Documented
    @Inherited
    public @interface DataSource
    {
    /*
    • 切换数据源名称
      */
      public DataSourceType value() default DataSourceType.MASTER;
      }

3.详细使用

@ApiOperation(value = "oracle数据源 同步 达梦数据库")
@GetMapping("/oracleUserToDMList")
public AjaxResult oracleUserToDMList() {
Login login = new Login();
AjaxResult ajaxResult = loginService.selectLoginList(login);
if (!"200".equals(ajaxResult.get("code").toString())) {
throw new CustomException("老系统oracle网络异常,请检查数据源配置,用户名,密码,或者网络是否通信。请开发人员排查!");
}
List oracleLoginDataList = (List) ajaxResult.get("data");
if (StringUtils.isEmpty(ajaxResult.get("data").toString())) {
throw new CustomException("老系统数据查询有问题,请开发人员排查!");
}

    if (oracleLoginDataList.size() < 1) {
        throw new CustomException("获取的老系统数据转换有问题,请开发人员排查!");
    }

    int inserNum = 0;
    int inserErrNum = 0;
    for (int i = 0; i < oracleLoginDataList.size(); i++) {
        SysUser sysUser = new SysUser();
        sysUser.setUserName(oracleLoginDataList.get(i).getUsername());
        sysUser.setNickName(oracleLoginDataList.get(i).getUserrealname());
        //同步的老系统用户密码 明文统一为  1111111
        sysUser.setPassword("gtWs/z111111111=");
        //新系统 0:正常 1:停用   老系统有字段是 ISDELETE = 1 ,删除的用户直接是物理删除
        sysUser.setStatus(String.valueOf(0));
        sysUser.setUnit(oracleLoginDataList.get(i).getUnit());
        sysUser.setIdnumber(oracleLoginDataList.get(i).getIdnumber());
        sysUser.setArea(oracleLoginDataList.get(i).getArea());
        sysUser.setDivision(oracleLoginDataList.get(i).getDivision());
        sysUser.setRemark("老系统接口同步数据");
        int i1 = sysUserMapper.insertUser(sysUser);
        if (i1 == 1) {
            inserNum = inserNum + 1;
        } else {
            inserErrNum = inserErrNum + 1;
        }
    }
    if (oracleLoginDataList.size() == inserNum) {
        return AjaxResult.success("同步成功:" + inserNum + " 条,用户数据, 失败: " + inserErrNum + " 条!");
    }
    return AjaxResult.error("oracle数据同步 达梦 失败,请开发人员检查!");
}

3.1 oracle数据源读数据
/**

 * 查询老系统-用户表列表
 *
 * @param login 老系统-用户表
 * @return 老系统-用户表
 */
@Override
@DataSource(value = DataSourceType.SLAVE)
public AjaxResult selectLoginList(Login login)
{
    return AjaxResult.success(loginMapper.selectLoginList(login));
}

3.2 达梦入库 oracle的数据

  这里没有指定数据源的原因是:项目框架默认指定  达梦数据源

/**
 * 新增用户信息
 * 
 * @param user 用户信息
 * @return 结果
 */
public int insertUser(SysUser user);

image.pngimage.png

image.png

达梦入库的数据
image.png
这里注意的是,一定要在上层 依次调用不同数据源的方法,否则会出现 多数据源失效问题

相关文章
|
7天前
|
关系型数据库 数据管理 数据库
数据管理DMS操作报错合集之在数据同步时遇到报错,该如何排查
数据管理DMS(Data Management Service)是阿里云提供的数据库管理和运维服务,它支持多种数据库类型,包括RDS、PolarDB、MongoDB等。在使用DMS进行数据库操作时,可能会遇到各种报错情况。以下是一些常见的DMS操作报错及其可能的原因与解决措施的合集。
|
8天前
|
DataWorks 数据挖掘 调度
DataWorks产品使用合集之如何查看HTTP触发器调用的域名
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
1天前
|
Java 关系型数据库 流计算
实时计算 Flink版操作报错合集之配置cats进行从MySQL到StarRocks的数据同步任务时遇到报错,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
4天前
|
存储 消息中间件 NoSQL
使用 Java 操作 Redis 数据类型的详解指南
使用 Java 操作 Redis 数据类型的详解指南
5 0
|
5天前
|
存储 缓存 Java
滚雪球学Java(59):从基础到高阶:Java中LinkedList的操作指南
【6月更文挑战第13天】🏆本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
11 1
滚雪球学Java(59):从基础到高阶:Java中LinkedList的操作指南
|
5天前
|
Java 大数据 API
【大数据】HDFS、HBase操作教程(含指令和JAVA API)
【大数据】HDFS、HBase操作教程(含指令和JAVA API)
35 0
【大数据】HDFS、HBase操作教程(含指令和JAVA API)
|
5天前
|
JSON Java 网络架构
【elastic search】JAVA操作elastic search
【elastic search】JAVA操作elastic search
7 1
|
7天前
|
JavaScript Java Serverless
Serverless 应用引擎操作报错合集之Java函数在运行时出现报错:"operation not permitted",是什么意思
Serverless 应用引擎(SAE)是阿里云提供的Serverless PaaS平台,支持Spring Cloud、Dubbo、HSF等主流微服务框架,简化应用的部署、运维和弹性伸缩。在使用SAE过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
7天前
|
分布式计算 DataWorks 关系型数据库
DataWorks操作报错合集之离线同步任务中,把表数据同步到POLARDB,显示所有数据都是脏数据,报错信息:ERROR JobContainer - 运行scheduler 模式[local]出错.是什么原因
DataWorks是阿里云提供的一站式大数据开发与治理平台,支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中,可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
|
8天前
|
SQL 分布式计算 大数据
MaxCompute操作报错合集之在数据同步时,遇到报错"InvalidData: The string's length is more than 8388608 bytes."是什么导致的
MaxCompute是阿里云提供的大规模离线数据处理服务,用于大数据分析、挖掘和报表生成等场景。在使用MaxCompute进行数据处理时,可能会遇到各种操作报错。以下是一些常见的MaxCompute操作报错及其可能的原因与解决措施的合集。

热门文章

最新文章