testthread.java

数据库连接池源码

package llm.pool.relation;

import java.util.ArrayList;

import org.apache.log4j.Logger;

public class TestThread extends Thread {
	
	private static Logger log = Logger.getLogger( TestThread.class.getName() );

	public TestThread() {
	}

	public void run() {
		test1();
	}
	
	public void test2() {
		DBOperate dbo = new DBOperate();	
		try {
			dbo.init( "SYSTEM" );
		} catch ( Exception e ) {
			log.error("执行异常",e);
		}
		ArrayList al = new ArrayList();
		String query = "";
		query = "INSERT INTO AA( BID, CID, QYBJ ) VALUES( '00', '02', '1' )";
		for ( int i = 0; i < 10; i ++ ) 
			al.add( query );
		while ( true ) {
			try {
//				DBOperate dbo = new DBOperate();				
//				// System.out.println("获取数据库连接");
//				dbo.init( "SYSTEM" );				
			    dbo.exeUpdate( al );
			    Thread.sleep( 10 );
//			    System.out.println( dbo.exeQueryInt( query ) );

			} catch ( Exception e ) {
				log.error("执行异常",e);
			}
		}			
	}
	
	public void test1() {
		while ( true ) {
			try {
				DBOperate dbo = new DBOperate();
				String query = "";
				log.fatal("获取数据库连接");
				dbo.init( "SYSTEM" );
			    query = "SELECT count(1) FROM AAA";
			    System.out.println( dbo.exeQueryInt( query ) );
//			    dbo.init( "SYSTEM1" );
//			    ds = (SimpleDataSource)dbo.getDataSource();
//				System.out.println("--2222--" + ds.getStatus());
//			    query = "SELECT count(*) FROM TY_DBAttrInfo";
//			    System.out.println( dbo.exeQueryInt( query ) );
//			    System.out.println(dbo.getQueryTotalRow());
//			    String[] temp = null;
//			    int ll = 0;
//			    for (int i = 0; i < al1.size(); i++ ) {
//			    	temp = (String[])al1.get(i);
//			    	
//			    	ll = temp.length;
//			    	for (int j = 0; j < ll; j ++ ) {
//			    		System.out.print( temp[j]  + ", " );	
//			    	}
//			    	System.out.println("");
//			    }
			} catch ( Exception e ) {
				log.error("执行异常",e);
			}
		}		
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		try {
			DBOperate dbo = new DBOperate();
			String query = "";
			log.fatal("获取数据库连接");
			dbo.init( "SYSTEM" );
		    query = "SELECT count(1) FROM AAa";
		    System.out.println( dbo.exeQueryInt( query ) );
		} catch ( Exception e ) {
			log.error("执行异常",e);
		}
		
		for ( int i = 0; i < 4; i ++  ) {
			new TestThread().start();
		}

	}

}