c3p0连接Mysql数据库

Posted 2020-10-06

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,
primary key (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) {
 6         super();
 7         this.cus_id = cus_id;
 8         this.cus_name = cus_name;
 9         this.age = age;
10     }
11     public Customer() {
12         super();
13     }
14     public String getCus_id() {
15         return cus_id;
16     }
17     public void setCus_id(String cus_id) {
18         this.cus_id = cus_id;
19     }
20     public String getCus_name() {
21         return cus_name;
22     }
23     public void setCus_name(String cus_name) {
24         this.cus_name = cus_name;
25     }
26     public int getAge() {
27         return age;
28     }
29     public void setAge(int age) {
30         this.age = age;
31     }
32     @Override
33     public String toString() {
34         return "Customer [cus_id=" + cus_id + ", cus_name=" + cus_name + ", age=" + age + "]";
35     }
36     
37 }

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     //静态代码块自动装载，连接数据库的参数
12     static {
13     
14         try {
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         }
26         
27     }
28     //获得连接
29     public static Connection getCon() {
30         try {
31             return dataSource.getConnection();
32         } catch (Exception e) {
33             e.printStackTrace();
34             return null;
35         }
36     }
37     public static ComboPooledDataSource getDataSource() {
38         return dataSource;
39     }
40     //关闭连接
41     public static void closeCon(Connection conn,PreparedStatement pst,ResultSet rs) {
42         if(rs != null) {
43             try {
44                 rs.close();
45             } catch (SQLException e) {
46                 e.printStackTrace();
47             }
48             finally {rs = null;}
49         }
50         if(pst != null) {
51             try {
52                 pst.close();
53             } catch (SQLException e) {
54                 e.printStackTrace();
55             }
56             finally {pst = null;}
57         }
58         if(conn != null) {
59             try {
60                 conn.close();
61             } catch (SQLException e) {
62                 e.printStackTrace();
63             }
64             finally {conn = null;}
65         }
66     }
67     public void closeCon(Connection conn) {
68         if(conn != null) {
69             try {
70                 conn.close();
71             } catch (SQLException e) {
72                 e.printStackTrace();
73             }
74             finally {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
16     public void 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         //关闭资源
25         new JDBCUtils().closeCon(conn);
26     }
27 
28 }

7、运行测试类