t_jksbgl(监控设备)

develop
Angel 10 months ago
parent 811b4ea864
commit 3fb16b0de7

@ -3,4 +3,6 @@ sydzSwitch=false
#单次查询数据量
oncesCounts=10000
syfwSwitch=true
syfwSwitch=false
jksbSwitch=true

@ -0,0 +1,327 @@
package com.ssf.mysqloracletest.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable;
import lombok.Data;
/**
*
* @TableName t_jksbgl
*/
@Data
public class TJksbglMysql {
/**
*
*/
private String id;
/**
*
*/
private String sbmc;
/**
*
*/
private String sbbh;
/**
* ip
*/
private String ipdz;
/**
*
*/
private String macdz;
/**
*
*/
private String sbdk;
/**
*
*/
private String jkdwlx;
/**
*
*/
private String sblx;
/**
*
*/
private String sbxs;
/**
*
*/
private String gnlx;
/**
*
*/
private String ywbq;
/**
*
*/
private String jcc;
/**
*
*/
private String sbjd;
/**
*
*/
private String sbwd;
/**
*
*/
private String azdz;
/**
*
*/
private String cjfx;
/**
*
*/
private String sbzt;
/**
*
*/
private String ssgajg;
/**
*
*/
private String jrfs;
/**
*
*/
private String wlbs;
/**
*
*/
private String sbcs;
/**
*
*/
private String azsj;
/**
*
*/
private String ssbmhy;
/**
*
*/
private String dwlx;
/**
*
*/
private String djrxm;
/**
*
*/
private String djrsfzh;
/**
*
*/
private String djrdwdm;
/**
*
*/
private String djrdwmc;
/**
*
*/
private String djsj;
/**
*
*/
private String jrsjl;
/**
*
*/
private String zrsjl;
/**
*
*/
private String j30tsjl;
/**
*
*/
private String j30tjl;
/**
*
*/
private String zxzpsj;
/**
*
*/
private String zxrksj;
/**
*
*/
private String j7tsjl;
/**
*
*/
private String sfzdryj;
/**
*
*/
private String glytbh;
/**
*
*/
private String glksbh;
/**
*
*/
private String sfsdryj;
/**
*
*/
private String sbid;
/**
*
*/
private String sbjc;
/**
*
*/
private String gldl;
/**
*
*/
private String dllx;
/**
*
*/
private String cjqy;
/**
*
*/
private String cjfxlx;
/**
*
*/
private String sbsybh;
/**
*
*/
private String sbbabh;
/**
*
*/
private String sbbazt;
/**
*
*/
private String sbbzmc;
/**
*
*/
private String lkldmc;
/**
*
*/
private String lklddm;
/**
*
*/
private String glxmmc;
/**
*
*/
private String glxmid;
/**
*
*/
private String jczq;
/**
*
*/
private String jckk;
/**
*
*/
private String zpfx;
/**
*
*/
private String gldw;
/**
*
*/
private String lxr;
/**
*
*/
private String lxdh;
/**
*
*/
private String sfjsbryj;
/**
*
*/
private String sfzzrkyj;
// @TableField(exist = false)
// private static final long serialVersionUID = 1L;
}

@ -0,0 +1,327 @@
package com.ssf.mysqloracletest.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import java.io.Serializable;
/**
*
* @TableName t_jksbgl
*/
@Data
public class TJksbglOracle {
/**
*
*/
private String id;
/**
*
*/
private String sbmc;
/**
*
*/
private String sbbh;
/**
* ip
*/
private String ipdz;
/**
*
*/
private String macdz;
/**
*
*/
private String sbdk;
/**
*
*/
private String jkdwlx;
/**
*
*/
private String sblx;
/**
*
*/
private String sbxs;
/**
*
*/
private String gnlx;
/**
*
*/
private String ywbq;
/**
*
*/
private String jcc;
/**
*
*/
private String sbjd;
/**
*
*/
private String sbwd;
/**
*
*/
private String azdz;
/**
*
*/
private String cjfx;
/**
*
*/
private String sbzt;
/**
*
*/
private String ssgajg;
/**
*
*/
private String jrfs;
/**
*
*/
private String wlbs;
/**
*
*/
private String sbcs;
/**
*
*/
private String azsj;
/**
*
*/
private String ssbmhy;
/**
*
*/
private String dwlx;
/**
*
*/
private String djrxm;
/**
*
*/
private String djrsfzh;
/**
*
*/
private String djrdwdm;
/**
*
*/
private String djrdwmc;
/**
*
*/
private String djsj;
/**
*
*/
private String jrsjl;
/**
*
*/
private String zrsjl;
/**
*
*/
private String j30tsjl;
/**
*
*/
private String j30tjl;
/**
*
*/
private String zxzpsj;
/**
*
*/
private String zxrksj;
/**
*
*/
private String j7tsjl;
/**
*
*/
private String sfzdryj;
/**
*
*/
private String glytbh;
/**
*
*/
private String glksbh;
/**
*
*/
private String sfsdryj;
/**
*
*/
private String sbid;
/**
*
*/
private String sbjc;
/**
*
*/
private String gldl;
/**
*
*/
private String dllx;
/**
*
*/
private String cjqy;
/**
*
*/
private String cjfxlx;
/**
*
*/
private String sbsybh;
/**
*
*/
private String sbbabh;
/**
*
*/
private String sbbazt;
/**
*
*/
private String sbbzmc;
/**
*
*/
private String lkldmc;
/**
*
*/
private String lklddm;
/**
*
*/
private String glxmmc;
/**
*
*/
private String glxmid;
/**
*
*/
private String jczq;
/**
*
*/
private String jckk;
/**
*
*/
private String zpfx;
/**
*
*/
private String gldw;
/**
*
*/
private String lxr;
/**
*
*/
private String lxdh;
/**
*
*/
private String sfjsbryj;
/**
*
*/
private String sfzzrkyj;
// @TableField(exist = false)
// private static final long serialVersionUID = 1L;
}

