首页 > 数据库> 文章详细

springboot定时同步数据，从sqlserver到mysql

2022-08-29 17:31:00 阅读：200 来源： 互联网

标签：info log 数据源 sqlserver mysql public springboot

定时同步数据，从sqlserver到mysql 注意事项：一.primary: master #设置默认的数据源或者数据源组,默认值即为master 二.@Scheduled() 和 @DS("slave_1")注解步骤： 1.在原先运行的程序外，新建多加一个springboot程序 2.配置好yml，连接两个数据库，全局配置一个开始时间

dynamic:
      primary: master #设置默认的数据源或者数据源组,默认值即为master
      strict: false #设置严格模式,默认false不启动. 启动后在未匹配到指定数据源时候会抛出异常,不启动则使用默认数据源.
      datasource:
        master:
          url: jdbc:mysql://ip:端口/库名?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=Asia/Shanghai
          username: root
          password: root
          driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
        slave_1:
          url: jdbc:sqlserver://ip:端口;DatabaseName=ykt
          username: sa
          password: 123
          driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
time: 2020-01-01 00:00:00

3.写好两个实体类，一个sqlserver的表，一个mysql的表 4.写好转移的逻辑业务（HelloService中）

@Service
@Slf4j
public class HelloService {
    @Autowired
    private DataMapper dataMapper;

    @Autowired
    private ParkRecordMapper parkRecordMapper;

    @Value("${time}")
    @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
    private Date starTime;
    
    public void saveData() throws ParseException {
//以下为具体业务，根据自己需求修改
        log.info("进入数据转存定时任务");
        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date endTime = new Date();
        List<ComeCar> comeCars = dataMapper.selectByTime(starTime,endTime);
        if (comeCars!=null && comeCars.isEmpty()){
            return;
        }
        for (int i = 0; i < comeCars.size(); i++) {
            ComeCar comeCar = comeCars.get(i);
            log.info("正在转存数据");
            ParkRecord parkRecord = new ParkRecord();
            parkRecord.setCreateDate(formatter.parse(comeCar.getComeDate()));
            parkRecord.setPhoto(comeCar.getComePic());
            log.info("单条数据为"+parkRecord);
            parkRecordMapper.insert(parkRecord);
        }
        starTime = endTime;
        log.info("刷新数据成功");
    }
}

5.创建一个定时器（SchedulingTask）

@Component
@Async
@Slf4j
public class SchedulingTask {

    private final long TEN_MINUTES = 600000;

    @Autowired
    HelloService helloService;

    /**
     * 每10分钟刷新一下数据
     */
    @Scheduled(fixedRate = TEN_MINUTES)
    public void refreshData() {
        try {
            helloService.saveData();
            log.info("定时任务开启，每10分钟刷新一下数据");
        } catch (ParseException e) {
            log.error("刷新数据失败,sql Server数据库有可能挂了");
            e.printStackTrace();
        }
    }
}

6.HelloController

@RestController
public class HelloController {
    @Autowired
    HelloService helloService;

    @GetMapping("hello")
    public String hello() throws ParseException {
        helloService.saveData();
        return "hello";
    }
}

7.运行测试没问题，修改模拟数据库地址，maven导出jar包，再到云服务器上运行就可以了！

8.具体业务其中一个mapper（sqlserver表）

@Mapper
public interface DataMapper {

    @DS("slave_1")
    List<ComeCar> selectByTime(@Param("star_time") Date starTime,@Param("end_time")Date endTime);
}

标签：info,log,数据源,sqlserver,mysql,public,springboot
来源： https://www.cnblogs.com/SjhCode/p/sqlserverToMysql.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

springboot定时同步数据，从sqlserver到mysql