使用连接池前后连接数据库的对比

首先，为什么使用JDBC？

JDBC是指java数据库连接，是面向关系型数据库的，它实际就是一个JAVA封装的API，我们采用Java语言执行sql语句，对（各种）数据库操作，具有跨平台性。不管是什么关系数据库，我们都可以通过jdbc实现数据库的连接和操作。

然后，为什么使用连接池？

我们不仅仅要求连接到数据库，更需要连接的效率。这就需要连接池了。也就是说，我提前连接好n个连接，需要的时候，我在池里取就行，不用再现创现用了，速度快了，效率高了。连接池有c3p0,dbcp等，有文章专门介绍过几种连接池的区别。结论就是c3p0是使用最广泛的。

下面比较使用连接池前后的效率

1 建一个pool管理类 Mpool

package com.db;

import java.beans.PropertyVetoException;
import java.sql.Connection;
import java.sql.SQLException;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class Mpool {
private static Mpool mPool;
private ComboPooledDataSource dataSource;

static {
mPool = new Mpool();
}
//构造方法
public Mpool() {
try {
dataSource = new ComboPooledDataSource("mysql");
dataSource.setUser("root");
dataSource.setPassword("root123");
dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test02");
dataSource.setDriverClass("com.mysql.jdbc.Driver");
dataSource.setInitialPoolSize(2);
dataSource.setMinPoolSize(1);
dataSource.setMaxPoolSize(10);
dataSource.setMaxStatements(50);
dataSource.setMaxIdleTime(60);
} catch (PropertyVetoException e) {
throw new RuntimeException(e);
}
}

public final static Mpool getInstance() {
return mPool;
}

public final Connection getConnection() {
try {
return dataSource.getConnection();
} catch (SQLException e) {
throw new RuntimeException("无法从数据源获取连接 ", e);
}
}

}

2 测试类 main

import java.sql.*;
import com.db.Mpool;;

public class Test {

public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println("使用连接池.......................");
for (int i = 0; i < 20; i++) {
long beginTime = System.currentTimeMillis();

//1 获取一个连接
Connection conn = Mpool.getInstance().getConnection();
try {

//2 这个连接要干嘛，封装在PreparedStatement准备对象中.不可以采用拼接的形式了，采用占位符。
/* PreparedStatement pstmt = conn
.prepareStatement("insert into user(userName,password) value("+i+",111)");
*/
PreparedStatement pstmt = conn
.prepareStatement("insert into user(userName,password) values(?,?)");
pstmt.setInt(1, i);
pstmt.setInt(2, i);
//3 准备好以后，执行准备对象

/* 3-1执行查询对象 ResultSet rs = pstmt.executeQuery();*/

//3-2 执行插入更新等的准备对象
//Boolean a= pstmt.execute(); //如果第第一个结果是结果集返回true。
//建议使用executeUpadate() 执行结果可以看到,0表示没有执行
int a= pstmt.executeUpdate();
System.out.println(a);

/* 如果是查询语句，则re存在返回结果。
while (rs.next()) {
re.get内容

}*/
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
long endTime = System.currentTimeMillis();
System.out.println("第" + (i + 1) + "次执行花费时间为:"
+ (endTime - beginTime));
}

}

}

3 只是用jdbc测试

import java.sql.*;

public class Test1 {

public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println("不使用连接池................................");
for (int i = 0; i < 20; i++) {
long beginTime = System.currentTimeMillis();
try {
Class.forName("com.mysql.jdbc.Driver").newInstance();
} catch (Exception e1) {
e1.printStackTrace();
}
String url = "jdbc:mysql://localhost:3306/test02";
String user = "root";
String password = "root123";
Connection conn=null;
try {
//直接使用jdbc获取conn
conn = DriverManager.getConnection(url, user, password);
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
try {
PreparedStatement pstmt = conn
.prepareStatement("insert into user(userName,password) values(?,?)");
pstmt.setInt(1, i);
pstmt.setInt(2, i);

int a =pstmt.executeUpdate();
System.out.println(a);
/* while (rs.next()) {
// get content
}*/
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
long endTime = System.currentTimeMillis();
System.out.println("第" + (i + 1) + "次执行花费时间为:"
+ (endTime - beginTime));
}
}
}