@ -0,0 +1,25 @@
package com.ssf.mysqloracletest.mapper;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import org.apache.ibatis.annotations.Mapper;
/**
* @author 10503
* @description t_jksbglMapper
* @createDate 2023-11-28 21:07:14
* @Entity com.ssf.mysqloracletest.domain.TJksbgl
*/
@Mapper
public interface TJksbglMysqlMapper {
public TJksbglMysql selectTJksbglById(String id);
public int insertTJksbgl(TJksbglMysql bean);
public int updateTJksbglById(TJksbglMysql bean);
}

@ -0,0 +1,27 @@
package com.ssf.mysqloracletest.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import com.ssf.mysqloracletest.domain.TJksbglOracle;
import com.ssf.mysqloracletest.domain.VSySydzOracle;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
import java.util.Map;
/**
* @author 10503
* @description t_jksbglMapper
* @createDate 2023-11-28 21:07:14
* @Entity com.ssf.mysqloracletest.domain.TJksbgl
*/
@Mapper
public interface TJksbglOracleMapper {
public int countJKsb();
public List<TJksbglOracle> getJKsbList(Map map);
}

@ -0,0 +1,19 @@
package com.ssf.mysqloracletest.service;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ssf.mysqloracletest.domain.VSySydzMysql;
/**
* @author 10503
* @description t_jksbglService
* @createDate 2023-11-28 21:07:14
*/
public interface TJksbglMysqlService {
public TJksbglMysql selectTJksbglById(String id);
public int insertTJksbgl(TJksbglMysql sydz);
public int updateTJksbglById(TJksbglMysql sydz);
}

@ -0,0 +1,20 @@
package com.ssf.mysqloracletest.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import com.ssf.mysqloracletest.domain.TJksbglOracle;
import com.ssf.mysqloracletest.domain.VSySydzOracle;
import java.util.List;
import java.util.Map;
/**
* @author 10503
* @description t_jksbglService
* @createDate 2023-11-28 21:07:14
*/
public interface TJksbglOracleService {
public int countJKsb();
public List<TJksbglOracle> getJKsbList(Map map);
}

@ -0,0 +1,37 @@
package com.ssf.mysqloracletest.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import com.ssf.mysqloracletest.domain.VSySydzMysql;
import com.ssf.mysqloracletest.mapper.TJksbglMysqlMapper;
import com.ssf.mysqloracletest.mapper.VSySydzMysqlMapper;
import com.ssf.mysqloracletest.service.TJksbglMysqlService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
@Service
@DS("mysql")
@RequiredArgsConstructor
public class TJksbglMysqlServiceImpl implements TJksbglMysqlService {
private final TJksbglMysqlMapper tjksbglMysqlMapper;
@Override
public TJksbglMysql selectTJksbglById(String id) {
return tjksbglMysqlMapper.selectTJksbglById(id);
}
@Override
public int insertTJksbgl(TJksbglMysql bean) {
return tjksbglMysqlMapper.insertTJksbgl(bean);
}
@Override
public int updateTJksbglById(TJksbglMysql bean) {
return tjksbglMysqlMapper.updateTJksbglById(bean);
}
}

@ -0,0 +1,43 @@
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.TJksbglMysql;
import com.ssf.mysqloracletest.domain.TJksbglOracle;
import com.ssf.mysqloracletest.domain.VSySydzOracle;
import com.ssf.mysqloracletest.mapper.TJksbglMysqlMapper;
import com.ssf.mysqloracletest.mapper.TJksbglOracleMapper;
import com.ssf.mysqloracletest.mapper.VSySydzOracleMapper;
import com.ssf.mysqloracletest.service.TJksbglMysqlService;
import com.ssf.mysqloracletest.service.TJksbglOracleService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
/**
* @author 10503
* @description t_jksbglService
* @createDate 2023-11-28 21:07:14
*/
@Service
@DS("oracleSydz")
public class TJksbglOracleServiceImpl implements TJksbglOracleService {
@Resource
private TJksbglOracleMapper oracleMapper;
@Override
public int countJKsb(){
return oracleMapper.countJKsb();
}
@Override
public List<TJksbglOracle> getJKsbList(Map map) {
return oracleMapper.getJKsbList(map);
}
}

