多线程操作操作数据库

命题

最近有一个需求是： 实现一个java
standalone应用，开辟静态HashMap（1500），创建500个线程，序号从1到500，每个线程都会建立3次连接访问数据库test，
调用数据库函数cms.sp_get_fundasset，传入线程序号作为参数。数据库函数返回的账户净值按序号写入对应的静态HashMap。统计500个线程全部结束后消耗的时间总长；

实现 思路

• 创建调用传统创建线程的类
• 创建db用于jdbc连接
• 创建test用于写测试代码

具体实现

线程类:

package cn.northpark.test.multhread;

import java.util.concurrent.CountDownLatch;

public class ConnThread implements Runnable {

	public  int threadNo;
	public  CountDownLatch latch;

	//设置线程的编号
	public ConnThread(int threadNo,CountDownLatch latch){
		this.threadNo = threadNo;
		this.latch = latch;
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		// 建立连接，并且请求存储过程

		try {
			db.getConn();

			// 每个线程查询三次
			//调用存储过程 
			for (int i = 0; i < 3; i++) {

				String result = db.callProcedureYY(db.conn,"cms.sp_get_fundasset",threadNo + 500*i);

				test.map.put(String.valueOf(threadNo + 500*i), result);
			}
			//存放结果



		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			// db.closeConn();
			latch.countDown();
			System.out.println("线程"+threadNo+"执行完毕");
		}

	}





	public static void main(String[] args) {
		try {
			db.getConn();
			String result = db.callProcedureYY(db.conn,"cms.sp_get_fundasset",1);
			System.out.println("result--->"+result);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			db.closeConn();
		}
	}
}

数据连接类:

package cn.northpark.test.multhread;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;

import oracle.jdbc.driver.OracleTypes;

public class db  {
	public static Connection conn = null; // 数据库连接对象
	public static CallableStatement cs = null;// 存储过程执行对象
	public static ResultSet rs = null;// 结果集对象

	public static  synchronized void getConn() throws ClassNotFoundException, SQLException {
		Class.forName("oracle.jdbc.driver.OracleDriver"); // 加载Oracle驱动程序
		// System.out.println("开始尝试连接数据库！");
		String url = "jdbc:oracle:" + "thin:@localhost:1521:test";// 127.0.0.1是本机地址，XE是精简版Oracle的默认数据库名
		String user = "test";// 用户名,系统默认的账户名
		String password = "test";// 你安装时选设置的密码
		conn = DriverManager.getConnection(url, user, password);// 获取连接
		// System.out.println("连接成功！");
	}




	/**
	 *
	 * @Discription 执行有参数，有返回值的存储过程
	 * @return void
	 * @param conn
	 * @throws Exception
	 */
	/*
	 * 对应的存储过程语句 --有参数，有返回值 create or replace procedure deleteLine(byNo in
	 * number,getCount out number) as begin delete from emp e where e.empno =
	 * byNo; select count(*) into getCount from emp e; end;
	 */
	public static synchronized String callProcedureYY(Connection conn,String funcName,int index) throws Exception {
		// 指定调用的存储过程
		cs = conn.prepareCall("{?=call "+funcName+"(?)}");
		// 设置参数
		cs.setInt(2, index);
		// 这里需要配置OUT的参数新型
		cs.registerOutParameter(1, OracleTypes.FLOAT);
		// 执行调用
		cs.execute();
		// 输入返回值
		String result = String.valueOf(cs.getFloat(1));
		// System.out.println(cs.getFloat(1));

		return result;
	}






	/**
	 * 描述：
	 * 关闭连接
	 */
	public static void closeConn(){
		try {
			// 逐一将上面的几个对象关闭，因为不关闭的话会影响性能、并且占用资源
			// 注意关闭的顺序，最后使用的最先关闭
			if (rs != null)
				rs.close();
			if (cs != null)
				cs.close();
			if (conn != null)
				conn.close();
			// System.out.println("数据库连接已关闭！");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}


}

测试执行类：

package cn.northpark.test.multhread;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CountDownLatch;

import org.quartz.JobExecutionException;

import cn.northpark.utils.TimeUtils;

public class test {

	public static final Map<String,String> map  = new HashMap<String,String>();
	public static final int CONN_COUNT  = 500;
	


	public static void main(String arg0) throws JobExecutionException {
		// TODO Auto-generated method stub
		try {
			//清空已有信息
			map.clear();

			String start = TimeUtils.nowTime();
			System.out.println("开始时间："+start);

			ArrayList<Runnable> threads = new ArrayList<Runnable>();

			CountDownLatch latch = new CountDownLatch(CONN_COUNT);

			for (int i = 1; i <= CONN_COUNT; i++) {
				threads.add(new ConnThread(i,latch));
			}

			// //开启线程
			//500 个线程  每个线程查询三次
			for (Runnable r:threads) {
				new Thread(r).start();
			}

			//调用await方法阻塞当前线程，等待子线程完成再继续
			latch.await();

			//释放连接
			db.closeConn();

			String end = TimeUtils.nowTime();
			System.out.println("结束时间："+end);

			System.out.println(map.size()+">>>>>"+map);
			System.out.println(TimeUtils.getPastTime(end, start));

		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

说明：

2017年11月8日

• 运行test.java ，即可执行500个线程，分别调用函数返回结果，并且存放到map集合里.并且打印执行时间.
• db.java里面是连接数据库的方法和信息
• ConnThread.java是线程类
• TimeUtils.java是时间工具类