picktask.java

定时将.txt数据导入mssql数据库。TestAutoRun.java文件为第一个调用文件。

package myseverlet;

import java.io.IOException;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.Timer;
import java.util.TimerTask;

/**
 * 定时将oracle数据导入mysql
 * 
 * 时间间隔一小时
 * 
 * 
 * @author zhyh
 * 
 */
class PickTask {
	private Timer timer;

	private String todayDateTime;

	private String hour;
	private String mi;

	public PickTask() {
		timer = new Timer();
	}

	/**
	 * 每天零点将mysql nowflash表数据读入mysql flashdata2008表
	 * 
	 * 每隔一个小时将oracle nowflash表中的数据导入 mysql nowflash表中
	 * 
	 */
	private TimerTask task = new TimerTask() {
		public void run() {
		
		System.out.println("Console is started !!!!!");	

/**
 * 将oracle 数据库内容定时读入mysql数据库
 * 
 */
//			System.out.println("TimerTask run is in");
//			todayDateTime = new Timestamp(System.currentTimeMillis())
//					.toString();
//			hour = todayDateTime.substring(11, 13);
//			System.out.println("todayDateTime=====" + todayDateTime);
//			mi = todayDateTime.substring(14, 16);
//
//			// 每天零点将数据读入flashdata2008表
//			if (hour.equals("00")) {
//				System.out.println("将数据读入flashdata2008 is in");
//				NowFlashToFlashData nowFlashToFlashData = new NowFlashToFlashData();
//				System.out.println("todayDateTime.substring(0,10)"
//						+ todayDateTime.substring(0, 10));
//				try {
//					nowFlashToFlashData.transDb(todayDateTime.substring(0, 10));
//				} catch (InstantiationException e) {
//					e.printStackTrace();
//				} catch (IllegalAccessException e) {
//					e.printStackTrace();
//				} catch (ClassNotFoundException e) {
//					e.printStackTrace();
//				} catch (SQLException e) {
//					e.printStackTrace();
//				}
//			}
//			
//			// 每隔一个小时将oracle nowflash表中的数据导入 mysql nowflash表中
//			OracleToMysql oracleToMysql = new OracleToMysql();
//			oracleToMysql.transDb();
//			System.out.println("TimerTask run is out");
		
//		ReadLocalTxt readLocalTxt = new ReadLocalTxt();
//		try {
//			readLocalTxt.run();
//		} catch (IOException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
			
			/**
			 * 将.txt文件中数据定时读入MsSql
			 * 
			 */
//			ReadTxtData readTxtData = new ReadTxtData();
//			try {
//				readTxtData.readRun();
//			} catch (Exception e) {
//				String todayDateTime = new Timestamp(System.currentTimeMillis()).toString();
//				String today = todayDateTime.substring(0,10);
//				String logMsg = "classes Name: TimerTask.java line 84" + e.getMessage() + "    " +todayDateTime;
//				LogPrint.logWrite("d:\\log\\error\\error" + today +".txt",logMsg);
//				e.printStackTrace();
//			}
			
		    ReadTxtDataBatch readTxtDataBatch = new ReadTxtDataBatch();
		    try {
				readTxtDataBatch.readRun();
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
	};
    
	/**
	 * 设定每隔多长时间运行程序
	 * 
	 * @param delay 开始时间
	 * @param internal 间隔时间
	 */
	public void start(int delay, int internal) {
		timer.schedule(task, delay * 1000, internal * 1000);
	}

}