package com.enhance.jdbc;
import java.beans.PropertyVetoException;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import com.mchange.v2.c3p0.ComboPooledDataSource;
//c3p0 下载地址:http://sourceforge.net/projects/c3p0/
//需要 c3p0.jar mchange-commons-java.jar
public class C3p0ConnectionPool {
private static ComboPooledDataSource ds=new ComboPooledDataSource();
private PreparedStatement pstmt;
private ResultSet rs;
static{
Properties prop=new Properties();
try {
prop.load(new FileInputStream("src/mysql.ini"));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
ds.setDriverClass(prop.getProperty("driver"));
} catch (PropertyVetoException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
ds.setJdbcUrl(prop.getProperty("url"));
ds.setUser(prop.getProperty("user"));
ds.setPassword(prop.getProperty("pass"));
ds.setMaxPoolSize(Integer.parseInt(prop.getProperty("maxActive")));
ds.setMinPoolSize(Integer.parseInt(prop.getProperty("minIdle")));
ds.setInitialPoolSize(Integer.parseInt(prop.getProperty("initialSize")));
ds.setMaxStatements(Integer.parseInt(prop.getProperty("maxStatements")));
}
public Connection getConenction() throws SQLException{
return ds.getConnection();
}
public void executeUpdate() throws SQLException{
Connection con=null;
try {
con=this.getConenction();
pstmt=con.prepareStatement("insert into img_table(img_name,img_data) values (?,?)");
pstmt.setString(1, "连接池进行blob数据的新增");
File file=new File("F:\\androidworkspace\\LauncherActivity\\res\\drawable-nodpi\\wallpaper.jpg");
pstmt.setBinaryStream(2, new FileInputStream(file));
int rows=pstmt.executeUpdate();
System.out.println(rows);
} catch (Exception e) {
e.printStackTrace();
}finally{
if(pstmt!=null)
pstmt.close();
if(con!=null)
con.close();
}
}
public void execute()throws SQLException{
Connection con=null;
try {
con=this.getConenction();
pstmt=con.prepareStatement("select img_id,img_name,img_data from img_table"); // where img_id=?
//pstmt.setInt(1, 3);
rs =pstmt.executeQuery();
while(rs.next()){
File file=new File("C:\\Users\\Bin\\Desktop\\"+rs.getString(2)+".jpg");
Blob blob=rs.getBlob(3);
//InputStream in=blob.getBinaryStream();
OutputStream out=new FileOutputStream(file);
out.write(blob.getBytes(1l, (int) blob.length()));
/*byte[] b=new byte[1024];
while(in.read(b,0,b.length)!=-1){
out.write(b);
out.flush();
}*/
//in.close();
out.close();
}
} catch (Exception e) {
e.printStackTrace();
}finally{
if(pstmt!=null)
pstmt.close();
if(con!=null)
con.close();
}
}
public static void main(String[] args) throws SQLException {
// TODO Auto-generated method stub
DBCPConnectionPool dbcppool=new DBCPConnectionPool();
dbcppool.executeUpdate();
dbcppool.execute();
}
}
//-------------------------------
package com.enhance.jdbc;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import org.apache.commons.dbcp.BasicDataSource;
//DBCP 下载地址:http://commons.apach.org/
//需要 commond-dbcp.jar commons-pool.jar
public class DBCPConnectionPool {
private static BasicDataSource ds=new BasicDataSource();
private PreparedStatement pstmt;
private ResultSet rs;
static{
Properties prop=new Properties();
try {
prop.load(new FileInputStream("src/mysql.ini"));
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
ds.setDriverClassName(prop.getProperty("driver"));
ds.setUrl(prop.getProperty("url"));
ds.setUsername(prop.getProperty("user"));
ds.setPassword(prop.getProperty("pass"));
ds.setInitialSize(Integer.parseInt(prop.getProperty("initialSize")));
ds.setMaxActive(Integer.parseInt(prop.getProperty("maxActive")));
ds.setMinIdle(Integer.parseInt(prop.getProperty("minIdle")));
}
public Connection getConenction() throws SQLException{
return ds.getConnection();
}
//下面一样
}
分享到:
相关推荐
c3p0-0.9.5.1,commons-dbcp-1.4,commons-pool-1.3,druid-1.0.26,junit-4.7等jar包,可供选择,一般在后期做项目的时候都离不开,必定会用到一个连接池,c3p0、或者阿里巴巴的druid、或者dbcp,dbcp很少用
数据库连接池的资源包(c3p0 , dbcp,druid连接池)
包含两种连接池jar包:c3p0-0.9.1.jar和commons-collections4-4.1.jar、commons-dbcp2-2.1.1.jar、commons-logging-1.2.jar、commons-pool2-2.4.2.jar和dbcp与c3p0详细配置文档
DBCP连接池DBCP和C3P0配置,可以对数据源进行各种有效的控制
常见的两种数据库连接池的jar包和源码。
三大连接池常用jar(c3p0,dbcp,druid)
DBCP和C3P0连接池常用配置参数一览表DBCP和C3P0连接池常用配置参数一览表DBCP和C3P0连接池常用配置参数一览表
DBCP、C3P0,JNDI 连接池配置使用,可以参考一下。
DBCP,c3p0连接池需要的全部的包,有所有的
c3p0连接池jar包,完整数据包。 c3p0与dbcp区别 dbcp没有自动回收空闲连接的功能 c3p0有自动回收空闲连接功能
DBCP连接池介绍 ----------------------------- 目前 DBCP 有两个版本分别是 1.3 和 1.4。 DBCP 1.3 版本需要运行于 JDK 1.4-1.5 ,支持 JDBC 3。 DBCP 1.4 版本需要运行于 JDK 1.6 ,支持 JDBC 4。 1.3和1.4基于...
里面有dbcp以及其依赖的jar包和c3p0jar包。可以通过使用数据库链接池,高效、安全的复用,避免了数据库连接频繁建立、关闭的开销。
本例演示c3p0 、dbcp 、proxool三种常用数据库连接池的用法及log4j2日志使用方法
有druid以及C3P0连接池的各种jar包,希望各位多多支持,有需要的给我多关注。谢谢各位!
DBCP,C3P0,Druid连接池资料和jar包
DBCP也是一个开源的连接池,是Apache Common成员之一,在企业开发中也比较常见,tomcat内置的连接池。C3P0访问数据库技术,方便快捷,牵扯到的jar包可去网上下载!
此含dbcp c3p0 连接池的jar 文件,下载后可直接引入项目使用,已经验证
c3p0,DBCP,dbutils,druid-1.0.9以及配置文件
DBCP连接池、C3P0连接池、配置文件