dbrun.java

对数据库中的信息进行撮合匹配

package com.cuohe.dblic;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

import com.cuohe.dbconnect.Dbconn;
import com.cuohe.dbwork.DbDelete;

public class DbRun {
		public static void main(String[] args) throws Exception{
			try{
				int runtag = 1;
				Dbconn dbconnect = new Dbconn();
				Connection conn = dbconnect.Dbconnect();
				ResultSet res;
				
				while(runtag == 1)
				{ 
//					取得系统时间
					DateFormat df = new SimpleDateFormat("HHmmss");
			        String sysDatetime = df.format(new Date());
					//String sysDatetime = "235959";
			        //int curtime = Integer.getInteger(sysDatetime);
			        int tag = sysDatetime.compareTo("235900");
					if(tag > 0)
					{
						String sql = "update Mth_OrderInfo set todaycount = 0";
						Statement stmt = conn.createStatement();
						stmt.executeUpdate(sql);
						stmt.close();
					}
					
					
					
					Statement stmt = conn.createStatement();
					res = stmt.executeQuery("select top 1 * from Mth_RequirementInfo;");
					
					if(res.next())
					{
						//数据备份
						BackupData backupdata = new BackupData();
						int backupTag = backupdata.BizdataBackup(res,conn);
						if(backupTag == 1)
						{
							System.out.println("backup access!");
						}
						//商机撮合
						int id = res.getInt(1);
						MatchData matchdata = new MatchData();
						int mthtag = matchdata.matchingdata(id,conn);
						if(mthtag == 1)
						{
							System.out.println("match success!");
						}
						System.out.println(id);
						DbDelete Dbdel = new DbDelete();
						int deltag = Dbdel.Dbdel(id,conn);
						if(deltag == 1)
						{
							System.out.println("access!");
						}
					}
					res.close();
					stmt.close();
					Thread.sleep(1000);
				}
			}
			catch(Exception ex)
			{
				System.out.println("err msg_main:" + ex);
			}		
		}
}