@ -0,0 +1,114 @@
package com.ssf.mysqloracletest.task;
import com.ssf.mysqloracletest.domain.TJksbglMysql;
import com.ssf.mysqloracletest.domain.TJksbglOracle;
import com.ssf.mysqloracletest.service.TJksbglMysqlService;
import com.ssf.mysqloracletest.service.TJksbglOracleService;
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 TjksbglTask {
private static final Logger logger = LoggerFactory.getLogger(TjksbglTask.class);
@Resource
private TJksbglMysqlService jksbMysqlService;
@Resource
private TJksbglOracleService jksbOracleService;
final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts);
private boolean jksbTag = false;
/**
*
* //
*/
@Scheduled(initialDelay = 100, fixedDelay = 3000)
public void transjksb() {
if (jksbTag) {
return;
}
if (!"true".equals(ConfigParam.jksbSwitch)) {
return;
}
try {
int countjksb = jksbOracleService.countJKsb();
logger.info("countjksb:" + countjksb);
if (countjksb > 0) {
jksbTag = true;
int count = countjksb / oncesCounts;
CountDownLatch latch = new CountDownLatch(count);
ExecutorService jksbPool = Executors.newFixedThreadPool(50);
for (int i = 0; i <= count; i++) {
Map jksbMap = new HashMap();
jksbMap.put("rowStart", i * oncesCounts);
jksbMap.put("rowEnd", (i + 1) * oncesCounts);
jksbPool.submit(() -> {
try {
List<TJksbglOracle> jksbs = jksbOracleService.getJKsbList(jksbMap);
for (TJksbglOracle jksb : jksbs) {
TJksbglMysql sBean = new TJksbglMysql();
BeanUtils.copyProperties(jksb, sBean);
//确定一个数据是否唯一
TJksbglMysql checkjksb = jksbMysqlService.selectTJksbglById(jksb.getId());
if (checkjksb == null) {
jksbMysqlService.insertTJksbgl(sBean);
logger.info("jksb-" + jksb.getId() + ":插入成功");
} else {
jksbMysqlService.updateTJksbglById(sBean);
logger.info("jksb-" + jksb.getId() + ":更新成功");
}
}
} catch (Exception e) {
logger.info("jksbs:" + e.getMessage());
}
latch.countDown();
});
logger.info("jksbMap数据总量:" + countjksb + "," + "当前处理下标:" + jksbMap.get("rowStart") + "/" + jksbMap.get("rowEnd"));
}
try {
// Wait for all threads to complete
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 关闭线程池
jksbPool.shutdown();
}
} catch (Exception e) {
logger.info(StringKit.getTrace(e));
}
}
}

@ -12,4 +12,5 @@ public class ConfigParam {
public static String oncesCounts = StringKit.toString(PropertiesUtil.queryPropertiesByKey("oncesCounts"));
public static String syfwSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("syfwSwitch"));
public static String jksbSwitch = StringKit.toString(PropertiesUtil.queryPropertiesByKey("jksbSwitch"));
}

