0%

JDBC简单使用

连接数据库

下载jar包 ,或者导入maven

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
public class JDBCTest {
// private static final String driver = "com.mysql.jdbc.Driver";//已过时
private static final String driver = "com.mysql.cj.jdbc.Driver";
private static final String username = "root";
private static final String password = "root";
private static final String schema = "test";
private static final int port = 3306;
private static final String url = "jdbc:mysql://localhost:"
+ port + "/" + schema+"?serverTimezone=GMT&useUnicode=true&characterEncoding=utf8";
//最好使用properties文件存储配置信息,或者使用数据库连接池

private static Connection conn;//建立连接

@BeforeClass
public static void initJDBC() throws Exception {
Class.forName(driver);//加载驱动
conn = DriverManager.getConnection(url, username, password);//建立数据库连接
}

@Test
public void testRead() {
try (Statement s = conn.createStatement();
ResultSet rs = s.executeQuery("SELECT * FROM stu;")//查询数据表返回结果集
) {
ResultSetMetaData rsmd = rs.getMetaData();//获取结果集的元数据
while (rs.next()) {//如果有下一条记录
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
System.out.print(rs.getString(i)+"\t");//将每列打印输出
}
System.out.print("\n");
}
} catch (SQLException e) {
e.printStackTrace();
}
}

@AfterClass
public static void destoryJDBC() throws Exception {
conn.close();//释放连接
}
}

执行SQL语句的Statement

Statement的基本用法

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
public class JDBCTest {
//省略初始化代码
@Test
public void testExecuteUpdate(){
try(Statement s = conn.createStatement();
){
s.executeUpdate("CREATE TABLE stu(" +
"sid INT UNSIGNED PRIMARY KEY AUTO_INCREMENT," +
"sname VARCHAR(20)," + "age INT ," + "tid INT )");
System.out.println("共有"+0+"条记录受影响");//执行DDL语句时返回0
int records = s.executeUpdate("UPDATE stu SET age=age+1");
System.out.println("共有"+records+"条记录受影响");//执行DML语句时返回受影响记录数目
} catch (SQLException e) {
e.printStackTrace();
}
}

@Test
public void testExecute(){
try(Statement s = conn.createStatement();
){
boolean hasResultSet = s.execute("SELECT * FROM stu;");//判断有没有结果集
if(hasResultSet){
try(ResultSet rs = s.getResultSet()){//获取结果集
ResultSetMetaData rsmd = rs.getMetaData();//获取结果集元数据
while (rs.next()) {
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
System.out.print(rs.getString(i)+"\t");
}
System.out.print("\n");
}
}
}

} catch (SQLException e) {
e.printStackTrace();
}
} //省略释放资源代码
}

预编译的PreparedStatement

PreparedStatementStatement的子接口,可以预编译SQL语句,效率高,还可以防注入。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public class JDBCTest {
//省略初始化代码
@Test
public void testPreparedStatement(){
try(PreparedStatement ps = conn.prepareStatement(
"INSERT INTO stu(sname, age) VALUES(?,?) ");//预编译SQL语句
){
for(int i = 0; i < 3; i++){
ps.setString(1,"stu"+i);//填充占位符
ps.setInt(2, 20+i);//填充占位符
ps.executeUpdate();//提交
}
} catch (SQLException e) {
e.printStackTrace();
}
}
//省略释放资源代码
}

调用存储过程的CallableStatement

MySQL常用语句

自定义一个加法的存储过程

1
2
3
4
5
delimiter //
create procedure add_num(in a int, in b int, out sum int)
begin
set sum = a + b;
end//
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
public class JDBCTest {
//省略初始化代码
@Test
public void testCallableStatement() throws Exception{
try(CallableStatement cs = conn.prepareCall("{CALL add_num(?,?,?)}");){
int a = 5, b = 3;
cs.setInt(1, a);
cs.setInt(2, b);
cs.registerOutParameter(3, Types.INTEGER);
cs.execute();
System.out.println(a+"+"+b+"="+cs.getInt(3));
}
}
//省略释放资源代码
}

事务

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
public class JDBCTest {
//省略初始化代码
@Test
public void testTransaction() throws SQLException {
conn.setAutoCommit(false); // 关闭事务自动提交
Statement s = conn.createStatement();
s.executeUpdate("INSERT INTO stu(sname) VALUES ('stu1');");
s.executeUpdate("INSERT INTO stu(sname) VALUES ('stu2');");
Savepoint sp = conn.setSavepoint("事务中间点"); // 设置事务中间点
s.executeUpdate("INSERT INTO stu(sname) VALUES ('stu3');");
conn.rollback(sp); // 回滚事务
conn.commit(); // 提交事务
}
//省略释放资源代码
}

数据库连接池

DBCP数据源

Tomcat的连接池使用DBCP连接池。
maven中导入

1
2
3
4
5
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.4</version>
</dependency>

从数据库连接池中获取数据库连接

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
public class JDBCTest {
//省略初始化代码
@Test
public void testDBCP() throws SQLException {
//BasicDataSource bds = BasicDataSourceFactory.createDataSource(properties);//另一种创建方式
BasicDataSource bds = new BasicDataSource();
bds.setDriverClassName(driver); // 加载驱动
bds.setUrl(url); // 设置url
bds.setUsername(username); // 设置用户名
bds.setPassword(password); // 设置密码
bds.setInitialSize(5); //设置连接池的初始连接数
bds.setMaxActive(20); //设置连接池最多可有20个活动连接数
bds.setMinIdle(2); //设置连接池中最少有2个空闲的连接
Connection conn = bds.getConnection();
//执行sql语句
conn.close();//释放连接,归还连接池
}
//省略释放资源代码
}

C3P0数据源

Hibernate的连接池使用C3P0连接池。
maven中导入

1
2
3
4
5
<dependency>
<groupId>c3p0</groupId>
<artifactId>c3p0</artifactId>
<version>0.9.1.2</version>
</dependency>

从数据库连接池中获取数据库连接

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public class JDBCTest {
//省略初始化代码
@Test
public void testC3P0() throws PropertyVetoException, SQLException {
ComboPooledDataSource cpds = new ComboPooledDataSource();
cpds.setDriverClass(driver); // 加载驱动
cpds.setJdbcUrl(url); // 设置url
cpds.setUser(username); // 设置用户名
cpds.setPassword(password); // 设置密码
cpds.setMaxPoolSize(40); //设置连接池的最大连接数
cpds.setMinPoolSize(2); //设置连接池的最小连接数
cpds.setInitialPoolSize(10); //设置连接池的初始连接数
cpds.setMaxStatements(190); //设置连接池的缓存Statement的最大数
Connection conn = cpds.getConnection();
//执行SQL语句
conn.close();
} //省略释放资源代码
}
点击进入云乞讨模式!