sqlengine.java

短信网关发送接受平台。

package data;
import java.sql.*;
import utilities.*;
import orderapp.*;
/**
 * Title:
 * Description:
 * Copyright:    Copyright (c) 2002
 * Company:
 * @author
 * @version 1.0
 */
/*
	SQL池处理线程
*/
public class sqlEngine extends Engine{
       public ConnectionPool conPool;
       public String sql;
	public sqlEngine() {
	       setDaemon(true);
	       conPool=new ConnectionPool();
	}
	public void run(){
	       while(true){
			if(!Config.sql_queue.isEmpty()){
				sql=(String)Config.sql_queue.pop();
				//System.out.println(sql);
				conPool.executeUpdate(sql);
			}
			try{
				Thread.sleep(50);
			}
			catch(Exception e){
					e.printStackTrace();
			}

	       }
	}
}