Javaは複数のデータ統合を実現し、ターゲットテーブルにmergeを入れる

    
    
           select
        	a.SJDBH    ,
        	XZQH       ,
        	JJDWBH     ,
        	SFDZ       ,
        	DWBZW      ,
        	XZB        ,
        	YZB        ,
        	BJR        ,
        	LXDH       ,
        	LXDZ       ,
        	SSFJ       ,
        	XQDW       ,
        	CLLX       ,
        	JQJB       ,
        	AY         ,
        	GLSJDBH    ,
        	SJXQ       ,
        	CJDW       ,
        	CLJG       ,
        	SJCLQK     ,
        	SJZT       ,
        	BJRXB      ,
        	SFDZFL     ,
        	jjygh      ,
        	jjyxm      ,
        	yywj       ,
        	sjc        ,
        	jjybh      ,
        	sfsj       ,
        	ljfknr     ,
        	sffkzj     ,
        	ywwxwz     ,
        	ywbzxl     ,
        	bkryqksm   ,
        	ssryqksm   ,
        	swryqksm   ,
        	zjhm       ,
        	jqlbdm     ,
        	jqlxdm     ,
        	jqxldm     ,
        	jqjbdm     ,
        	zdbz       ,
        	ssxqdm     ,
        	ssxqmc     ,
        	szjqdm     ,
        	szjqmc     ,
        	jzwmc      ,
        	sfdzflmc   ,
        	jjth       ,
        	jjtip      ,
        	xqdwmc     ,
        	ssfjmc     ,
        	aymc       ,
        	jqlbmc     ,
        	jqlxmc     ,
        	jqxlmc     ,
        	scjjdwmc   ,
        	scpjdwmc   ,
        	scfkdwmc   ,
        	jqbqid     ,
        	jqbqmc     ,
        	isHuangpu  ,
        	lat02      ,
        	lng02      ,
        	number     ,
        	office_name,
        	area_name  ,
        	ZLJSSJ     ,
        	fksjc      ,
        	CJQK       ,
        	FKRGH
        from
        (select
        	SJDBH      ,
        	XZQH       ,
        	JJDWBH     ,
        	SFDZ       ,
        	DWBZW      ,
        	XZB        ,
        	YZB        ,
        	BJR        ,
        	LXDH       ,
        	LXDZ       ,
        	SSFJ       ,
        	XQDW       ,
        	CLLX       ,
        	JQJB       ,
        	AY         ,
        	GLSJDBH    ,
        	SJXQ       ,
        	CJDW       ,
        	CLJG       ,
        	SJCLQK     ,
        	SJZT       ,
        	BJRXB      ,
        	SFDZFL     ,
        	jjygh      ,
        	jjyxm      ,
        	yywj       ,
        	sjc        ,
        	jjybh      ,
        	sfsj       ,
        	ljfknr     ,
        	sffkzj     ,
        	ywwxwz     ,
        	ywbzxl     ,
        	bkryqksm   ,
        	ssryqksm   ,
        	swryqksm   ,
        	zjhm       ,
        	jqlbdm     ,
        	jqlxdm     ,
        	jqxldm     ,
        	jqjbdm     ,
        	zdbz       ,
        	ssxqdm     ,
        	ssxqmc     ,
        	szjqdm     ,
        	szjqmc     ,
        	jzwmc      ,
        	sfdzflmc   ,
        	jjth       ,
        	jjtip      ,
        	xqdwmc     ,
        	ssfjmc     ,
        	aymc       ,
        	jqlbmc     ,
        	jqlxmc     ,
        	jqxlmc     ,
        	scjjdwmc   ,
        	scpjdwmc   ,
        	scfkdwmc   ,
        	jqbqid     ,
        	jqbqmc     ,
        	isHuangpu  ,
        	lat02      ,
        	lng02      ,
        	number     ,
        	office_name,
        	area_name
        from t_sjd
        where sjc>= DATE_FORMAT(date_sub(NOW(),INTERVAL 1 DAY),'%Y-%m-%d')
	          and jqlbmc='  ' and SJXQ like '%    %') a
        inner join
        (select
        	SJDBH,
        	ZLJSSJ,
        	CJQK,
        	FKRGH,
        	max(sjc) fksjc
        from t_fkd
        where sjc>= DATE_FORMAT(date_sub(NOW(),INTERVAL 1 DAY),'%Y-%m-%d')
        	  and FKRGH in (select user_code from ism_police_user where plate_code not in (4,5) and is_4G is not null)
        GROUP BY SJDBH) b on a.SJDBH=b.SJDBH
    

    
    
		select
			case_occur_time,
			case_end_time,
			case_duration,
			case_long_effect,
			policeman_no,
			policeman_name,
			case_detail,
			video_url,
			audio_url
		from recog_case_info
		where /*case_occur_time>= DATE_FORMAT(date_sub(NOW(),INTERVAL 1 DAY),'%Y-%m-%d') and*/
		      policeman_no=#{policeNo}
	  		  and case_occur_time>=#{startTime}
	  		  and hour(case_occur_time)=hour(#{startTime})
    

	
	
       insert into t_4gsituation(
       	 			SJDBH ,
  					XZQH ,
  					JJDWBH ,
  					SFDZ,
  					DWBZW,
  					XZB,
  					YZB,
  					BJR,
  					LXDH,
  					LXDZ,
  					SSFJ,
  					XQDW,
  					CLLX,
  					JQJB,
  					AY,
  					GLSJDBH,
  					SJXQ,
  					CJDW,
  					CLJG,
  					SJCLQK,
  					SJZT,
  					BJRXB,
  					SFDZFL,
  					jjygh,
  					jjyxm,
  					yywj,
  					sjc,
  					jjybh,
  					sfsj,
  					ljfknr,
  					sffkzj,
  					ywwxwz,
  					ywbzxl,
  					bkryqksm,
  					ssryqksm,
  					swryqksm,
  					zjhm,
  					jqlbdm,
  					jqlxdm,
  					jqxldm,
  					jqjbdm,
  					zdbz,
  					ssxqdm,
  					ssxqmc,
  					szjqdm,
  					szjqmc,
  					jzwmc,
  					sfdzflmc,
  					jjth,
  					jjtip,
  					xqdwmc,
  					ssfjmc,
  					aymc,
  					jqlbmc,
  					jqlxmc,
  					jqxlmc,
  					scjjdwmc,
  					scpjdwmc,
  					scfkdwmc,
  					jqbqid,
  					jqbqmc,
  					isHuangpu,
  					lat02,
  					lng02,
  					number,
  					office_name,
  					area_name,
  					fksjc,
  					ZLJSSJ,
  					CJQK,
  					case_detail,
  					case_occur_time,
  					case_end_time,
  					case_duration,
  					case_long_effect,
  					video_url,
  					audio_url,
  					policeman_no,
  					policeman_name)
       values ( #{SJDBH},
  				#{XZQH},
  				#{JJDWBH},
  				#{SFDZ},
  				#{DWBZW},
  				#{XZB},
  				#{YZB},
  				#{BJR},
  				#{LXDH},
  				#{LXDZ},
  				#{SSFJ},
  				#{XQDW},
  				#{CLLX},
  				#{JQJB},
  				#{AY},
  				#{GLSJDBH},
  				#{SJXQ},
  				#{CJDW},
  				#{CLJG},
  				#{SJCLQK},
  				#{SJZT},
  				#{BJRXB},
  				#{SFDZFL},
  				#{jjygh},
  				#{jjyxm},
  				#{yywj},
  				#{sjc},
  				#{jjybh},
  				#{sfsj},
  				#{ljfknr},
  				#{sffkzj},
  				#{ywwxwz},
  				#{ywbzxl},
  				#{bkryqksm},
  				#{ssryqksm},
  				#{swryqksm},
  				#{zjhm},
  				#{jqlbdm},
  				#{jqlxdm},
  				#{jqxldm},
  				 #{jqjbdm},
  				#{zdbz},
  				#{ssxqdm},
  				#{ssxqmc},
  				#{szjqdm},
  				#{szjqmc},
  				#{jzwmc},
  				#{sfdzflmc},
  				#{jjth},
  				#{jjtip},
  				#{xqdwmc},
  				#{ssfjmc},
  				#{aymc},
  				#{jqlbmc},
  				#{jqlxmc},
  				#{jqxlmc},
  				#{scjjdwmc},
  				#{scpjdwmc},
  				#{scfkdwmc},
  				#{jqbqid},
  				#{jqbqmc},
  				#{isHuangpu},
  				#{lat02},
  				#{lng02},
  				#{number},
  				#{office_name},
  				#{area_name},
  				#{fksjc},
  				#{ZLJSSJ},
  				#{CJQK},
  				#{caseDetail},
  				#{caseOccurTime},
  				#{caseEndTime},
  				#{caseDuration},
  				#{caseLongEffect},
  				#{videoUrl},
  				#{audioUrl},
  				#{policemanNo},
  				#{policemanName})
  		 ON DUPLICATE KEY UPDATE
  		     	    XZQH=#{XZQH},
  					JJDWBH=#{JJDWBH} ,
  					SFDZ=#{SFDZ},
  					DWBZW=#{DWBZW},
  					XZB=#{XZB},
  					YZB=#{YZB},
  					BJR=#{BJR},
  					LXDH=#{LXDH},
  					LXDZ=#{LXDZ},
  					SSFJ=#{SSFJ},
  					XQDW=#{XQDW},
  					CLLX=#{CLLX},
  					JQJB=#{JQJB},
  					AY=#{AY},
  					GLSJDBH=#{GLSJDBH},
  					SJXQ=#{SJXQ},
  					CJDW=#{CJDW},
  					CLJG=#{CLJG},
  					SJCLQK=#{SJCLQK},
  					SJZT=#{SJZT},
  					BJRXB=#{BJRXB},
  					SFDZFL=#{SFDZFL},
  					jjygh=#{jjygh},
  					jjyxm=#{jjyxm},
  					yywj=#{yywj},
  					sjc=#{sjc},
  					jjybh=#{jjybh},
  					sfsj=#{sfsj},
  					ljfknr=#{ljfknr},
  					sffkzj=#{sffkzj},
  					ywwxwz=#{ywwxwz},
  					ywbzxl=#{ywbzxl},
  					bkryqksm=#{bkryqksm},
  					ssryqksm=#{ssryqksm},
  					swryqksm=#{swryqksm},
  					zjhm=#{zjhm},
  					jqlbdm=#{jqlbdm},
  					jqlxdm=#{jqlxdm},
  					jqxldm=#{jqxldm},
  					jqjbdm= #{jqjbdm},
  					zdbz=#{zdbz},
  					ssxqdm=#{ssxqdm},
  					ssxqmc=#{ssxqmc},
  					szjqdm=#{szjqdm},
  					szjqmc=#{szjqmc},
  					jzwmc=#{jzwmc},
  					sfdzflmc=#{sfdzflmc},
  					jjth=#{jjth},
  					jjtip=#{jjtip},
  					xqdwmc=#{xqdwmc},
  					ssfjmc=#{ssfjmc},
  					aymc=#{aymc},
  					jqlbmc=#{jqlbmc},
  					jqlxmc=#{jqlxmc},
  					jqxlmc=#{jqxlmc},
  					scjjdwmc=#{scjjdwmc},
  					scpjdwmc=#{scpjdwmc},
  					scfkdwmc=#{scfkdwmc},
  					jqbqid=#{jqbqid},
  					jqbqmc=#{jqbqmc},
  					isHuangpu=#{isHuangpu},
  					lat02=#{lat02},
  					lng02=#{lng02},
  					number=#{number},
  					office_name=#{office_name},
  					area_name=#{area_name},
  					fksjc=#{fksjc},
  					ZLJSSJ=#{ZLJSSJ},
  					CJQK=#{CJQK},
  					case_detail=#{caseDetail},
  					case_occur_time=#{caseOccurTime},
  					case_end_time=#{caseEndTime},
  					case_duration=#{caseDuration},
  					case_long_effect=#{caseLongEffect},
  					video_url=#{videoUrl},
  					audio_url=#{audioUrl},
  					policeman_no=#{policemanNo},
  					policeman_name=#{policemanName};
    

Mapper

package com.ruoyi.system.mapper;

import java.util.List;
import java.util.Map;

public interface Situation4GMapper {
    /*
    *             */
    public List

Service

package com.ruoyi.system.service;

import java.text.ParseException;

public interface Situation4GService {
    /**
     *                        
     */
    public void get4GSituation() throws ParseException;

}

ServiceImpl(プライマリロジック)

package com.ruoyi.system.service.impl;


import com.ruoyi.system.mapper.Situation4GMapper;
import com.ruoyi.system.service.Situation4GService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@EnableScheduling
@Service
public class Situation4GServiceImpl implements Situation4GService {
   @Autowired
    private Situation4GMapper situation4GMapper;

    @Override
    @Scheduled(cron = "5 * * * * ?")
    public void get4GSituation() throws ParseException {
        //          ,      map       
        Map paramMap = new HashMap<>();
        SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        List