使用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);
}
}
} |