msqlqueue.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MGuardian.plugin.sessionIdManager;

import java.sql.*;
import net.jumperz.sql.*;
import net.jumperz.util.*;
import java.util.*;

public class MSqlQueue
{
private LinkedList queryStringQueue = new LinkedList();
private LinkedList argsQueue = new LinkedList();
private Connection connection;
//--------------------------------------------------------------------------------
public MSqlQueue( Connection c )
{
connection = c;
}
//--------------------------------------------------------------------------------
public void putSql( String queryString, MObjectArray args )
{
queryStringQueue.addLast( queryString );
argsQueue.addLast( args );
}
//--------------------------------------------------------------------------------
public void executeSql()
throws SQLException
{
while( !queryStringQueue.isEmpty() )
	{
	String queryString = ( String )queryStringQueue.getFirst();
	MObjectArray args = ( MObjectArray )argsQueue.getFirst();

	MSqlUtil.executeUpdate2( connection, queryString, args );

	queryStringQueue.removeFirst();
	argsQueue.removeFirst();
	}
}
//--------------------------------------------------------------------------------
public void clear()
{
queryStringQueue.clear();
argsQueue.clear();
}
//--------------------------------------------------------------------------------
}