数据库连接池负责分配、管理和释放数据库连接，它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个；释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏。这项技术能明显提高对数据库操作的性能。
对于数据库连接池，我举一个小小的例子，通过这个例子(虽然不妥当)。我们可以吧数据库理解为一个大的池塘。；连接池为池塘里面的各个小的池塘(相当于一个容器)，这个小的池塘里面，存储了我们岁要访问的数据库的相关信息。所以，当我们要访问数据库的时候，我们要访问这个容器，再从这个容器里卖弄取数据，因此，不产生对原数据库的直接操作，从而保护数据(个人理解，好懂就行)
我一般喜欢用C3P0。C3P0是一个开源的JDBC连接池，它实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。即便喜欢用，但是对于通过配置C3P0来对数据库建立连接，我还是不太会，所以，我不采用这种配置的方法。
在百度百科里面，有关于C3P0的具体配置，可以直接使用config.properties配置文件DriverClass=com.mysql.jdbc.Driver
JdbcUrl=jdbc:mysql://IP:3306/auto_smart_home_data?useUnicode=true&characterEncoding=UTF-8
User=root
Password=123
MaxPoolSize=20
MinPoolSize=2
InitialPoolSize=5
MaxStatements=30
MaxIdleTime=100
接下来，便是java使用了：packagecom.MySql;
importjava.sql.Connection;
importjava.util.Properties;
importcom.mchange.boPooledDataSource;
/*
*@author22923
*@date创建时间5月13日
*@description通过配置文件的形式，建立对C3P0的操作，
*/
publicclassC3P0Mysql{
privateComboPooledDataSourcecpds;
privatestaticC3P0Mysqlc3P0Properties;
static{
c3P0Properties=newC3P0Mysql();
}
publicC3P0Mysql(){
try{
cpds=newComboPooledDataSource();
//加载配置文件
Propertiesprops=newProperties();
props.load(C3P0Mysql.class.getClassLoader().getResourceAsStream("config.properties"));
cpds.setDriverClass(props.getProperty("DriverClass"));
cpds.setJdbcUrl(props.getProperty("JdbcUrl"));
cpds.setUser(props.getProperty("User"));
cpds.setPassword(props.getProperty("Password"));
cpds.setMaxPoolSize(Integer.parseInt(props.getProperty("MaxPoolSize")));
cpds.setMinPoolSize(Integer.parseInt(props.getProperty("MinPoolSize")));
cpds.setInitialPoolSize(Integer.parseInt(props.getProperty("InitialPoolSize")));
cpds.setMaxStatements(Integer.parseInt(props.getProperty("MaxStatements")));
cpds.setMaxIdleTime(Integer.parseInt(props.getProperty("MaxIdleTime")));
}catch(Exceptione){
e.printStackTrace();
}
}
publicstaticC3P0MysqlgetInstance(){
returnc3P0Properties;
}
publicConnectiongetConnection(){
Connectionconn=null;
try{
conn=cpds.getConnection();
}catch(Exceptione){
e.printStackTrace();
}
returnconn;
}
publicstaticvoidmain(String[]args){
//TODOAuto-generatedmethodstub
Connectionconnection=C3P0Mysql.c3P0Properties.getConnection();
System.out.println("已经连接成功");
}
}
上面的结果是这个：
似乎感觉还没有我直接用来的好。下main是我直接在java中建立连接。
packagecom.MySql;
importcom.mchange.boPooledDataSource;
importjava.sql.Connection;
importjava.sql.SQLException;
publicclassMyDBManger{
/**
*@authorsunyang_ah@
*@return
*@function利用数据库连接池对数据库进行连接
**/
ComboPooledDataSourcecombo=newComboPooledDataSource();
privateMyDBManger(){
//TODOAuto-generatedmethodstub
try{
combo.setDriverClass("com.mysql.jdbc.Driver");//加载驱动
combo.setPassword("");
combo.setUser("root");
combo.setJdbcUrl("jdbc:mysql:///auto_smart");//地址可以换成云端
combo.setMaxPoolSize(10);//池中最大的数量
combo.setMinPoolSize(3);
combo.setCheckoutTimeout(20000);//超时连接，断
//测试下
combo.getConnection().close();
}catch(Exceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
System.out.println("error:"+e.getMessage());
}
}
privatestaticMyDBMangerDBManager=newMyDBManger();
publicstaticMyDBMangergetDBManger(){
returnDBManager;
}
//外面调用获得数据库连接对象，调用此方法
publicConnectiongetconnection()throwsSQLException{
returncombo.getConnection();
}
publicstaticvoidmain(String[]args){
//TODOAuto-generatedmethodstub
newMyDBManger();
}
}
就向上面的那样，我们调用这个程序，就可以直接得到一个数据库的连接。packagecom.MySql;
importjava.sql.PreparedStatement;
importjava.sql.ResultSet;
importjava.sql.SQLException;
importjava.sql.Statement;
importjava.sql.Connection;
publicclassDemoTest{
Connectionconnection=null;
ResultSetrs=null;
Statementstatement=null;
publicDemoTest(){
//TODOAuto-generatedconstructorstub
try{
connection=MyDBManger.getDBManger().getconnection();
statement=connection.createStatement();//statement相当于一辆货车，把数据库连接里取数据出来
rs=statement.executeQuery("SELECT*FROMautohome");
System.out.println(
"编号"+"\t"+"名字"+"\t"+"密码"+"\t"
);
while(rs.next()){
System.out.println(
rs.getString("ID")+"\t"+
rs.getString("DATETIME")+"\t"+
rs.getString("TEMPTURE")+"\t"
);
}
connection.close();
rs.close();
statement.close();
}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
publicstaticvoidmain(String[]args){
//TODOAuto-generatedmethodstub
newDemoTest();
}
}
对于常用的数据库操作，无非增删查改，对于一些存储过程，触发器之类的，还是算了吧。
先看增，增无非就是insert 。//往数据库中插入数据
privatevoidInsert(){
try{
//得到一个数据库的连接
connection=DataBaseManger.getDBManger().getconnection();
statement=connection.createStatement();
//做插入
statement.executeUpdate(sql);//sql为sql语句
}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
再看删，其实删和增，是一样的。包括改在内。也就是一个sql语句的不一样。其他的都一样的操作。
对于查，整的来说，也是一样的，唯一不同的是，他的返回值可以有好多，而对于增删改，返回值是int 类型:
int executeUpdate(String sql) throws SQLException;
下面的这个是查找的代码，因为做的是一个服务器，所以最后都是转化成json的格式发。不影响。try{
connection=MyDBManger.getDBManger().getconnection();//得到一个连接
st=connection.createStatement();
rs=st.executeQuery("selectid,temperature,humidity,co,createTimefromcheckdataorderbyiddescLIMIT1");
System.out.println("====================================");
while(rs.next()){
try{
json.put("id",rs.getInt("id"));
json.put("temp",rs.getDouble("temperature"));
json.put("hum",rs.getDouble("humidity"));
json.put("co",rs.getDouble("co"));
json.put("time",rs.getString("createTime"));
out.write(json.toString());
}catch(Exceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
System.out.println(json.toString());
}
}catch(SQLExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
具体的怎么实现这个增删查改，我就直接用网上的一些代码好了。别人写的也是挺好的代码，为啥不用呢？是吧。做个参考。
这个DBConnection.java类，其实就是一个数据库的开关，只是他没用数据库连接池。是直接连接的。publicclassDBConnection{
Stringdriver="com.mysql.jdbc.Driver";
Stringurl="jdbc:mysql://localhost:3306/test";
Stringuser="root";
Stringpassword="123456";
publicConnectionconn;
publicDBConnection(){
try{
Class.forName(driver);//加载驱动程序
conn=(Connection)DriverManager.getConnection(url,user,password);//连续数据库
if(!conn.isClosed())
System.out.println("SucceededconnectingtotheDatabase!");
}catch(Exceptione){
e.printStackTrace();
}
}
publicvoidclose(){
try{
this.conn.close();
}catch(Exceptione){
e.printStackTrace();
}
}
}
publicclassJDBCTest{
publicstaticvoidmain(String[]args){
//add(uname,uemail,upwd);
//update("李诗诗","lishishi@com","666");
//show();
del("王小五");
}
//插入操作
publicstaticintadd(Stringuname,Stringuemail,Stringupwd){
inti=0;
Stringsql="insertintoemployee(name,email,pwd)values(?,?,?)";
DBConnectiondb=newDBConnection();
try{
PreparedStatementpreStmt=(PreparedStatement)db.conn.prepareStatement(sql);
preStmt.setString(1,uname);
preStmt.setString(2,uemail);
preStmt.setString(3,upwd);
preStmt.executeUpdate();
//Statementstatement=(Statement)db.conn.createStatement();
//statement.executeUpdate(sql);
preStmt.close();
db.close();//关闭连接
}catch(Exceptione){
e.printStackTrace();
}
returni;//返回影响的行数，1为执行成功
}
//查找操作
publicstaticvoidshow(){
Stringsql="select*fromemployee";
DBConnectiondb=newDBConnection();
System.out.println("-----------------");
System.out.println("姓名"+"\t"+"邮箱"+"\t"+"日期");
System.out.println("-----------------");
try{
Statementstmt=(Statement)db.conn.createStatement();
ResultSetrs=(ResultSet)stmt.executeQuery(sql);
while(rs.next()){
Stringuname=rs.getString("name");
Stringuemail=rs.getString("email");
Stringuhiredate=rs.getString("hiredate");
//可以将查找到的值写入类，然后返回相应的对象
//这里先用输出的端口显示一下
System.out.println(uname+"\t"+uemail+"\t"+uhiredate);
}
rs.close();
db.close();//关闭连接
}catch(SQLExceptione){
e.printStackTrace();
}
}
//更新操作
publicstaticintupdate(Stringuname,Stringuemail,Stringupwd){
inti=0;
Stringsql="updateemployeesetemail=?,pwd=?wherename=?";
DBConnectiondb=newDBConnection();
try{
PreparedStatementpreStmt=(PreparedStatement)db.conn.prepareStatement(sql);
preStmt.setString(1,uemail);
preStmt.setString(2,upwd);
preStmt.setString(3,uname);
preStmt.executeUpdate();
preStmt.close();
db.close();//关闭连接
}catch(SQLExceptione){
e.printStackTrace();
}
returni;//返回影响的行数，1为执行成功
}
//删除操作
publicstaticintdel(Stringuname){
inti=0;
Stringsql="deletefromemployeewherename=?";
DBConnectiondb=newDBConnection();
try{
PreparedStatementpreStmt=(PreparedStatement)db.conn.prepareStatement(sql);
preStmt.setString(1,uname);
preStmt.executeUpdate();
preStmt.close();
db.close();//关闭连接
}catch(SQLExceptione){
e.printStackTrace();
}
returni;//返回影响的行数，1为执行成功
}
}
上面的这个代码来自博客：/liushao/p/6381678.html，但愿这哥们不要怪我
其他的就没啥了。
我没找到上传附件的地方，就不上传了，关于C3P0连接池的一些jar包网上一堆。直接下载就好了。我也是因为同学找我要一些资料。才写的这个。
