首页 / MYSQL / c3p0连接Mysql数据库
c3p0连接Mysql数据库
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了c3p0连接Mysql数据库，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4560字，纯文字阅读大概需要7分钟。
内容图文
c3p0连接Mysql数据库
注：测试使用maven构建的项目，如需学习maven构建项目，请先到maven分类学习如何构建maven项目
1、创建一个maven项目，然后找到pom.xml文件，打开（第一次打开不是通过.xml文件格式打开，可通过右键 -- Open With -- XML Editor 打开）
打开后在配置文件中添加依赖，也就是jar包。
2、添加依赖：
（1）c3p0核心依赖
<dependency>
<groupId>c3p0</groupId>
<artifactId>c3p0</artifactId>
<version>0.9.1.1</version>
</dependency>
（2）MySQL依赖
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.38</version> </dependency>
（3）JDBC工具类库
<dependency> <groupId>commons-dbutils</groupId> <artifactId>commons-dbutils</artifactId> <version>1.2</version> </dependency>
3、新建一个数据库，执行数据库脚本代码，创建表
drop
table
if
exists
customer;
create
table
customer
(
cus_id
int
not
null
auto_increment,
cus_name
varchar(10),
cus_age int,
primarykey (cus_id)
);
4、新建一个实体类，对应数据库中的表结构
1
public
class
Customer {
2
private
String cus_id;
3
private
String cus_name;
4
private
int
age;
5
public Customer(String cus_id, String cus_name, int age) {
6super();
7this.cus_id = cus_id;
8this.cus_name = cus_name;
9this.age = age;
10 }
11public Customer() {
12super();
13 }
14public String getCus_id() {
15return cus_id;
16 }
17publicvoid setCus_id(String cus_id) {
18this.cus_id = cus_id;
19 }
20public String getCus_name() {
21return cus_name;
22 }
23publicvoid setCus_name(String cus_name) {
24this.cus_name = cus_name;
25 }
26publicint getAge() {
27return age;
28 }
29publicvoid setAge(int age) {
30this.age = age;
31 }
32 @Override
33public String toString() {
34return "Customer [cus_id=" + cus_id + ", cus_name=" + cus_name + ", age=" + age + "]";
35 }
3637 }
5、新建一个工具类，用于连接设置数据源和连接数据库信息（连接数据库的地址和用户根据自己的来修改）
我的url:jdbc:mysql://192.168.1.222:3306/test ；用户名：root 密码：root
1
import
java.beans.PropertyVetoException;
2
import
java.sql.Connection;
3
import
java.sql.PreparedStatement;
4
import
java.sql.ResultSet;
5
import
java.sql.SQLException;
6
import
com.mchange.v2.c3p0.ComboPooledDataSource;
7
8
public
class
JDBCUtils {
9
//
private static ComboPooledDataSource dataSource = new ComboPooledDataSource();
10
static ComboPooledDataSource dataSource = new ComboPooledDataSource();
11//静态代码块自动装载，连接数据库的参数12static {
1314try {
15 dataSource.setDriverClass("com.mysql.jdbc.Driver");
16 dataSource.setJdbcUrl("jdbc:mysql://192.168.1.222:3306/test");
17 dataSource.setUser("root");
18 dataSource.setPassword("root");
19 dataSource.setMaxPoolSize(10);//最大连接数20 dataSource.setMinPoolSize(0);//最小连接数21 dataSource.setInitialPoolSize(5);//初始化连接数22 dataSource.setAcquireIncrement(5);//连接增量23 } catch (PropertyVetoException e) {
24 e.printStackTrace();
25 }
2627 }
28//获得连接29publicstatic Connection getCon() {
30try {
31return dataSource.getConnection();
32 } catch (Exception e) {
33 e.printStackTrace();
34returnnull;
35 }
36 }
37publicstatic ComboPooledDataSource getDataSource() {
38return dataSource;
39 }
40//关闭连接41publicstaticvoid closeCon(Connection conn,PreparedStatement pst,ResultSet rs) {
42if(rs != null) {
43try {
44 rs.close();
45 } catch (SQLException e) {
46 e.printStackTrace();
47 }
48finally {rs = null;}
49 }
50if(pst != null) {
51try {
52 pst.close();
53 } catch (SQLException e) {
54 e.printStackTrace();
55 }
56finally {pst = null;}
57 }
58if(conn != null) {
59try {
60 conn.close();
61 } catch (SQLException e) {
62 e.printStackTrace();
63 }
64finally {conn = null;}
65 }
66 }
67publicvoid closeCon(Connection conn) {
68if(conn != null) {
69try {
70 conn.close();
71 } catch (SQLException e) {
72 e.printStackTrace();
73 }
74finally {conn = null;}
75 }
76 }
77 }
6、建立一个测试类，测试数据连接
1
import
java.sql.Connection;
2
import
java.sql.SQLException;
3
import
org.apache.commons.dbutils.QueryRunner;
4
import
org.apache.commons.dbutils.handlers.BeanHandler;
5
import
org.junit.Test;
6
import
com.li.spring.pojo.Customer;
7
import
com.li.spring.utils.JDBCUtils;
8
9
public
class
ConnTest {
10
//
要使用QueryRunner，需要导入commons.dbutils的jar包
11
//
通过工具类获取数据源
12 QueryRunner queryrunner = new QueryRunner(JDBCUtils.getDataSource());
13//获取连接14 Connection conn = JDBCUtils.getCon();
15 @Test
16publicvoid test() throws SQLException {
17//新建一个对象，接收查询的结果集18 Customer cus = new Customer();
19//查询语句20 String sql = "select * from customer";
21 cus = (Customer) queryrunner.query(conn, sql,new BeanHandler(Customer.class));
22//System.out.println(conn.getClass().getName());23 System.out.println(cus.toString());
24//关闭资源25new JDBCUtils().closeCon(conn);
26 }
2728 }
7、运行测试类
原文：http://www.cnblogs.com/lisheng-cn/p/7510743.html
内容总结
以上是互联网集市为您收集整理的c3p0连接Mysql数据库全部内容，希望文章能够帮你解决c3p0连接Mysql数据库所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。