test.java

短信开发用于文件交换处理转发的类模块

package com.pub.backserver.blackList;

import org.apache.log4j.Logger;

import com.pub.berkeleydb.BklyEnv;

/**
 * <p>
 * Title:
 * </p>
 * 
 * <p>
 * Description:
 * </p>
 * 
 * <p>
 * Copyright: Copyright (c) 2005
 * </p>
 * 
 * <p>
 * Company:
 * </p>
 * 
 * @author not attributable
 * @version 1.0
 */
public class Test {
	private static Logger log = Logger.getLogger(Test.class);

	public static void main(String[] args) {

		org.apache.log4j.BasicConfigurator.configure();

		// open Berkeley DB
		BklyEnv env = new BklyEnv();
		 if (env.open("E:/NewSmsMms/berkeleydb/backserver/black") != 0) {
		 log.error("open env error");
		 return;
		 }

//		if (env.open("../queuee/black") != 0) {
//			log.error("open env error");
//			return;
//		}

		BlackDatabase bb = new BlackDatabase();
		if (bb.open("BlackList", env) != 0) {
			log.error("open database error");
			return;
		}
		// try {
		// env.getOriginEnv().cleanLog();
		// }
		// catch (Throwable ex) {
		// }

		// int ret = bb.LoadFromDatabase("oracle.jdbc.driver.OracleDriver",
		// "jdbc:oracle:thin:@218.206.76.242:1521:orcl",
		// "wxtlplatform", "wxtlplatform",
		// "select vc2mobile,numtype from tl_blacklist where
		// datcreate>=to_date('2006-9-19 13:30:18','yyyy-mm-dd hh24:mi:ss') and
		// rownum<100");

		// query
		BlackEntity be = new BlackEntity();
		
		
		

		long lStart = 0;
		log.info("Query starting ...");
		lStart = System.currentTimeMillis();
		String sMobile = "";
		for(int i = 0; i < 100000; i++) {
			sMobile = "1381166";
			sMobile += pickRandom(1000, 9999);		
			be.setPhone(sMobile);
			int iInsert = bb.Insert(be);
		
			int iQuery = bb.Query(be);
			
			int iDelete = bb.Delete(be);
			
			iQuery = bb.Query(be);
			
			log.info("Total : " + i + " - "+ be.toString());
		}		
		log.info("Query 10W time used : " + (System.currentTimeMillis() - lStart) + " millisecond.");
		bb.close();
	}
	
	public static int pickRandom(int min, int max) {
		return (int) (Math.random() * (max - min + 1) + min);
	}

}