@ -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://localhost:55306/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,279 @@
<?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.TJksbglMysqlMapper">
<resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TJksbglMysql">
<result property="id" column="ID" jdbcType="VARCHAR"/>
<result property="sbmc" column="SBMC" jdbcType="VARCHAR"/>
<result property="sbbh" column="SBBH" jdbcType="VARCHAR"/>
<result property="ipdz" column="IPDZ" jdbcType="VARCHAR"/>
<result property="macdz" column="MACDZ" jdbcType="VARCHAR"/>
<result property="sbdk" column="SBDK" jdbcType="VARCHAR"/>
<result property="jkdwlx" column="JKDWLX" jdbcType="VARCHAR"/>
<result property="sblx" column="SBLX" jdbcType="VARCHAR"/>
<result property="sbxs" column="SBXS" jdbcType="VARCHAR"/>
<result property="gnlx" column="GNLX" jdbcType="VARCHAR"/>
<result property="ywbq" column="YWBQ" jdbcType="VARCHAR"/>
<result property="jcc" column="JCC" jdbcType="VARCHAR"/>
<result property="sbjd" column="SBJD" jdbcType="VARCHAR"/>
<result property="sbwd" column="SBWD" jdbcType="VARCHAR"/>
<result property="azdz" column="AZDZ" jdbcType="VARCHAR"/>
<result property="cjfx" column="CJFX" jdbcType="VARCHAR"/>
<result property="sbzt" column="SBZT" jdbcType="VARCHAR"/>
<result property="ssgajg" column="SSGAJG" jdbcType="VARCHAR"/>
<result property="jrfs" column="JRFS" jdbcType="VARCHAR"/>
<result property="wlbs" column="WLBS" jdbcType="VARCHAR"/>
<result property="sbcs" column="SBCS" jdbcType="VARCHAR"/>
<result property="azsj" column="AZSJ" jdbcType="VARCHAR"/>
<result property="ssbmhy" column="SSBMHY" jdbcType="VARCHAR"/>
<result property="dwlx" column="DWLX" jdbcType="VARCHAR"/>
<result property="djrxm" column="DJRXM" jdbcType="VARCHAR"/>
<result property="djrsfzh" column="DJRSFZH" jdbcType="VARCHAR"/>
<result property="djrdwdm" column="DJRDWDM" jdbcType="VARCHAR"/>
<result property="djrdwmc" column="DJRDWMC" jdbcType="VARCHAR"/>
<result property="djsj" column="DJSJ" jdbcType="VARCHAR"/>
<result property="jrsjl" column="JRSJL" jdbcType="VARCHAR"/>
<result property="zrsjl" column="ZRSJL" jdbcType="VARCHAR"/>
<result property="j30tsjl" column="J30TSJL" jdbcType="VARCHAR"/>
<result property="j30tjl" column="J30TJL" jdbcType="VARCHAR"/>
<result property="zxzpsj" column="ZXZPSJ" jdbcType="VARCHAR"/>
<result property="zxrksj" column="ZXRKSJ" jdbcType="VARCHAR"/>
<result property="j7tsjl" column="J7TSJL" jdbcType="VARCHAR"/>
<result property="sfzdryj" column="SFZDRYJ" jdbcType="VARCHAR"/>
<result property="glytbh" column="GLYTBH" jdbcType="VARCHAR"/>
<result property="glksbh" column="GLKSBH" jdbcType="VARCHAR"/>
<result property="sfsdryj" column="SFSDRYJ" jdbcType="VARCHAR"/>
<result property="sbid" column="SBID" jdbcType="VARCHAR"/>
<result property="sbjc" column="SBJC" jdbcType="VARCHAR"/>
<result property="gldl" column="GLDL" jdbcType="VARCHAR"/>
<result property="dllx" column="DLLX" jdbcType="VARCHAR"/>
<result property="cjqy" column="CJQY" jdbcType="VARCHAR"/>
<result property="cjfxlx" column="CJFXLX" jdbcType="VARCHAR"/>
<result property="sbsybh" column="SBSYBH" jdbcType="VARCHAR"/>
<result property="sbbabh" column="SBBABH" jdbcType="VARCHAR"/>
<result property="sbbazt" column="SBBAZT" jdbcType="VARCHAR"/>
<result property="sbbzmc" column="SBBZMC" jdbcType="VARCHAR"/>
<result property="lkldmc" column="LKLDMC" jdbcType="VARCHAR"/>
<result property="lklddm" column="LKLDDM" jdbcType="VARCHAR"/>
<result property="glxmmc" column="GLXMMC" jdbcType="VARCHAR"/>
<result property="glxmid" column="GLXMID" jdbcType="VARCHAR"/>
<result property="jczq" column="JCZQ" jdbcType="VARCHAR"/>
<result property="jckk" column="JCKK" jdbcType="VARCHAR"/>
<result property="zpfx" column="ZPFX" jdbcType="VARCHAR"/>
<result property="gldw" column="GLDW" jdbcType="VARCHAR"/>
<result property="lxr" column="LXR" jdbcType="VARCHAR"/>
<result property="lxdh" column="LXDH" jdbcType="VARCHAR"/>
<result property="sfjsbryj" column="SFJSBRYJ" jdbcType="VARCHAR"/>
<result property="sfzzrkyj" column="SFZZRKYJ" jdbcType="VARCHAR"/>
</resultMap>
<select id="selectTJksbglById" parameterType="java.lang.String" resultMap="BaseResultMap">
select * from t_jksbgl
where SBMC = #{SBMC} limit 1
</select>
<insert id="insertTJksbgl" parameterType="com.ssf.mysqloracletest.domain.TJksbglMysql" useGeneratedKeys="true"
keyProperty="id">
insert into t_jksbgl
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null and id != '' ">ID,</if>
<if test="sbmc != null and sbmc != '' ">SBMC,</if>
<if test="sbbh != null and sbbh != '' ">SBBH,</if>
<if test="ipdz != null and ipdz != '' ">IPDZ,</if>
<if test="macdz != null and macdz != '' ">MACDZ,</if>
<if test="sbdk != null and sbdk != '' ">SBDK,</if>
<if test="jkdwlx != null and jkdwlx != '' ">JKDWLX,</if>
<if test="sblx != null and sblx != '' ">SBLX,</if>
<if test="sbxs != null and sbxs != '' ">SBXS,</if>
<if test="gnlx != null and gnlx != '' ">GNLX,</if>
<if test="ywbq != null and ywbq != '' ">YWBQ,</if>
<if test="jcc != null and jcc != '' ">JCC,</if>
<if test="sbjd != null and sbjd != '' ">SBJD,</if>
<if test="sbwd != null and sbwd != '' ">SBWD,</if>
<if test="azdz != null and azdz != '' ">AZDZ,</if>
<if test="cjfx != null and cjfx != '' ">CJFX,</if>
<if test="sbzt != null and sbzt != '' ">SBZT,</if>
<if test="ssgajg != null and ssgajg != '' ">SSGAJG,</if>
<if test="jrfs != null and jrfs != '' ">JRFS,</if>
<if test="wlbs != null and wlbs != '' ">WLBS,</if>
<if test="sbcs != null and sbcs != '' ">SBCS,</if>
<if test="azsj != null and azsj != '' ">AZSJ,</if>
<if test="ssbmhy != null and ssbmhy != '' ">SSBMHY,</if>
<if test="dwlx != null and dwlx != '' ">DWLX,</if>
<if test="djrxm != null and djrxm != '' ">DJRXM,</if>
<if test="djrsfzh != null and djrsfzh != '' ">DJRSFZH,</if>
<if test="djrdwdm != null and djrdwdm != '' ">DJRDWDM,</if>
<if test="djrdwmc != null and djrdwmc != '' ">DJRDWMC,</if>
<if test="djsj != null and djsj != '' ">DJSJ,</if>
<if test="jrsjl != null and jrsjl != '' ">JRSJL,</if>
<if test="zrsjl != null and zrsjl != '' ">ZRSJL,</if>
<if test="j30tsjl != null and j30tsjl != '' ">J30TSJL,</if>
<if test="j30tjl != null and j30tjl != '' ">J30TJL,</if>
<if test="zxzpsj != null and zxzpsj != '' ">ZXZPSJ,</if>
<if test="zxrksj != null and zxrksj != '' ">ZXRKSJ,</if>
<if test="j7tsjl != null and j7tsjl != '' ">J7TSJL,</if>
<if test="sfzdryj != null and sfzdryj != '' ">SFZDRYJ,</if>
<if test="glytbh != null and glytbh != '' ">GLYTBH,</if>
<if test="glksbh != null and glksbh != '' ">GLKSBH,</if>
<if test="sfsdryj != null and sfsdryj != '' ">SFSDRYJ,</if>
<if test="sbid != null and sbid != '' ">SBID,</if>
<if test="sbjc != null and sbjc != '' ">SBJC,</if>
<if test="gldl != null and gldl != '' ">GLDL,</if>
<if test="dllx != null and dllx != '' ">DLLX,</if>
<if test="cjqy != null and cjqy != '' ">CJQY,</if>
<if test="cjfxlx != null and cjfxlx != '' ">CJFXLX,</if>
<if test="sbsybh != null and sbsybh != '' ">SBSYBH,</if>
<if test="sbbabh != null and sbbabh != '' ">SBBABH,</if>
<if test="sbbazt != null and sbbazt != '' ">SBBAZT,</if>
<if test="sbbzmc != null and sbbzmc != '' ">SBBZMC,</if>
<if test="lkldmc != null and lkldmc != '' ">LKLDMC,</if>
<if test="lklddm != null and lklddm != '' ">LKLDDM,</if>
<if test="glxmmc != null and glxmmc != '' ">GLXMMC,</if>
<if test="glxmid != null and glxmid != '' ">GLXMID,</if>
<if test="jczq != null and jczq != '' ">JCZQ,</if>
<if test="jckk != null and jckk != '' ">JCKK,</if>
<if test="zpfx != null and zpfx != '' ">ZPFX,</if>
<if test="gldw != null and gldw != '' ">GLDW,</if>
<if test="lxr != null and lxr != '' ">LXR,</if>
<if test="lxdh != null and lxdh != '' ">LXDH,</if>
<if test="sfjsbryj != null and sfjsbryj != '' ">SFJSBRYJ,</if>
<if test="sfzzrkyj != null and sfzzrkyj != '' ">SFZZRKYJ,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null and id != '' ">#{ID},</if>
<if test="sbmc != null and sbmc != '' ">#{SBMC},</if>
<if test="sbbh != null and sbbh != '' ">#{SBBH},</if>
<if test="ipdz != null and ipdz != '' ">#{IPDZ},</if>
<if test="macdz != null and macdz != '' ">#{MACDZ},</if>
<if test="sbdk != null and sbdk != '' ">#{SBDK},</if>
<if test="jkdwlx != null and jkdwlx != '' ">#{JKDWLX},</if>
<if test="sblx != null and sblx != '' ">#{SBLX},</if>
<if test="sbxs != null and sbxs != '' ">#{SBXS},</if>
<if test="gnlx != null and gnlx != '' ">#{GNLX},</if>
<if test="ywbq != null and ywbq != '' ">#{YWBQ},</if>
<if test="jcc != null and jcc != '' ">#{JCC},</if>
<if test="sbjd != null and sbjd != '' ">#{SBJD},</if>
<if test="sbwd != null and sbwd != '' ">#{SBWD},</if>
<if test="azdz != null and azdz != '' ">#{AZDZ},</if>
<if test="cjfx != null and cjfx != '' ">#{CJFX},</if>
<if test="sbzt != null and sbzt != '' ">#{SBZT},</if>
<if test="ssgajg != null and ssgajg != '' ">#{SSGAJG},</if>
<if test="jrfs != null and jrfs != '' ">#{JRFS},</if>
<if test="wlbs != null and wlbs != '' ">#{WLBS},</if>
<if test="sbcs != null and sbcs != '' ">#{SBCS},</if>
<if test="azsj != null and azsj != '' ">#{AZSJ},</if>
<if test="ssbmhy != null and ssbmhy != '' ">#{SSBMHY},</if>
<if test="dwlx != null and dwlx != '' ">#{DWLX},</if>
<if test="djrxm != null and djrxm != '' ">#{DJRXM},</if>
<if test="djrsfzh != null and djrsfzh != '' ">#{DJRSFZH},</if>
<if test="djrdwdm != null and djrdwdm != '' ">#{DJRDWDM},</if>
<if test="djrdwmc != null and djrdwmc != '' ">#{DJRDWMC},</if>
<if test="djsj != null and djsj != '' ">#{DJSJ},</if>
<if test="jrsjl != null and jrsjl != '' ">#{JRSJL},</if>
<if test="zrsjl != null and zrsjl != '' ">#{ZRSJL},</if>
<if test="j30tsjl != null and j30tsjl != '' ">#{J30TSJL},</if>
<if test="j30tjl != null and j30tjl != '' ">#{J30TJL},</if>
<if test="zxzpsj != null and zxzpsj != '' ">#{ZXZPSJ},</if>
<if test="zxrksj != null and zxrksj != '' ">#{ZXRKSJ},</if>
<if test="j7tsjl != null and j7tsjl != '' ">#{J7TSJL},</if>
<if test="sfzdryj != null and sfzdryj != '' ">#{SFZDRYJ},</if>
<if test="glytbh != null and glytbh != '' ">#{GLYTBH},</if>
<if test="glksbh != null and glksbh != '' ">#{GLKSBH},</if>
<if test="sfsdryj != null and sfsdryj != '' ">#{SFSDRYJ},</if>
<if test="sbid != null and sbid != '' ">#{SBID},</if>
<if test="sbjc != null and sbjc != '' ">#{SBJC},</if>
<if test="gldl != null and gldl != '' ">#{GLDL},</if>
<if test="dllx != null and dllx != '' ">#{DLLX},</if>
<if test="cjqy != null and cjqy != '' ">#{CJQY},</if>
<if test="cjfxlx != null and cjfxlx != '' ">#{CJFXLX},</if>
<if test="sbsybh != null and sbsybh != '' ">#{SBSYBH},</if>
<if test="sbbabh != null and sbbabh != '' ">#{SBBABH},</if>
<if test="sbbazt != null and sbbazt != '' ">#{SBBAZT},</if>
<if test="sbbzmc != null and sbbzmc != '' ">#{SBBZMC},</if>
<if test="lkldmc != null and lkldmc != '' ">#{LKLDMC},</if>
<if test="lklddm != null and lklddm != '' ">#{LKLDDM},</if>
<if test="glxmmc != null and glxmmc != '' ">#{GLXMMC},</if>
<if test="glxmid != null and glxmid != '' ">#{GLXMID},</if>
<if test="jczq != null and jczq != '' ">#{JCZQ},</if>
<if test="jckk != null and jckk != '' ">#{JCKK},</if>
<if test="zpfx != null and zpfx != '' ">#{ZPFX},</if>
<if test="gldw != null and gldw != '' ">#{GLDW},</if>
<if test="lxr != null and lxr != '' ">#{LXR},</if>
<if test="lxdh != null and lxdh != '' ">#{LXDH},</if>
<if test="sfjsbryj != null and sfjsbryj != '' ">#{SFJSBRYJ},</if>
<if test="sfzzrkyj != null and sfzzrkyj != '' ">#{SFZZRKYJ},</if>
</trim>
</insert>
<update id="updateTJksbglById" parameterType="com.ssf.mysqloracletest.domain.TJksbglMysql">
update t_jksbgl
<trim prefix="SET" suffixOverrides=",">
<if test="id != null and id != '' ">ID=#{ID},</if>
<if test="sbmc != null and sbmc != '' ">SBMC=#{SBMC},</if>
<if test="sbbh != null and sbbh != '' ">SBBH=#{SBBH},</if>
<if test="ipdz != null and ipdz != '' ">IPDZ=#{IPDZ},</if>
<if test="macdz != null and macdz != '' ">MACDZ=#{MACDZ},</if>
<if test="sbdk != null and sbdk != '' ">SBDK=#{SBDK},</if>
<if test="jkdwlx != null and jkdwlx != '' ">JKDWLX=#{JKDWLX},</if>
<if test="sblx != null and sblx != '' ">SBLX=#{SBLX},</if>
<if test="sbxs != null and sbxs != '' ">SBXS=#{SBXS},</if>
<if test="gnlx != null and gnlx != '' ">GNLX=#{GNLX},</if>
<if test="ywbq != null and ywbq != '' ">YWBQ=#{YWBQ},</if>
<if test="jcc != null and jcc != '' ">JCC=#{JCC},</if>
<if test="sbjd != null and sbjd != '' ">SBJD=#{SBJD},</if>
<if test="sbwd != null and sbwd != '' ">SBWD=#{SBWD},</if>
<if test="azdz != null and azdz != '' ">AZDZ=#{AZDZ},</if>
<if test="cjfx != null and cjfx != '' ">CJFX=#{CJFX},</if>
<if test="sbzt != null and sbzt != '' ">SBZT=#{SBZT},</if>
<if test="ssgajg != null and ssgajg != '' ">SSGAJG=#{SSGAJG},</if>
<if test="jrfs != null and jrfs != '' ">JRFS=#{JRFS},</if>
<if test="wlbs != null and wlbs != '' ">WLBS=#{WLBS},</if>
<if test="sbcs != null and sbcs != '' ">SBCS=#{SBCS},</if>
<if test="azsj != null and azsj != '' ">AZSJ=#{AZSJ},</if>
<if test="ssbmhy != null and ssbmhy != '' ">SSBMHY=#{SSBMHY},</if>
<if test="dwlx != null and dwlx != '' ">DWLX=#{DWLX},</if>
<if test="djrxm != null and djrxm != '' ">DJRXM=#{DJRXM},</if>
<if test="djrsfzh != null and djrsfzh != '' ">DJRSFZH=#{DJRSFZH},</if>
<if test="djrdwdm != null and djrdwdm != '' ">DJRDWDM=#{DJRDWDM},</if>
<if test="djrdwmc != null and djrdwmc != '' ">DJRDWMC=#{DJRDWMC},</if>
<if test="djsj != null and djsj != '' ">DJSJ=#{DJSJ},</if>
<if test="jrsjl != null and jrsjl != '' ">JRSJL=#{JRSJL},</if>
<if test="zrsjl != null and zrsjl != '' ">ZRSJL=#{ZRSJL},</if>
<if test="j30tsjl != null and j30tsjl != '' ">J30TSJL=#{J30TSJL},</if>
<if test="j30tjl != null and j30tjl != '' ">J30TJL=#{J30TJL},</if>
<if test="zxzpsj != null and zxzpsj != '' ">ZXZPSJ=#{ZXZPSJ},</if>
<if test="zxrksj != null and zxrksj != '' ">ZXRKSJ=#{ZXRKSJ},</if>
<if test="j7tsjl != null and j7tsjl != '' ">J7TSJL=#{J7TSJL},</if>
<if test="sfzdryj != null and sfzdryj != '' ">SFZDRYJ=#{SFZDRYJ},</if>
<if test="glytbh != null and glytbh != '' ">GLYTBH=#{GLYTBH},</if>
<if test="glksbh != null and glksbh != '' ">GLKSBH=#{GLKSBH},</if>
<if test="sfsdryj != null and sfsdryj != '' ">SFSDRYJ=#{SFSDRYJ},</if>
<if test="sbid != null and sbid != '' ">SBID=#{SBID},</if>
<if test="sbjc != null and sbjc != '' ">SBJC=#{SBJC},</if>
<if test="gldl != null and gldl != '' ">GLDL=#{GLDL},</if>
<if test="dllx != null and dllx != '' ">DLLX=#{DLLX},</if>
<if test="cjqy != null and cjqy != '' ">CJQY=#{CJQY},</if>
<if test="cjfxlx != null and cjfxlx != '' ">CJFXLX=#{CJFXLX},</if>
<if test="sbsybh != null and sbsybh != '' ">SBSYBH=#{SBSYBH},</if>
<if test="sbbabh != null and sbbabh != '' ">SBBABH=#{SBBABH},</if>
<if test="sbbazt != null and sbbazt != '' ">SBBAZT=#{SBBAZT},</if>
<if test="sbbzmc != null and sbbzmc != '' ">SBBZMC=#{SBBZMC},</if>
<if test="lkldmc != null and lkldmc != '' ">LKLDMC=#{LKLDMC},</if>
<if test="lklddm != null and lklddm != '' ">LKLDDM=#{LKLDDM},</if>
<if test="glxmmc != null and glxmmc != '' ">GLXMMC=#{GLXMMC},</if>
<if test="glxmid != null and glxmid != '' ">GLXMID=#{GLXMID},</if>
<if test="jczq != null and jczq != '' ">JCZQ=#{JCZQ},</if>
<if test="jckk != null and jckk != '' ">JCKK=#{JCKK},</if>
<if test="zpfx != null and zpfx != '' ">ZPFX=#{ZPFX},</if>
<if test="gldw != null and gldw != '' ">GLDW=#{GLDW},</if>
<if test="lxr != null and lxr != '' ">LXR=#{LXR},</if>
<if test="lxdh != null and lxdh != '' ">LXDH=#{LXDH},</if>
<if test="sfjsbryj != null and sfjsbryj != '' ">SFJSBRYJ=#{SFJSBRYJ},</if>
<if test="sfzzrkyj != null and sfzzrkyj != '' ">SFZZRKYH=#{SFZZRKYJ},</if>
</trim>
where SBMC = #{SBMC}
</update>
</mapper>

