("jdbcdriver"));
comb.setJdbcUrl(prop.getProperty("url"));
comb.setUser(prop.getProperty("jdbc:mysql://localhost:3306/test"));
comb.setPassword(prop.getProperty("root"));
Connection con = comb.getConnection();//从c3p0拿一条鱼,啊呸!什么鱼啊,拿一条数据库连接
//执行查询语句
String sql = "select * from user";
PreparedStatement ps = con.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
//打印数据库信息
while(rs.next())
{
System.out.println(rs.getString(1));
System.out.println(rs.getString(2));
System.out.println(rs.getString(3));
System.out.println(rs.getString(5));
System.out.println(rs.getString(6));
System.out.println(rs.getString(7));
}
//关闭连接
con.close();//这是啥,这是把连接还给连接池,而不是关闭连接in.close();comb.close();rs.close();ps.close();} }
?
?
第二种方法:(类似于,但更简洁)
我们需要新建一个配置文件:c3p0.properties (注意:名字是固定的。c3p0默认只认识这个名字)
?
?
c3p0.driverClass=com.mysql.jdbc.Driver
c3p0.jdbcUrl=jdbc:mysql://localhost:3306/test
c3p0.user=root
c3p0.password=root
OK!我们新建一个类:C3p0Demo2
?
?
package day12;
import java.beans.PropertyVetoException;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.DataSource;
import org.junit.Test;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3p0Demo2 {
@Test
public void getConByC3P0() throws SQLException
{
DataSource ds = new ComboPooledDataSource();//c3p0自己去读配置文件了,我们啥也不干
Connection con = ds.getConnection();//我们直接拿一条鱼
System.out.println("con:"+con);
String sql = "select * from user";
PreparedStatement ps = con.prepareStatement(sql);
ResultSet rs = ps.executeQuery();
while(rs.next())
{
System.out.println(rs.getString(1));
System.out.println(rs.getString(2));
System.out.println(rs.getString(3));
System.out.println(rs.getString(5));
System.out.println(rs.getString(6));
System.out.println(rs.getString(7));
}
//关闭连接
con.close();//这是啥,这是把连接还给连接池,而不是关闭连接
rs.close();
ps.close();
}
}