JDBC结合C3PO的原始连接

好久以前做过,怕忘了,重新做一次

 

package cn.wp.web.jdbc;

import java.beans.PropertyVetoException;
import java.net.ConnectException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.junit.Test;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 * 关于数据库连接池的使用，首先我们要明白我们为什么要用它，
 1 对应普通的数据库连接操作，通常会涉及到以下一些操作是比较耗时的：
 2 网络通讯，涉及到网络延时及协议通讯
 3 身份验证，涉及安全性检查
 4 连接合法性检查，主要是检查所连接的数据库是否存在
 5 并发控制机制
 6 构造并初始化输出缓冲区
 7 连接成功后的信息保存，日志存储
 8 服务器性能
 9 数据库配置优化
 10 系统分配内存资源
 等等~~~状况，导致数据库连接操作比较耗时，~~~而且每次都得花费0.05s～1s的时间

 但是使用连接池技术，本质上就是在一个请求对应的连接，都由一个线程池来维护着，
 也就是说“上下文切换”的代价是线程级别（所谓的纳秒级），对于大规模的并发访问，
 就算以每秒几亿级别的访问量都是不成问题的
 */

/** 做个原始JDBC数据库连接的工具类.通过C3PO连接数据 */
public class JdbcUtil {
	/**
	 * 将连接对象绑定线程中,属于原形技术,目的减少耗费资源 简单介绍下对象ThreadLocal
	 * 该对象内部用拥有一个map集合,可以存取对象,保护线程之间对象的独立性 每个线程中都有一个自己的ThreadLocalMap类对象，
	 * */
	private static ThreadLocal<Connection> thread = new ThreadLocal<Connection>();

	/**
	 * 数据表操作API
	 * */
	private static PreparedStatement preStatement = null;

	@Test
	public void test() throws ConnectException {
		String sql = "insert into user(name) values (?)";
		preStatement = getPreStatement(sql);

		try {
			Long start = System.currentTimeMillis();
			for (int i = 0; i <100; i++) {
				preStatement.setString(1, "123");
				preStatement.addBatch();
				if (i % 30 == 0) {
					preStatement.executeBatch();
					preStatement.clearBatch();
				}
			}
			// 处理剩下的SQL语句
			preStatement.executeBatch();
			preStatement.clearBatch();
			Long end = System.currentTimeMillis();
			System.out.println("执行完毕" + "插入语句" + "花费时间"
					+ ((start - end) / 1000) + "秒");
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {

			closeStatement(preStatement);
			colseConnection();
		}
	}

	/**
	 * 根据sql语句获取执行的preStatement对象
	 * */
	public static PreparedStatement getPreStatement(String sql) {
		try {
			preStatement = getThread_Connection().prepareStatement(sql);

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return preStatement;
	}

	/**
	 * 获取线程中的Connection对象
	 * */
	public static Connection getThread_Connection() {
		Connection conn = thread.get();
		if (null == conn) {
			conn = getConnection();
			thread.set(conn);
		}
		return conn;
	}

	/**
	 * 通过C3PO获取连接的Connection对象
	 * */
	public static Connection getConnection() {
		/**
		 * ComboPooledDataSource连接数据库对象有两种方式 第一种,在classes目录下建一个C3P0配置文件,设置基本连接信息
		 * 第二种,实例化该对象后,通过设置对象.属性的方式设置基本连接信息
		 * */
		Connection conn = null;

		try {
			ComboPooledDataSource c3p0 = new ComboPooledDataSource(false);
			c3p0.setDriverClass("com.mysql.jdbc.Driver");
			c3p0.setUser("root");
			c3p0.setPassword("*****");
			c3p0.setJdbcUrl("jdbc:mysql://127.0.0.1:3306/test");
			c3p0.setInitialPoolSize(20);
			conn = c3p0.getConnection();
		} catch (PropertyVetoException | SQLException e) {
			e.printStackTrace();
		}

		return conn;
	}

	/** 提供一个conn关闭的方法 */
	public static void closeConnection(Connection conn) {
		if (null != conn) {
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 提供一个PreparedStatement关闭的方法
	 * */
	public static void closeStatement(PreparedStatement sta) {
		if (null != sta) {
			try {
				sta.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public static void getclose(ResultSet rs) {
		if (rs != null) {
			try {
				rs.close();
			} catch (Exception e) {
				e.printStackTrace();
				throw new RuntimeException();
			}
		}
	}

	// 封装事务开始方法
	public static void getbegin() {
		try {
			Connection conn = getConnection();
			conn.setAutoCommit(false);
			System.out.println(conn.hashCode() + "setAutocommit");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// 封装事务提交方法
	public static void getsmbit() {
		try {
			Connection conn = getConnection();
			conn.commit();
			System.out.println(conn.hashCode() + "commit");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// 封装事务回退方法
	public static void getback() {
		try {
			Connection conn = getConnection();
			conn.rollback();
			System.out.println(conn.hashCode() + "rockback");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// 封装关闭Connection对象
	public static void colseConnection() {
		try {
			Connection conn = getConnection();
			thread.remove();
			JdbcUtil.closeConnection(conn);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}