sourcethread.java

一个简单的数据库同步系统

package com.unimas.dbsync.input;


import com.unimas.dbsync.entity.SourceTabBaseBean;

import java.io.IOException;

/**
 * Created by IntelliJ IDEA.
 * User: 孔加亮
 * Date: 2008-12-9
 * Time: 9:05:26.
 */

/**
 * 源端线程
 */
public class SourceThread extends Thread {
    public void run() {
        while (true) {
            try {
                SourceTabBaseBean bean = new SourceTabBaseBean();
                GetRecordsFromDb getRecordsFromDb = new GetRecordsFromDb();
                getRecordsFromDb.getStuInf(bean);
                InputFile.inputFile(bean);
                Thread.sleep(60 * 1000);
            } catch (InterruptedException e) {
                System.out.println("源端端线程启动不正常");
            }catch(IOException e){
                e.printStackTrace();
            }
        }
    }
}