前言:什么是JDBC
Java 数据库连接,(Java Database Connectivity,简称JDBC)是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口,提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。它JDBC是面向关系型数据库的。
简单地说,就是用于执行SQL语句的一类Java API,通过JDBC使得我们可以直接使用Java编程来对关系数据库进行操作。通过封装,可以使开发人员使用纯Java API完成SQL的执行。
一、准备工作(一):MySQL安装配置和基础学习
使用JDBC操作数据库之前,首先你需要有一个数据库。这里提供了3个链接供读者自学,如果曾有过SQL语言的使用经历(包括在学校中的课堂学习),前两个链接足以上手。
Mysql下载安装、部署与图形化详细操作教程:http://www.zzvips.com/article/76317.html
建议边看入门教程,边练习,在练习insert、update、select、delete等基本操作的同时,将后面要用的表建好。
下图是我接下来用于演示的数据库的表。
二、准备工作(二):下载数据库对应的jar包并导入
使用JDBC需要在工程中导入对应的jar包。数据库与JDBC包的对应关系可以参考各种数据库对应的jar包、驱动类名和URL格式。在Eclipse下的导入方法:
在工程的图标上右击,选择”Properties”,在”Java Bulid Path”中选择”Add External JARs…”,选择下载并解压后获得的jar包。
如果对MySQL进行操作,这时下面的import就不会报错了:
1
2
|
import com.mysql.jdbc.Connection; import com.mysql.jdbc.PreparedStatement; |
除此以外,还需要JDBC的包,直接import即可。
1
2
3
|
import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; |
三、JDBC基本操作
为了简单起见,与数据库相关的操作、命令、参数都被硬编码了。有兴趣的读者可以对这些进行探索,降低数据与操作的耦合性。
先看具体代码并实践,本文第五部分对用到的API稍作了研究。
下面的所有方法和数据成员都在public class JDBCOperation内部。
(1)定义记录的类(可选)
这样做主要是为了便于操作和接口定义,是非必须的。
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
|
static class Student { private String Id; private String Name; private String Sex; private String Age; Student(String Name, String Sex, String Age) { this .Id = null ; //default this .Name = Name; this .Sex = Sex; this .Age = Age; } 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 getSex() { return Sex; } public void setSex(String Sex) { this .Sex = Sex; } public String getAge() { return Age; } public void setage(String Age) { this .Age = Age; } } |
(2)连接的获取
在操作前必须先获取与数据库的连接。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
private static Connection getConn() { String driver = "com.mysql.jdbc.Driver" ; String url = "jdbc:mysql://localhost:3306/samp_db" ; String username = "root" ; String password = "" ; Connection conn = null ; try { Class.forName(driver); //classLoader,加载对应驱动 conn = (Connection) DriverManager.getConnection(url, username, password); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn; } |
(3)insert
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
private static int insert(Student student) { Connection conn = getConn(); int i = 0 ; String sql = "insert into students (Name,Sex,Age) values(?,?,?)" ; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); pstmt.setString( 1 , student.getName()); pstmt.setString( 2 , student.getSex()); pstmt.setString( 3 , student.getAge()); i = pstmt.executeUpdate(); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i; } |
(4)update
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
private static int update(Student student) { Connection conn = getConn(); int i = 0 ; String sql = "update students set Age='" + student.getAge() + "' where Name='" + student.getName() + "'" ; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); i = pstmt.executeUpdate(); System.out.println( "resutl: " + i); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i; } |
(5)select
以select * from XXX为例。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
private static Integer getAll() { Connection conn = getConn(); String sql = "select * from students" ; PreparedStatement pstmt; try { pstmt = (PreparedStatement)conn.prepareStatement(sql); ResultSet rs = pstmt.executeQuery(); int col = rs.getMetaData().getColumnCount(); System.out.println( "============================" ); while (rs.next()) { for ( int i = 1 ; i <= col; i++) { System.out.print(rs.getString(i) + "\t" ); if ((i == 2 ) && (rs.getString(i).length() < 8 )) { System.out.print( "\t" ); } } System.out.println( "" ); } System.out.println( "============================" ); } catch (SQLException e) { e.printStackTrace(); } return null ; } |
(6)delete
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
|
private static int delete(String name) { Connection conn = getConn(); int i = 0 ; String sql = "delete from students where Name='" + name + "'" ; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); i = pstmt.executeUpdate(); System.out.println( "resutl: " + i); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i; } |
四、测试
在测试前,需要在系统中打开对应数据库的服务。MySQL在Windows下的启动命令为net start mysql
测试代码
1
2
3
4
5
6
7
8
|
public static void main(String args[]) { JDBCOperation.getAll(); JDBCOperation.insert( new Student( "Achilles" , "Male" , "14" )); JDBCOperation.getAll(); JDBCOperation.update( new Student( "Bean" , "" , "7" )); JDBCOperation.delete( "Achilles" ); JDBCOperation.getAll(); } |
Eclipse中的输出
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
|
============================ 1 Ender male 8 2 Bean male 6 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 ============================ ============================ 1 Ender male 8 2 Bean male 6 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 7 Achilles Male 14 ============================ resutl: 1 resutl: 1 ============================ 1 Ender male 8 2 Bean male 7 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 ============================ |
五、代码分析
在上述对数据库进行增删改查的过程中,可以发现其共性部分,即通用的流程:
(1)创建Connection对象、SQL查询命令字符串;
(2)对Connection对象传入SQL查询命令,获得PreparedStatement对象;
(3)对PreparedStatement对象执行executeUpdate()或executeQurey()获得结果;
(4)先后关闭PreparedStatement对象和Connection对象。
可见,使用JDBC时,最常打交道的是Connection、PreparedStatement这两个类,以及select中的ResultSet类。
Connection
java.sql
接口 Connection
所有超级接口:Wrapper
--------------------------------------------------------------------------------
public interface Connectionextends Wrapper
与特定数据库的连接(会话)。在连接上下文中执行 SQL 语句并返回结果。
Connection 对象的数据库能够提供描述其表、所支持的 SQL 语法、存储过程、此连接功能等等的信息。此信息是使用 getMetaData 方法获得的。
PreparedStatemnt
java.sql
接口 PreparedStatement
所有超级接口:Statement, Wrapper所有已知子接口:CallableStatement
--------------------------------------------------------------------------------
public interface PreparedStatementextends Statement
表示预编译的 SQL 语句的对象。
SQL 语句被预编译并存储在 PreparedStatement 对象中。然后可以使用此对象多次高效地执行该语句。
常用方法
1
|
boolean execute() |
在此 PreparedStatement 对象中执行 SQL 语句,该语句可以是任何种类的 SQL 语句。
1
|
ResultSet executeQuery() |
在此 PreparedStatement 对象中执行 SQL 查询,并返回该查询生成的 ResultSet 对象。
1
|
int executeUpdate() |
在此 PreparedStatement 对象中执行 SQL 语句,该语句必须是一个 SQL 数据操作语言(Data Manipulation Language,DML)语句,比如 INSERT、UPDATE 或 DELETE 语句;或者是无返回内容的 SQL 语句,比如 DDL 语句。
ResultSet
java.sql
接口 ResultSet
所有超级接口:Wrapper所有已知子接口:CachedRowSet, FilteredRowSet, JdbcRowSet, JoinRowSet,RowSet,SyncResolver, WebRowSet
--------------------------------------------------------------------------------
public interface ResultSetextends Wrapper
表示数据库结果集的数据表,通常通过执行查询数据库的语句生成。
六、思考问题
1.每次SQL操作都需要建立和关闭连接,这势必会消耗大量的资源开销,如何避免?
分析:可以采用连接池,对连接进行统一维护,不必每次都建立和关闭。事实上这是很多对JDBC进行封装的工具所采用的。
2.Java代码中,传入的数据格式与数据库定义不同怎么办?如把Java的String对象赋值给数据库的tinyint属性。
分析:在执行SQL语句时,数据库会尝试进行转换。根据我的实验,如果用内容为纯字母的String对象传入tinyint的age属性时,会被转化成0。具体转化规则应该和数据库有关。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:http://www.cnblogs.com/wuyuegb2312/p/3872607.html