matchdata.java

来自「对数据库中的信息进行撮合匹配」· Java 代码 · 共 63 行

package com.cuohe.dblic;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;

import com.cuohe.ini.ReadConfig;

public class MatchData {
	//主函数中监听到表中有记录插入，在此方法中进行结合查询
	private int i = 0;
	public int matchingdata(int id,Connection conn)
	{
		String sql = "select * from Mth_RequirementInfo as mth,Mth_OrderInfo as mthorder where mth.id = " + id;
		try
		{
			Statement stmt = conn.createStatement();
			ResultSet res;
			res = stmt.executeQuery(sql);			
			int backcode = 0;
			//如果有记录，则证明撮合成功，将记录逐条处理
			while(res.next())
			{				
				if(res.getString("Title").indexOf(res.getString("Keyword")) != -1)
				{
					ReadConfig rvf = new ReadConfig();
					String totalcnt = rvf.Readini("totalcnt");
					int todaycount = Integer.parseInt(totalcnt);
					if(res.getInt("todaycount") <= todaycount)
					{
//						此处将数据加工，生成映射表【商机撮合表（MthMathinfo）】
						AddInfo addinfo = new AddInfo();
						int inserttag = addinfo.DbInsert(res,conn);
						if(inserttag == 1)
						{
							i++;
							setcount(i);
							backcode = 1;
						}
					}
					
				}
			}
			res.close();
			stmt.close();
			return backcode;			
		}
		catch(Exception ex)
		{
			System.out.println("matchingdata ERR msg :" + ex);
		}
		return 0;		
	}
	public void setcount(int i)
	{
		this.i = i;
	}
	public int getcount()
	{
		return this.i;
	}
}