回滚到fisrt()时注意使用next()时需要将光标移到第一行之前使用previous();packagecom.trs.util;www.2cto.comimportjava.util.Calendar;importjava.util.Date;importjava.util.Properties;impor...
回滚到fisrt()时注意使用next()时需要将光标移到第一行之前 使用previous();
package com.trs.util;
www.2cto.com
import java.util.Calendar;
import java.util.Date;
import java.util.Properties;
import java.sql.Connection;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import org.apache.log4j.Logger;
import com.trs.client.TRSConnection;
import com.trs.client.TRSResultSet;
import com.trs.dao.oracleDao;
import com.trs.dao.trsDao;
public class checkTest {
private static Logger CheckTRSLogger = Logger.getLogger("CheckTRSLogger");
public static void check(){
Date dateSta = null; //时间段起始
Date dateEnd = null; //时间段结束
Date dateComp = null; //总时间截止
Calendar calSta=Calendar.getInstance();
Calendar calEnd=Calendar.getInstance();
Calendar calComp=Calendar.getInstance();
String calStaString = ""; www.2cto.com
String calEndString = "";
TRSConnection trsCon = null;
TRSResultSet trsRs = null;
Connection oraCon = null;
ResultSet oracleRs = null;
String table = "";//oracle中检索的表名
String tableTem = "";//oracle中临时的表名
String tableRecord =""; //记录遗漏的记录
String column_oracle1 = "";//oracel中检索的关键字段
String column_oracle2 = "";//oracel中检索的字段
String host = "";//trs
数据库ip
String port = "";//trs数据库端口
String username = "";//trs数据库用户名
String password = "";//trs数据库密码
String library = "";//trs数据库中检索库名
String column_trs1 = "";//trs数据库中检索字段名
String column_trs2 = "";//trs数据库中关键字段名
int trsNum = 0; //TRS记录数量
int oracleNum = 0; //
Oracle 记录数量
try {
DBUtil.loadProperties("oracleconfig.properties");
} catch (Exception e2) { www.2cto.com
e2.printStackTrace();
CheckTRSLogger.error(e2.getMessage());
}
table = DBUtil.getConfigInfo("table");
tableTem = DBUtil.getConfigInfo("tableTem");
tableRecord = DBUtil.getConfigInfo("tableRecord");
column_oracle1 = DBUtil.getConfigInfo("column_oracle1");
column_oracle2 = DBUtil.getConfigInfo("column_oracle2");
try {
DBUtil.loadProperties("trsconfig.properties");
} catch (Exception e2) {
e2.printStackTrace();
CheckTRSLogger.error(e2.getMessage());
}
host = DBUtil.getConfigInfo("host");//trs数据库ip
port = DBUtil.getConfigInfo("port");//trs数据库端口
username = DBUtil.getConfigInfo("username");//trs数据库用户名
password = DBUtil.getConfigInfo("password");//trs数据库密码
library = DBUtil.getConfigInfo("library");//trs数据库中检索库名
column_trs1 = DBUtil.getConfigInfo("column1");//trs数据库中检索字段名
column_trs2 = DBUtil.getConfigInfo("column2");//trs数据库中检索关键字段名 ID
try {
DBUtil.loadProperties("timeLimits.properties");
} catch (Exception e2) {
e2.printStackTrace();
CheckTRSLogger.error(e2.getMessage());
}
String dateStaString = DBUtil.getConfigInfo("DateSta");
String dateEndString = DBUtil.getConfigInfo("dateEnd");
String dateCompString = DBUtil.getConfigInfo("dateComp");
String dataFormate = "yyyy.MM.dd HH:mm:ss"; www.2cto.com
SimpleDateFormat dateformat = new SimpleDateFormat(dataFormate);
try{
dateSta = dateformat.parse(dateStaString);
dateEnd = dateformat.parse(dateEndString);
dateComp = dateformat.parse(dateCompString);
calSta.setTime(dateSta);
calEnd.setTime(dateEnd);
calComp.setTime(dateComp);
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}
int dayNum =(calEnd.get(Calendar.YEAR)-calSta.get(Calendar.YEAR))*365
+calEnd.get(Calendar.DAY_OF_YEAR)-calSta.get(Calendar.DAY_OF_YEAR);
String calCompString = dateformat.format(calComp.getTime());
//时间量小于截止时间执行比对程序
while(calEnd.before(calComp)){
calStaString = dateformat.format(calSta.getTime());
calEndString = dateformat.format(calEnd.getTime());
try{
trsCon = trsDao.getTRSConnection(host, port, username, password);
trsRs = trsDao.readTRS(trsCon, library, column_trs1, calStaString, calEndString);
trsNum = (int)trsRs.getRecordCount();
CheckTRSLogger.info("此时间段"+calStaString+"-----"+calEndString+"TRS记录量"+trsNum);
oraCon = oracleDao.getOracleConnection();
oracleRs = oracleDao.readOracle(oraCon, table, column_oracle1,column_oracle2, calStaString, calEndString);
oracleRs.last(); www.2cto.com
oracleNum = oracleRs.getRow();
oracleRs.first();
oracleRs.previous();
if(oracleNum>trsNum){
if(trsNum>0){
for (int i = 0; i
{
trsRs.moveTo(0, i);
String columnValue = trsRs.getString(column_trs2);
oracleDao.insertOracle(oraCon,tableTem,column_oracle1,columnValue);
}
try{
trsRs.close();
trsCon.close();
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}
while(oracleRs.next()){
String temColumnValue = oracleRs.getString(column_oracle1);
if(!oracleDao.isExt(oraCon,tableTem,column_oracle1,temColumnValue)){
oracleDao.insertOracle(oraCon ,tableRecord,column_oracle1,temColumnValue);
}
}
oracleDao.deleteOracle(oraCon,tableTem);
}else{
while(oracleRs.next()){
String temColumnValue1 = oracleRs.getString(column_oracle1);
oracleDao.insertOracle(oraCon ,tableRecord,column_oracle1,temColumnValue1);
} www.2cto.com
}
}
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}finally{
try{
oracleRs.close();
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}
try{
oraCon.close();
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}
try{
trsRs.close();
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}
try{
trsCon.close();
}catch(Exception e){
e.printStackTrace();
CheckTRSLogger.error(e.getMessage());
}
} www.2cto.com
CheckTRSLogger.info("已对比的时间段："+calStaString+"----------"+calEndString);
calSta = (Calendar)calEnd.clone();
calEnd.add(Calendar.DAY_OF_YEAR, dayNum);
}
}
}
作者 ygsilence
推荐阅读
-
本文详细介绍了 Java 中 org.apache.xmlbeans.SchemaType 类的 getBaseEnumType() 方法，提供了多个代码示例，并解释了其在不同场景下的使用方法。 ...
[详细]
蜡笔小新 2024-12-26 11:46:55
-
本文详细介绍了如何在ECharts中使用线性渐变色，通过echarts.graphic.LinearGradient方法实现。文章不仅提供了完整的代码示例，还解释了各个参数的具体含义及其应用场景。 ...
[详细]
蜡笔小新 2024-12-26 08:13:53
-
-
本文详细介绍了如何解决MyBatis中常见的BindingException错误，提供了多种排查和修复方法，确保Mapper接口与XML文件的正确配置。 ...
[详细]
蜡笔小新 2024-12-25 19:42:47
-
在处理Java项目中的JAR包冲突时，我们遇到了JaxWsDynamicClientFactory被弃用的问题，并成功将其迁移到org.codehaus.xfire.client。本文详细介绍了这一过程及解决方案。 ...
[详细]
蜡笔小新 2024-12-25 18:48:34
-
本文详细介绍了Linux系统中init进程的作用及其启动过程，解释了运行级别的概念，并提供了调整服务启动顺序的具体步骤和实例。通过了解这些内容，用户可以更好地管理系统的启动流程和服务配置。 ...
[详细]
蜡笔小新 2024-12-25 16:16:05
-
本文详细介绍了 Apache Shiro，一个强大且灵活的开源安全框架。Shiro 专注于简化身份验证、授权、会话管理和加密等复杂的安全操作，使开发者能够更轻松地保护应用程序。其核心目标是提供易于使用和理解的API，同时确保高度的安全性和灵活性。 ...
[详细]
蜡笔小新 2024-12-25 16:03:57
-
探讨了小型企业在构建安全网络和软件时所面临的挑战和机遇。本文介绍了如何通过合理的方法和工具，确保小型企业能够有效提升其软件的安全性，从而保护客户数据并增强市场竞争力。 ...
[详细]
蜡笔小新 2024-12-25 12:19:50
-
本文详细介绍了如何准备和安装 Eclipse 开发环境及其相关插件，包括 JDK、Tomcat、Struts 等组件的安装步骤及配置方法。 ...
[详细]
蜡笔小新 2024-12-24 19:47:22
-
本文深入探讨了HBase常用的运维工具，详细介绍了每种工具的功能、使用场景及操作示例。对于HBase的开发人员和运维工程师来说，这些工具是日常管理和故障排查的重要手段。 ...
[详细]
蜡笔小新 2024-12-24 17:00:59
-
在本周的白板演练中，Apache Flink 的 PMC 成员及数据工匠首席技术官 Stephan Ewen 深入探讨了如何利用保存点功能进行流处理中的数据重新处理、错误修复、系统升级和 A/B 测试。本文将详细解释保存点的工作原理及其应用场景。 ...
[详细]
蜡笔小新 2024-12-24 16:57:24
-
本文详细介绍了 Java 中 org.apache.qpid.server.model.VirtualHost 类的 closeAsync() 方法，提供了具体的代码示例和应用场景。通过这些示例，读者可以更好地理解和使用该方法。 ...
[详细]
蜡笔小新 2024-12-24 16:23:01
-
本文详细介绍了 Flink 和 YARN 的交互机制。YARN 是 Hadoop 生态系统中的资源管理组件，类似于 Spark on YARN 的配置方式。我们将基于官方文档，深入探讨如何在 YARN 上部署和运行 Flink 任务。 ...
[详细]
蜡笔小新 2024-12-24 11:15:38
-
本文详细介绍如何通过修改配置文件来隐藏Apache、Nginx和PHP的版本号，从而增强网站的安全性。我们将提供具体的配置步骤，并解释这些设置的重要性。 ...
[详细]
蜡笔小新 2024-12-24 10:21:12
-
本文详细介绍如何利用已搭建的LAMP（Linux、Apache、MySQL、PHP）环境，快速创建一个基于WordPress的内容管理系统（CMS）。WordPress是一款流行的开源博客平台，适用于个人或小型团队使用。 ...
[详细]
蜡笔小新 2024-12-23 20:23:57
-
本文详细介绍了Java中org.apache.logging.log4j.spi.AbstractLogger类的logIfEnabled()方法，包括其功能、参数说明及实际代码示例。通过这些示例，读者可以更好地掌握如何在项目中使用该方法进行日志记录。 ...
[详细]
蜡笔小新 2024-12-23 19:58:12
-
京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有