使用c3p0连接MySQL数据库并对MySQL数据库进行基本操作。
1. [文件] 数据库准备 ~ 226B 下载(64)
|
1
2
3
4
5
6
7
8
9
10
|
##创建数据库并指定编码create database test character set utf8;##切换数据库use test;##创建表格create table user(id int primary key auto_increment,name varchar(50),password varchar(50)); |
2. [文件] c3p0-config.xml ~ 1KB 下载(96)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
<c3p0-config> <!-- 默认配置，如果没有指定则使用这个配置 --> <default-config> <property name="checkoutTimeout">30000</property> <property name="idleConnectionTestPeriod">30</property> <property name="initialPoolSize">10</property> <property name="maxIdleTime">30</property> <property name="maxPoolSize">100</property> <property name="minPoolSize">10</property> <property name="maxStatements">200</property> <user-overrides user="test-user"> <property name="maxPoolSize">10</property> <property name="minPoolSize">1</property> <property name="maxStatements">0</property> </user-overrides> </default-config> <!-- 命名的配置 --> <named-config name="test"> <property name="driverClass">com.mysql.jdbc.Driver</property> <property name="jdbcUrl">jdbc:mysql:///test?useUnicode=true&characterset=utf-8 </property> <property name="user">root</property> <property name="password">1234</property> <!-- 如果池中数据连接不够时一次增长多少个 --> <property name="acquireIncrement">5</property> <property name="initialPoolSize">20</property> <property name="minPoolSize">10</property> <property name="maxPoolSize">40</property> <property name="maxStatements">0</property> <property name="maxStatementsPerConnection">5</property> </named-config></c3p0-config> |
3. [文件] C3P0Utils.java ~ 615B 下载(85)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
import java.sql.Connection;import java.sql.SQLException;import javax.sql.DataSource;import com.mchange.v2.c3p0.ComboPooledDataSource;/** * c3p0连接MySQL数据库工具包 * * @author 冰雨凌風 * */public class C3P0Utils { // 定义全局变量 private static ComboPooledDataSource cpds; // 静态代码块 static { cpds = new ComboPooledDataSource("test"); } // 获得数据源 public static DataSource getDataSource() { return cpds; } // 获得连接 public static Connection getConnection() throws Exception { return cpds.getConnection(); }} |
4. [文件] User.java ~ 583B 下载(54)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
public class User { private String id; private String name; private String password; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } @Override public String toString() { return "User [id=" + id + ", name=" + name + ", password=" + password + "]"; }} |
5. [文件] C3P0Test.java ~ 2KB 下载(64)
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
import java.sql.SQLException;import org.apache.commons.dbutils.QueryRunner;import org.apache.commons.dbutils.handlers.BeanHandler;import org.junit.Test;/** * 利用dbutils对数据库进行CURD操作 * * @author 冰雨凌風 * */public class C3P0Test { /** * 在数据库中插入数据 */ @Test public void add() { try { // 创建执行者 QueryRunner runner = new QueryRunner(C3P0Utils.getDataSource()); // 准备sql语句 String sql = "insert into user(name,password) value(?,?)"; // 准备参数 Object[] params = { "admin", "1234" }; // 执行语句 runner.update(sql, params); System.out.println("插入数据成功！"); } catch (SQLException e) { throw new RuntimeException(e); } } /** * 查询数据 */ @Test public void query() { try { // 创建执行者 QueryRunner runner = new QueryRunner(C3P0Utils.getDataSource()); // 准备sql语句 String sql = "select * from user"; // 执行语句 User user = runner.query(sql, new BeanHandler<User>(User.class)); System.out.println(user); } catch (SQLException e) { throw new RuntimeException(e); } } /** * 更新数据 */ @Test public void update() { try { // 创建执行者 QueryRunner runner = new QueryRunner(C3P0Utils.getDataSource()); // 准备sql语句 String sql = "update user set password=? where name=?"; // 准备参数 Object[] params = { "123456", "admin" }; // 执行语句 runner.update(sql, params); System.out.println("更新数据成功！"); } catch (SQLException e) { throw new RuntimeException(e); } } /** * 删除数据 */ @Test public void delete() { try { // 创建执行者 QueryRunner runner = new QueryRunner(C3P0Utils.getDataSource()); // 准备sql语句 String sql = "delete from user"; // 执行语句 runner.update(sql); System.out.println("删除数据成功"); } catch (SQLException e) { throw new RuntimeException(e); } }} |