hanrenchun
1 year ago
parent
811b4ea864
commit
98a5f4ddd5
@ -0,0 +1,221 @@
|
||||
package com.ssf.mysqloracletest.domain;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
*
|
||||
* @TableName v_sy_syrk
|
||||
*/
|
||||
@TableName(value ="v_sy_syrk")
|
||||
@Data
|
||||
public class VSySyrkMysql implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String zjlid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ysxtjrzj;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xxscPdbz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String id;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ryfjid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ryid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String sfzh;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xb;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String mz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String hyzk;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String whcd;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String csrq;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String sjhm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String lxdh;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String hjssxq;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String hjdxz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xjzdxz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String rylx;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String pcsdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String pcsmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String cjwhdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String cjwhmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String jwqdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String jwqmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String wgdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String wgmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String jzwid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String fjid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String fjdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xqid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String sts;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String crId;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String crMc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String crDt;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String chId;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String chMc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String chDt;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String cdcJym;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ysbzkRksj;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ysbzkGxsj;
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,222 @@
|
||||
package com.ssf.mysqloracletest.domain;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
*
|
||||
* @TableName v_sy_syrk
|
||||
*/
|
||||
@TableName(value ="v_sy_syrk")
|
||||
@Data
|
||||
public class VSySyrkOracle implements Serializable {
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String zjlid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ysxtjrzj;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xxscPdbz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String id;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ryfjid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ryid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String sfzh;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xb;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String mz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String hyzk;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String whcd;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String csrq;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String sjhm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String lxdh;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String hjssxq;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String hjdxz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xjzdxz;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String rylx;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String pcsdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String pcsmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String cjwhdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String cjwhmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String jwqdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String jwqmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String wgdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String wgmc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String jzwid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String fjid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String fjdm;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String xqid;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String sts;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String crId;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String crMc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String crDt;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String chId;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String chMc;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String chDt;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String cdcJym;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ysbzkRksj;
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private String ysbzkGxsj;
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,26 @@
|
||||
package com.ssf.mysqloracletest.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkMysql;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
|
||||
|
||||
/**
|
||||
* @author 28758
|
||||
* @description 针对表【v_sy_syrk】的数据库操作Mapper
|
||||
* @createDate 2023-11-28 18:50:36
|
||||
* @Entity generator.domain.VSySyrk
|
||||
*/
|
||||
@Mapper
|
||||
public interface VSySyrkMysqlMapper extends BaseMapper<VSySyrkMysql> {
|
||||
|
||||
public VSySyrkMysql selectVSySyrkById(String id);
|
||||
|
||||
public int insertVSySyrk(VSySyrkMysql bean);
|
||||
|
||||
public int updateVSySyrkById(VSySyrkMysql bean);
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -0,0 +1,28 @@
|
||||
package com.ssf.mysqloracletest.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.ssf.mysqloracletest.domain.VSySyfwOracle;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkOracle;
|
||||
import org.apache.ibatis.annotations.Mapper;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
|
||||
/**
|
||||
* @author 28758
|
||||
* @description 针对表【v_sy_syrk】的数据库操作Mapper
|
||||
* @createDate 2023-11-28 18:50:36
|
||||
* @Entity generator.domain.VSySyrk
|
||||
*/
|
||||
@Mapper
|
||||
public interface VSySyrkOracleMapper extends BaseMapper<VSySyrkOracle> {
|
||||
public int countSyrk();
|
||||
|
||||
public List<VSySyrkOracle> getSyrkList(Map map);
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -0,0 +1,18 @@
|
||||
package com.ssf.mysqloracletest.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkMysql;
|
||||
|
||||
/**
|
||||
* @author 28758
|
||||
* @description 针对表【v_sy_syrk】的数据库操作Service
|
||||
* @createDate 2023-11-28 18:50:36
|
||||
*/
|
||||
public interface VSySyrkMysqlService extends IService<VSySyrkMysql> {
|
||||
public VSySyrkMysql selectVSySyrkById(String id);
|
||||
|
||||
public int insertVSySyrk(VSySyrkMysql syrk);
|
||||
|
||||
public int updateVSySyrkById(VSySyrkMysql syrk);
|
||||
|
||||
}
|
||||
@ -0,0 +1,20 @@
|
||||
package com.ssf.mysqloracletest.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkOracle;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkOracle;
|
||||
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author 28758
|
||||
* @description 针对表【v_sy_syrk】的数据库操作Service
|
||||
* @createDate 2023-11-28 18:50:36
|
||||
*/
|
||||
public interface VSySyrkOracleService extends IService<VSySyrkOracle> {
|
||||
public int countSyrk();
|
||||
|
||||
public List<VSySyrkOracle> getSyrkList(Map map);
|
||||
|
||||
}
|
||||
@ -0,0 +1,41 @@
|
||||
package com.ssf.mysqloracletest.service.impl;
|
||||
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkMysql;
|
||||
import com.ssf.mysqloracletest.mapper.VSySyrkMysqlMapper;
|
||||
import com.ssf.mysqloracletest.service.VSySyrkMysqlService;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author 28758
|
||||
* @description 针对表【v_sy_syrk】的数据库操作Service实现
|
||||
* @createDate 2023-11-28 18:50:36
|
||||
*/
|
||||
@Service
|
||||
@DS("mysql")
|
||||
@RequiredArgsConstructor
|
||||
public class VSySyrkMysqlServiceImpl extends ServiceImpl<VSySyrkMysqlMapper, VSySyrkMysql> implements VSySyrkMysqlService {
|
||||
|
||||
private final VSySyrkMysqlMapper sySyrkMysqlMapper;
|
||||
|
||||
@Override
|
||||
public VSySyrkMysql selectVSySyrkById(String id) {
|
||||
return sySyrkMysqlMapper.selectVSySyrkById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public int insertVSySyrk(VSySyrkMysql syrk) {
|
||||
return 0;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int updateVSySyrkById(VSySyrkMysql syrk) {
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -0,0 +1,42 @@
|
||||
package com.ssf.mysqloracletest.service.impl;
|
||||
|
||||
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkOracle;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkOracle;
|
||||
import com.ssf.mysqloracletest.mapper.VSySyrkOracleMapper;
|
||||
import com.ssf.mysqloracletest.mapper.VSySyrkOracleMapper;
|
||||
import com.ssf.mysqloracletest.service.VSySyrkOracleService;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author 28758
|
||||
* @description 针对表【v_sy_syrk】的数据库操作Service实现
|
||||
* @createDate 2023-11-28 18:50:36
|
||||
*/
|
||||
@Service
|
||||
@DS("oracleSydz")
|
||||
public class VSySyrkOracleServiceImpl extends ServiceImpl<VSySyrkOracleMapper, VSySyrkOracle> implements VSySyrkOracleService {
|
||||
|
||||
@Resource
|
||||
private VSySyrkOracleMapper oracleMapper;
|
||||
|
||||
@Override
|
||||
public int countSyrk() {
|
||||
return oracleMapper.countSyrk();
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<VSySyrkOracle> getSyrkList(Map map) {
|
||||
return oracleMapper.getSyrkList(map);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
@ -0,0 +1,114 @@
|
||||
package com.ssf.mysqloracletest.task;
|
||||
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkMysql;
|
||||
import com.ssf.mysqloracletest.domain.VSySyrkOracle;
|
||||
import com.ssf.mysqloracletest.service.VSySyrkMysqlService;
|
||||
import com.ssf.mysqloracletest.service.VSySyrkOracleService;
|
||||
import com.ssf.mysqloracletest.utils.ConfigParam;
|
||||
import com.ssf.mysqloracletest.utils.NumKit;
|
||||
import com.ssf.mysqloracletest.utils.StringKit;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
/**
|
||||
* 用户数据接入
|
||||
*/
|
||||
@Component
|
||||
public class VSySyrkTask {
|
||||
|
||||
private static final Logger logger = LoggerFactory.getLogger(VSySyrkTask.class);
|
||||
|
||||
@Resource
|
||||
private VSySyrkMysqlService syrkMysqlService;
|
||||
|
||||
@Resource
|
||||
private VSySyrkOracleService syrkOracleService;
|
||||
|
||||
final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts);
|
||||
|
||||
private boolean syrkTag = false;
|
||||
|
||||
/**
|
||||
* 连云港 对接海康平台获取人员基础数据
|
||||
* //
|
||||
*/
|
||||
@Scheduled(initialDelay = 100, fixedDelay = 3000)
|
||||
public void transSyrk() {
|
||||
|
||||
if (syrkTag) {
|
||||
return;
|
||||
}
|
||||
|
||||
if (!"true".equals(ConfigParam.syrkSwitch)) {
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
try {
|
||||
int countSyrk = syrkOracleService.countSyrk();
|
||||
logger.info("countsyrk:" + countSyrk);
|
||||
|
||||
if (countSyrk > 0) {
|
||||
|
||||
syrkTag = true;
|
||||
|
||||
int count = countSyrk / oncesCounts;
|
||||
CountDownLatch latch = new CountDownLatch(count);
|
||||
ExecutorService syrkPool = Executors.newFixedThreadPool(50);
|
||||
|
||||
for (int i = 0; i <= count; i++) {
|
||||
Map syrkMap = new HashMap();
|
||||
syrkMap.put("rowStart", i * oncesCounts);
|
||||
syrkMap.put("rowEnd", (i + 1) * oncesCounts);
|
||||
syrkPool.submit(() -> {
|
||||
try {
|
||||
List<VSySyrkOracle> syrks = syrkOracleService.getSyrkList(syrkMap);
|
||||
for (VSySyrkOracle syrk : syrks) {
|
||||
VSySyrkMysql sBean = new VSySyrkMysql();
|
||||
BeanUtils.copyProperties(syrk, sBean);
|
||||
//确定一个数据是否唯一
|
||||
VSySyrkMysql checkSyrk = syrkMysqlService.selectVSySyrkById(syrk.getZjlid());
|
||||
if (checkSyrk == null) {
|
||||
syrkMysqlService.insertVSySyrk(sBean);
|
||||
logger.info("syrk-" + syrk.getZjlid() + ":插入成功");
|
||||
} else {
|
||||
syrkMysqlService.updateVSySyrkById(sBean);
|
||||
logger.info("syrk-" + syrk.getZjlid() + ":更新成功");
|
||||
}
|
||||
}
|
||||
} catch (Exception e) {
|
||||
logger.info("syrks:" + e.getMessage());
|
||||
}
|
||||
latch.countDown();
|
||||
});
|
||||
logger.info("syrkMap数据总量:" + countSyrk + "," + "当前处理下标:" + syrkMap.get("rowStart") + "/" + syrkMap.get("rowEnd"));
|
||||
}
|
||||
|
||||
try {
|
||||
// Wait for all threads to complete
|
||||
latch.await();
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
// 关闭线程池
|
||||
syrkPool.shutdown();
|
||||
}
|
||||
|
||||
} catch (Exception e) {
|
||||
logger.info(StringKit.getTrace(e));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -1 +1 @@
|
||||
server:
port: 5678
spring:
datasource:
dynamic:
primary: mysql #设置默认的数据源或者数据源组,默认值即为master
strict: false #设置严格模式,默认false不启动. 启动后再为匹配到指定数据源时候回抛出异常,不启动会使用默认数据源.
datasource:
oracleSydz:
url: jdbc:oracle:thin:@50.146.63.219:1588/sygadsj
driver-class-name: oracle.jdbc.driver.OracleDriver
username: za_sjdj
password: 'za_sjdj0324'
mysql:
url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: '!QAZ1qaz'
mybatis-plus:
mapper-locations:
- classpath:mapper/*.xml
|
||||
server:
port: 5678
spring:
datasource:
dynamic:
primary: mysql #设置默认的数据源或者数据源组,默认值即为master
strict: false #设置严格模式,默认false不启动. 启动后再为匹配到指定数据源时候回抛出异常,不启动会使用默认数据源.
datasource:
oracleSydz:
url: jdbc:oracle:thin:@50.146.63.219:1588/sygadsj
driver-class-name: oracle.jdbc.driver.OracleDriver
username: za_sjdj
password: 'za_sjdj0324'
mysql:
url: jdbc:mysql://121.41.91.94:12036/yhzafk?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: '!QAZ1qaz'
mybatis-plus:
mapper-locations:
- classpath:mapper/*.xml
|
||||
@ -0,0 +1,183 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper
|
||||
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
||||
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.ssf.mysqloracletest.mapper.VSySyrkMysqlMapper">
|
||||
|
||||
<resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.VSySyrkMysql">
|
||||
<result property="zjlid" column="ZJLID" jdbcType="VARCHAR"/>
|
||||
<result property="ysxtjrzj" column="YSXTJRZJ" jdbcType="VARCHAR"/>
|
||||
<result property="xxscPdbz" column="XXSC_PDBZ" jdbcType="VARCHAR"/>
|
||||
<result property="id" column="ID" jdbcType="VARCHAR"/>
|
||||
<result property="ryfjid" column="RYFJID" jdbcType="VARCHAR"/>
|
||||
<result property="ryid" column="RYID" jdbcType="VARCHAR"/>
|
||||
<result property="sfzh" column="SFZH" jdbcType="VARCHAR"/>
|
||||
<result property="xm" column="XM" jdbcType="VARCHAR"/>
|
||||
<result property="xb" column="XB" jdbcType="VARCHAR"/>
|
||||
<result property="mz" column="MZ" jdbcType="VARCHAR"/>
|
||||
<result property="hyzk" column="HYZK" jdbcType="VARCHAR"/>
|
||||
<result property="whcd" column="WHCD" jdbcType="VARCHAR"/>
|
||||
<result property="csrq" column="CSRQ" jdbcType="VARCHAR"/>
|
||||
<result property="sjhm" column="SJHM" jdbcType="VARCHAR"/>
|
||||
<result property="lxdh" column="LXDH" jdbcType="VARCHAR"/>
|
||||
<result property="hjssxq" column="HJSSXQ" jdbcType="VARCHAR"/>
|
||||
<result property="hjdxz" column="HJDXZ" jdbcType="VARCHAR"/>
|
||||
<result property="xjzdxz" column="XJZDXZ" jdbcType="VARCHAR"/>
|
||||
<result property="rylx" column="RYLX" jdbcType="VARCHAR"/>
|
||||
<result property="pcsdm" column="PCSDM" jdbcType="VARCHAR"/>
|
||||
<result property="pcsmc" column="PCSMC" jdbcType="VARCHAR"/>
|
||||
<result property="cjwhdm" column="CJWHDM" jdbcType="VARCHAR"/>
|
||||
<result property="cjwhmc" column="CJWHMC" jdbcType="VARCHAR"/>
|
||||
<result property="jwqdm" column="JWQDM" jdbcType="VARCHAR"/>
|
||||
<result property="jwqmc" column="JWQMC" jdbcType="VARCHAR"/>
|
||||
<result property="wgdm" column="WGDM" jdbcType="VARCHAR"/>
|
||||
<result property="wgmc" column="WGMC" jdbcType="VARCHAR"/>
|
||||
<result property="jzwid" column="JZWID" jdbcType="VARCHAR"/>
|
||||
<result property="fjid" column="FJID" jdbcType="VARCHAR"/>
|
||||
<result property="fjdm" column="FJDM" jdbcType="VARCHAR"/>
|
||||
<result property="xqid" column="XQID" jdbcType="VARCHAR"/>
|
||||
<result property="sts" column="STS" jdbcType="VARCHAR"/>
|
||||
<result property="crId" column="CR_ID" jdbcType="VARCHAR"/>
|
||||
<result property="crMc" column="CR_MC" jdbcType="VARCHAR"/>
|
||||
<result property="crDt" column="CR_DT" jdbcType="VARCHAR"/>
|
||||
<result property="chId" column="CH_ID" jdbcType="VARCHAR"/>
|
||||
<result property="chMc" column="CH_MC" jdbcType="VARCHAR"/>
|
||||
<result property="chDt" column="CH_DT" jdbcType="VARCHAR"/>
|
||||
<result property="cdcJym" column="CDC_JYM" jdbcType="VARCHAR"/>
|
||||
<result property="ysbzkRksj" column="YSBZK_RKSJ" jdbcType="VARCHAR"/>
|
||||
<result property="ysbzkGxsj" column="YSBZK_GXSJ" jdbcType="VARCHAR"/>
|
||||
</resultMap>
|
||||
|
||||
<select id="selectVSySyrkById" parameterType="java.lang.String" resultMap="BaseResultMap">
|
||||
select * from v_sy_syrk
|
||||
where ID = #{id} limit 1
|
||||
</select>
|
||||
|
||||
<insert id="insertVSySyrk" parameterType="com.ssf.mysqloracletest.domain.VSySyrkMysql" useGeneratedKeys="true"
|
||||
keyProperty="id">
|
||||
insert into v_sy_syrk
|
||||
<trim prefix="(" suffix=")" suffixOverrides=",">
|
||||
<if test="ZJLID != null and ZJLID != '' ">ZJLID,</if>
|
||||
<if test="YSXTJRZJ != null and YSXTJRZJ != '' ">YSXTJRZJ,</if>
|
||||
<if test="XXSC_PDBZ != null and XXSC_PDBZ != '' ">XXSC_PDBZ,</if>
|
||||
<if test="ID != null and ID != '' ">ID,</if>
|
||||
<if test="RYFJID != null and RYFJID != '' ">RYFJID,</if>
|
||||
<if test="RYID != null and RYID != '' ">RYID,</if>
|
||||
<if test="SFZH != null and SFZH != '' ">SFZH,</if>
|
||||
<if test="XM != null and XM != '' ">XM,</if>
|
||||
<if test="XB != null and XB != '' ">XB,</if>
|
||||
<if test="MZ != null and MZ != '' ">MZ,</if>
|
||||
<if test="HYZK != null and HYZK != '' ">HYZK,</if>
|
||||
<if test="WHCD != null and WHCD != '' ">WHCD,</if>
|
||||
<if test="CSRQ != null and CSRQ != '' ">CSRQ,</if>
|
||||
<if test="SJHM != null and SJHM != '' ">SJHM,</if>
|
||||
<if test="LXDH != null and LXDH != '' ">LXDH,</if>
|
||||
<if test="PCSDM != null and PCSDM != '' ">PCSDM,</if>
|
||||
<if test="PCSMC != null and PCSMC != '' ">PCSMC,</if>
|
||||
<if test="CJWHDM != null and CJWHDM != '' ">CJWHDM,</if>
|
||||
<if test="CJWHMC != null and CJWHMC != '' ">CJWHMC,</if>
|
||||
<if test="JWQDM != null and JWQDM != '' ">JWQDM,</if>
|
||||
<if test="JWQMC != null and JWQMC != '' ">JWQMC,</if>
|
||||
<if test="WGDM != null and WGDM != '' ">WGDM,</if>
|
||||
<if test="WGMC != null and WGMC != '' ">WGMC,</if>
|
||||
<if test="JZWID != null and JZWID != '' ">JZWID,</if>
|
||||
<if test="FJID != null and FJID != '' ">FJID,</if>
|
||||
<if test="FJDM != null and FJDM != '' ">FJDM,</if>
|
||||
<if test="XQID != null and XQID != '' ">XQID,</if>
|
||||
<if test="STS != null and STS != '' ">STS,</if>
|
||||
<if test="CR_ID != null and CR_ID != '' ">CR_ID,</if>
|
||||
<if test="CR_MC != null and CR_MC != '' ">CR_MC,</if>
|
||||
<if test="CR_DT != null and CR_DT != '' ">CR_DT,</if>
|
||||
<if test="CH_ID != null and CH_ID != '' ">CH_ID,</if>
|
||||
<if test="CH_MC != null and CH_MC != '' ">CH_MC,</if>
|
||||
<if test="CH_DT != null and CH_DT != '' ">CH_DT,</if>
|
||||
<if test="CDC_JYM != null and CDC_JYM != '' ">CDC_JYM,</if>
|
||||
<if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">YSBZK_RKSJ,</if>
|
||||
<if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">YSBZK_GXSJ,</if>
|
||||
</trim>
|
||||
<trim prefix="values (" suffix=")" suffixOverrides=",">
|
||||
<if test="ZJLID != null and ZJLID != '' ">#{ZJLID},</if>
|
||||
<if test="YSXTJRZJ != null and YSXTJRZJ != '' ">#{YSXTJRZJ},</if>
|
||||
<if test="XXSC_PDBZ != null and XXSC_PDBZ != '' ">#{XXSC_PDBZ},</if>
|
||||
<if test="ID != null and ID != '' ">#{ID},</if>
|
||||
<if test="RYFJID != null and RYFJID != '' ">#{RYFJID},</if>
|
||||
<if test="RYID != null and RYID != '' ">#{RYID},</if>
|
||||
<if test="SFZH != null and SFZH != '' ">#{SFZH},</if>
|
||||
<if test="XM != null and XM != '' ">#{XM},</if>
|
||||
<if test="XB != null and XB != '' ">#{XB},</if>
|
||||
<if test="MZ != null and MZ != '' ">#{MZ},</if>
|
||||
<if test="HYZK != null and HYZK != '' ">#{HYZK},</if>
|
||||
<if test="WHCD != null and WHCD != '' ">#{WHCD},</if>
|
||||
<if test="CSRQ != null and CSRQ != '' ">#{CSRQ},</if>
|
||||
<if test="SJHM != null and SJHM != '' ">#{SJHM},</if>
|
||||
<if test="LXDH != null and LXDH != '' ">#{LXDH},</if>
|
||||
<if test="PCSDM != null and PCSDM != '' ">#{PCSDM},</if>
|
||||
<if test="PCSMC != null and PCSMC != '' ">#{PCSMC},</if>
|
||||
<if test="CJWHDM != null and CJWHDM != '' ">#{CJWHDM},</if>
|
||||
<if test="CJWHMC != null and CJWHMC != '' ">#{CJWHMC},</if>
|
||||
<if test="JWQDM != null and JWQDM != '' ">#{JWQDM},</if>
|
||||
<if test="JWQMC != null and JWQMC != '' ">#{JWQMC},</if>
|
||||
<if test="WGDM != null and WGDM != '' ">#{WGDM},</if>
|
||||
<if test="WGMC != null and WGMC != '' ">#{WGMC},</if>
|
||||
<if test="JZWID != null and JZWID != '' ">#{JZWID},</if>
|
||||
<if test="FJID != null and FJID != '' ">#{FJID},</if>
|
||||
<if test="FJDM != null and FJDM != '' ">#{FJDM},</if>
|
||||
<if test="XQID != null and XQID != '' ">#{XQID},</if>
|
||||
<if test="STS != null and STS != '' ">#{STS},</if>
|
||||
<if test="CR_ID != null and CR_ID != '' ">#{CR_ID},</if>
|
||||
<if test="CR_MC != null and CR_MC != '' ">#{CR_MC},</if>
|
||||
<if test="CR_DT != null and CR_DT != '' ">#{CR_DT},</if>
|
||||
<if test="CH_ID != null and CH_ID != '' ">#{CH_ID},</if>
|
||||
<if test="CH_MC != null and CH_MC != '' ">#{CH_MC},</if>
|
||||
<if test="CH_DT != null and CH_DT != '' ">#{CH_DT},</if>
|
||||
<if test="CDC_JYM != null and CDC_JYM != '' ">#{CDC_JYM},</if>
|
||||
<if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">#{YSBZK_RKSJ},</if>
|
||||
<if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">#{YSBZK_GXSJ},</if>
|
||||
</trim>
|
||||
</insert>
|
||||
|
||||
<update id="updateVSySyrkById" parameterType="com.ssf.mysqloracletest.domain.VSySyrkMysql">
|
||||
update v_sy_syrk
|
||||
<trim prefix="SET" suffixOverrides=",">
|
||||
<if test="ZJLID != null and ZJLID != '' ">ZJLID=#{ZJLID},</if>
|
||||
<if test="YSXTJRZJ != null and YSXTJRZJ != '' ">YSXTJRZJ=#{YSXTJRZJ},</if>
|
||||
<if test="XXSC_PDBZ != null and XXSC_PDBZ != '' ">XXSC_PDBZ=#{XXSC_PDBZ},</if>
|
||||
<if test="ID != null and ID != '' ">ID=#{ID},</if>
|
||||
<if test="RYFJID != null and RYFJID != '' ">RYFJID=#{RYFJID},</if>
|
||||
<if test="RYID != null and RYID != '' ">RYID=#{RYID},</if>
|
||||
<if test="SFZH != null and SFZH != '' ">SFZH=#{SFZH},</if>
|
||||
<if test="XM != null and XM != '' ">XM=#{XM},</if>
|
||||
<if test="XB != null and XB != '' ">XB=#{XB},</if>
|
||||
<if test="MZ != null and MZ != '' ">MZ=#{MZ},</if>
|
||||
<if test="HYZK != null and HYZK != '' ">HYZK=#{HYZK},</if>
|
||||
<if test="WHCD != null and WHCD != '' ">WHCD=#{WHCD},</if>
|
||||
<if test="CSRQ != null and CSRQ != '' ">CSRQ=#{CSRQ},</if>
|
||||
<if test="SJHM != null and SJHM != '' ">SJHM=#{SJHM},</if>
|
||||
<if test="LXDH != null and LXDH != '' ">LXDH=#{LXDH},</if>
|
||||
<if test="PCSDM != null and PCSDM != '' ">PCSDM=#{PCSDM},</if>
|
||||
<if test="PCSMC != null and PCSMC != '' ">PCSMC=#{PCSMC},</if>
|
||||
<if test="CJWHDM != null and CJWHDM != '' ">CJWHDM=#{CJWHDM},</if>
|
||||
<if test="CJWHMC != null and CJWHMC != '' ">CJWHMC=#{CJWHMC},</if>
|
||||
<if test="JWQDM != null and JWQDM != '' ">JWQDM=#{JWQDM},</if>
|
||||
<if test="JWQMC != null and JWQMC != '' ">JWQMC=#{JWQMC},</if>
|
||||
<if test="WGDM != null and WGDM != '' ">WGDM=#{WGDM},</if>
|
||||
<if test="WGMC != null and WGMC != '' ">WGMC=#{WGMC},</if>
|
||||
<if test="JZWID != null and JZWID != '' ">JZWID=#{JZWID},</if>
|
||||
<if test="FJID != null and FJID != '' ">FJID=#{FJID},</if>
|
||||
<if test="FJDM != null and FJDM != '' ">FJDM=#{FJDM},</if>
|
||||
<if test="XQID != null and XQID != '' ">XQID=#{XQID},</if>
|
||||
<if test="STS != null and STS != '' ">STS=#{STS},</if>
|
||||
<if test="CR_ID != null and CR_ID != '' ">CR_ID=#{CR_ID},</if>
|
||||
<if test="CR_MC != null and CR_MC != '' ">CR_MC=#{CR_MC},</if>
|
||||
<if test="CR_DT != null and CR_DT != '' ">CR_DT=#{CR_DT},</if>
|
||||
<if test="CH_ID != null and CH_ID != '' ">CH_ID=#{CH_ID},</if>
|
||||
<if test="CH_MC != null and CH_MC != '' ">CH_MC=#{CH_MC},</if>
|
||||
<if test="CH_DT != null and CH_DT != '' ">CH_DT=#{CH_DT},</if>
|
||||
<if test="CDC_JYM != null and CDC_JYM != '' ">CDC_JYM=#{CDC_JYM},</if>
|
||||
<if test="YSBZK_RKSJ != null and YSBZK_RKSJ != '' ">YSBZK_RKSJ=#{YSBZK_RKSJ},</if>
|
||||
<if test="YSBZK_GXSJ != null and YSBZK_GXSJ != '' ">YSBZK_GXSJ=#{YSBZK_GXSJ},</if>
|
||||
</trim>
|
||||
where ID = #{id}
|
||||
</update>
|
||||
|
||||
</mapper>
|
||||
Loading…
Reference in new issue