@ -0,0 +1,82 @@
<?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.TJksbglOracleMapper">
<select id="countJKsb" resultType="int">
select count(*)
from SYX_JWYSJ.T_JKSBGL
</select>
<resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TJksbglMysql">
<result property="id" column="ID" jdbcType="VARCHAR"/>
<result property="sbmc" column="SBMC" jdbcType="VARCHAR"/>
<result property="sbbh" column="SBBH" jdbcType="VARCHAR"/>
<result property="ipdz" column="IPDZ" jdbcType="VARCHAR"/>
<result property="macdz" column="MACDZ" jdbcType="VARCHAR"/>
<result property="sbdk" column="SBDK" jdbcType="VARCHAR"/>
<result property="jkdwlx" column="JKDWLX" jdbcType="VARCHAR"/>
<result property="sblx" column="SBLX" jdbcType="VARCHAR"/>
<result property="sbxs" column="SBXS" jdbcType="VARCHAR"/>
<result property="gnlx" column="GNLX" jdbcType="VARCHAR"/>
<result property="ywbq" column="YWBQ" jdbcType="VARCHAR"/>
<result property="jcc" column="JCC" jdbcType="VARCHAR"/>
<result property="sbjd" column="SBJD" jdbcType="VARCHAR"/>
<result property="sbwd" column="SBWD" jdbcType="VARCHAR"/>
<result property="azdz" column="AZDZ" jdbcType="VARCHAR"/>
<result property="cjfx" column="CJFX" jdbcType="VARCHAR"/>
<result property="sbzt" column="SBZT" jdbcType="VARCHAR"/>
<result property="ssgajg" column="SSGAJG" jdbcType="VARCHAR"/>
<result property="jrfs" column="JRFS" jdbcType="VARCHAR"/>
<result property="wlbs" column="WLBS" jdbcType="VARCHAR"/>
<result property="sbcs" column="SBCS" jdbcType="VARCHAR"/>
<result property="azsj" column="AZSJ" jdbcType="VARCHAR"/>
<result property="ssbmhy" column="SSBMHY" jdbcType="VARCHAR"/>
<result property="dwlx" column="DWLX" jdbcType="VARCHAR"/>
<result property="djrxm" column="DJRXM" jdbcType="VARCHAR"/>
<result property="djrsfzh" column="DJRSFZH" jdbcType="VARCHAR"/>
<result property="djrdwdm" column="DJRDWDM" jdbcType="VARCHAR"/>
<result property="djrdwmc" column="DJRDWMC" jdbcType="VARCHAR"/>
<result property="djsj" column="DJSJ" jdbcType="VARCHAR"/>
<result property="jrsjl" column="JRSJL" jdbcType="VARCHAR"/>
<result property="zrsjl" column="ZRSJL" jdbcType="VARCHAR"/>
<result property="j30tsjl" column="J30TSJL" jdbcType="VARCHAR"/>
<result property="j30tjl" column="J30TJL" jdbcType="VARCHAR"/>
<result property="zxzpsj" column="ZXZPSJ" jdbcType="VARCHAR"/>
<result property="zxrksj" column="ZXRKSJ" jdbcType="VARCHAR"/>
<result property="j7tsjl" column="J7TSJL" jdbcType="VARCHAR"/>
<result property="sfzdryj" column="SFZDRYJ" jdbcType="VARCHAR"/>
<result property="glytbh" column="GLYTBH" jdbcType="VARCHAR"/>
<result property="glksbh" column="GLKSBH" jdbcType="VARCHAR"/>
<result property="sfsdryj" column="SFSDRYJ" jdbcType="VARCHAR"/>
<result property="sbid" column="SBID" jdbcType="VARCHAR"/>
<result property="sbjc" column="SBJC" jdbcType="VARCHAR"/>
<result property="gldl" column="GLDL" jdbcType="VARCHAR"/>
<result property="dllx" column="DLLX" jdbcType="VARCHAR"/>
<result property="cjqy" column="CJQY" jdbcType="VARCHAR"/>
<result property="cjfxlx" column="CJFXLX" jdbcType="VARCHAR"/>
<result property="sbsybh" column="SBSYBH" jdbcType="VARCHAR"/>
<result property="sbbabh" column="SBBABH" jdbcType="VARCHAR"/>
<result property="sbbazt" column="SBBAZT" jdbcType="VARCHAR"/>
<result property="sbbzmc" column="SBBZMC" jdbcType="VARCHAR"/>
<result property="lkldmc" column="LKLDMC" jdbcType="VARCHAR"/>
<result property="lklddm" column="LKLDDM" jdbcType="VARCHAR"/>
<result property="glxmmc" column="GLXMMC" jdbcType="VARCHAR"/>
<result property="glxmid" column="GLXMID" jdbcType="VARCHAR"/>
<result property="jczq" column="JCZQ" jdbcType="VARCHAR"/>
<result property="jckk" column="JCKK" jdbcType="VARCHAR"/>
<result property="zpfx" column="ZPFX" jdbcType="VARCHAR"/>
<result property="gldw" column="GLDW" jdbcType="VARCHAR"/>
<result property="lxr" column="LXR" jdbcType="VARCHAR"/>
<result property="lxdh" column="LXDH" jdbcType="VARCHAR"/>
<result property="sfjsbryj" column="SFJSBRYJ" jdbcType="VARCHAR"/>
<result property="sfzzrkyj" column="SFZZRKYJ" jdbcType="VARCHAR"/>
</resultMap>
<select id="getJKsbList" parameterType="java.util.Map" resultMap="BaseResultMap">
SELECT t2.*
FROM (SELECT ROWNUM rn, t1.* FROM (SELECT * FROM SYX_JWYSJ.T_JKSBGL) t1 WHERE ROWNUM<![CDATA[ <= ]]> ${rowEnd}) t2
WHERE t2.rn <![CDATA[ >= ]]> ${rowStart}
</select>
</mapper>

@ -18,6 +18,7 @@
<result property="DZYSID" column="DZYSID"/>
</resultMap>
<select id="getSydzList" parameterType="java.util.Map" resultMap="SydzResult">
SELECT t2.*
FROM (SELECT ROWNUM rn, t1.* FROM (SELECT * FROM SYX_JWYSJ.V_SY_SYDZ) t1 WHERE ROWNUM<![CDATA[ <= ]]> ${rowEnd}) t2

Loading…
Cancel
Save