jdbc简介
jdbc全称为：java data base connectivity (java数据库连接），可以为多种数据库提供填统一的访问。jdbc是sun开发的一套数据库访问编程接口，是一种sql级的api。它是由java语言编写完成，所以具有很好的跨平台特性，使用jdbc编写的数据库应用程序可以在任何支持java的平台上运行，而不必在不同的平台上编写不同的应用程序。
jdbc编程步骤
（1）加载驱动程序：
下载驱动包 : http://dev.mysql.com/downloads/connector/j/
解压，得到 jar文件。将该文件复制到java工程目录java resources/libraries/ 下，→ buildpath 。
（2）获得数据库连接
（3）创建statement对象：
（4）向数据库发送sql命令
（5）处理数据库的返回结果(resultset类)
?
|
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
|
package com.baidu.emp.jdbctest;
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.resultset;
import java.sql.statement;
import com.mysql.jdbc.driver;
/**
* 开始使用jdbc连接数据库
* @author admin
*
*/
public class test001 {
public static void main(string[] args) throws exception {
/**
* 加载驱动
*/
// 方法一：
/*
* import java.sql.drivermanager; import com.mysql.jdbc.driver;
*/
// driver driver = new driver();
// drivermanager.registerdriver(driver);
// 方法二：(推荐使用)
class.forname("com.mysql.jdbc.driver");
/**
* 创建链接
*/
string url = "jdbc:mysql://localhost:3306/testjdbc";
string user = "root";
string password = "root";
connection connection = drivermanager.getconnection(url, user, password);
// 创建statement对象
statement statement = connection.createstatement();
/**
* 执行sql，获取结果集
*/
string sql = "select * from test01";
resultset result = statement.executequery(sql);
// 遍历结果集
while (result.next()) {
string name = result.getstring("name");
int id = result.getint("id");
system.out.println(name + "\\t" + id);
}
/**
* 关闭链接，释放资源
*/
result.close();
statement.close();
connection.close();
}
}
|
防止sql注入改用preparestatement
?
|
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
|
package com.boya.emp.jdbctest;
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.resultset;
/**
* sql注入，使用preparestatement对象进行预编译
* @author admin
*
*/
public class test002 {
public static void main(string[] args) throws exception {
/**
* 加载驱动
*/
class.forname("com.mysql.jdbc.driver");
/**
* 创建链接
*/
string url = "jdbc:mysql://localhost:3306/testjdbc";
string user = "root";
string password = "root";
connection connection = drivermanager.getconnection(url, user, password);
// 写sql
string sql = "select * from test01 where id = ?";
//创建statement对象，预编译
preparedstatement statement = connection.preparestatement(sql);
//设置参数
statement.setint(1, 2);
/**
* 执行sql，获取结果集
*/
resultset result = statement.executequery();
// 遍历结果集
while (result.next()) {
string name = result.getstring("name");
int id = result.getint("id");
system.out.println(name + "\\t" + id);
}
/**
* 关闭链接，释放资源
*/
result.close();
statement.close();
connection.close();
}
}
|
进行代码优化，设置配置文件，工具类，实现增删该查
增加配置文件方便修改数据库，用户登录。。。
jdbc.properties(配置文件名)
?
|
1
2
3
4
|
drivername=com.mysql.jdbc.driver
url=jdbc:mysql://localhost:3306/testjdbc
username=root
password=root
|
注意写配置文件时中间不可以有空格，引号之类的
工具类：增强了代码的复用性
?
|
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
90
91
92
93
94
95
96
97
98
99
100
101
102
|
package com.baidu.emp.utils;
import java.io.inputstream;
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.resultset;
import java.sql.sqlexception;
import java.util.properties;
import org.junit.test;
public class jdbcutils {
static string driverclassname;
static string url;
static string user;
static string password;
static {
// 创建配置文件对象
properties properties = new properties();
// 加载配置文件输入流
inputstream inputstream = jdbcutils.class.getclassloader().getresourceasstream("jdbc.properties");
// 重新加载配置文件
try {
properties.load(inputstream);
// 获取配置文件的值
driverclassname = properties.getproperty("drivername");
url = properties.getproperty("url");
user = properties.getproperty("username");
password = properties.getproperty("password");
class.forname(driverclassname);
} catch (exception e) {
// 抛出异常
throw new runtimeexception(e);
}
}
/**
* 获取连接
*/
@test
public void testname() throws exception {
system.out.println(driverclassname);
}
public static connection getconnection() {
connection connection = null;
try {
connection = drivermanager.getconnection(url, user, password);
} catch (sqlexception e) {
// 抛出异常
throw new runtimeexception(e);
}
return connection;
}
/**
* 关闭链接，释放资源
*/
public static void close(connection connection, preparedstatement statement, resultset resultset) {
try {
if (resultset != null) {
resultset.close();
}
resultset = null; // 垃圾及时清除
//注意，不要弄成死循环
close(connection, statement);
} catch (sqlexception e) {
throw new runtimeexception(e);
}
}
/**
* 增删改释放资源
*/
public static void close(connection connection, preparedstatement statement) {
try {
if (connection != null) {
connection.close();
}
connection = null;
if (statement != null) {
statement.close();
}
statement = null;
} catch (sqlexception e) {
throw new runtimeexception(e);
}
}
}
|
测试增删改查：
?
|
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package com.baidu.emp.jdbctest;
import java.sql.connection;
import java.sql.preparedstatement;
import java.sql.resultset;
import org.junit.after;
import org.junit.before;
import org.junit.test;
import com.baidu.emp.utils.jdbcutils;
/**
* 使用jdbcutils连接数据库进行增删改查
*
* @author admin
*
*/
public class test003 {
// 初始化值
connection connection = null;
preparedstatement statement = null;
resultset result = null;
@before
public void start() throws exception {
// 创建链接
connection = jdbcutils.getconnection();
system.out.println("创建链接");
}
@after
public void end() throws exception {
// 关闭链接
jdbcutils.close(connection, statement, result);
system.out.println("关闭链接");
}
/**
*插入数据
* @throws exception
*/
@test
public void add() throws exception {
string sql = "insert into test01 values(null,?)";
statement = connection.preparestatement(sql);
statement.setstring(1, "李四");
int result = statement.executeupdate();
if (result!=0) {
system.out.println("添加成功");
}
}
/**
* 删除数据
* @throws exception
*/
@test
public void del() throws exception {
string sql = "delete from test01 where id =?";
statement = connection.preparestatement(sql);
statement.setint(1,3);
int result = statement.executeupdate();
if (result!=0) {
system.out.println("删除成功");
}
}
/**
* 修改数据
* @throws exception
*/
@test
public void change() throws exception {
string sql = "update test01 set name = ? where id = ?";
statement = connection.preparestatement(sql);
statement.setstring(1, "张飞");
statement.setint(2, 2);
int result = statement.executeupdate();
if (result!=0) {
system.out.println("修改成功");
}
}
/**
* 查询全部数据
* @throws exception
*/
@test
public void findall() throws exception {
string sql = "select id , name from test01";
statement = connection.preparestatement(sql);
result = statement.executequery();
if (result.next()) {
system.out.println("查询成功");
}
}
/**
* 条件查询数据
* @throws exception
*/
@test
public void findone() throws exception {
string sql = "select id , name from test01 where id = ?";
statement = connection.preparestatement(sql);
statement.setint(1, 2);
result = statement.executequery();
if (result.next()) {
system.out.println("查询成功");
}
}
}
|
以上就是相关知识以及相关代码，感谢大家对快网idc的支持。
相关文章
猜你喜欢
- 个人服务器网站搭建：如何选择合适的服务器提供商？ 2025-06-10
- ASP.NET自助建站系统中如何实现多语言支持？ 2025-06-10
- 64M VPS建站：如何选择最适合的网站建设平台？ 2025-06-10
- ASP.NET本地开发时常见的配置错误及解决方法？ 2025-06-10
- ASP.NET自助建站系统的数据库备份与恢复操作指南 2025-06-10
