【转载】通过JDBC对MySQL数据库的增删改查

分手后的思念是犯贱 2023-07-04 14:24 8阅读 0赞

## [通过JDBC进行简单的增删改查（以MySQL为例）][JDBC_MySQL] ##

[前言：什么是JDBC][JDBC]

[一、准备工作（一）：MySQL安装配置和基础学习][MySQL]

[二、准备工作（二）：下载数据库对应的jar包并导入][jar]

[三、JDBC基本操作][JDBC 1]

[(1)定义记录的类（可选）][1]

[(2)连接的获取][2]

[(3)insert][3_insert]

[(4)update][4_update]

[(5)select][5_select]

[(6)delete][6_delete]

[四、测试][Link 1]

[五、代码分析][Link 2]

[六、思考问题][Link 3]

## 前言：什么是JDBC ##

维基百科的简介：

> **　　**Java 数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。它JDBC是面向关系型数据库的。

简单地说，就是用于执行SQL语句的一类Java API，通过JDBC使得我们可以直接使用Java编程来对关系数据库进行操作。通过封装，可以使开发人员使用纯Java API完成SQL的执行。

## 一、准备工作（一）：MySQL安装配置和基础学习 ##

使用JDBC操作数据库之前，首先你需要有一个数据库。这里提供了3个链接供读者自学，如果曾有过SQL语言的使用经历（包括在学校中的课堂学习），前两个链接足以上手。

1.安装和配置：[mysql安装图解 mysql图文安装教程(详细说明)][mysql_ mysql][  
][mysql_ mysql]

2.基本操作：[21分钟 MySQL 入门教程][21_ MySQL]

3.简易命令查询 ：[一千行MySQL学习笔记][MySQL 1]

[ ][MySQL 1]

**建议边看入门教程，边练习，在练习insert、update、select、delete等基本操作的同时，将后面要用的表建好。**

下图是我接下来用于演示的数据库的表。

![281032291805275.png][]

## 二、准备工作（二）：下载数据库对应的jar包并导入 ##

使用JDBC需要在工程中导入对应的jar包。数据库与JDBC包的对应关系可以参考[各种数据库对应的jar包、驱动类名和URL格式][jar_URL]。在Eclipse下的导入方法：

在工程的图标上右击，选择”Properties”，在”Java Bulid Path”中选择”Add External JARs…”，选择下载并解压后获得的jar包。

![281057300244359.jpg][]

如果对MySQL进行操作，这时下面的import就不会报错了：

import com.mysql.jdbc.Connection;
    import com.mysql.jdbc.PreparedStatement;

除此以外，还需要JDBC的包，直接import即可。

import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;

## 三、JDBC基本操作 ##

为了简单起见，与数据库相关的操作、命令、参数都被硬编码了。有兴趣的读者可以对这些进行探索，降低数据与操作的耦合性。

**先看具体代码并实践，本文第五部分对用到的API稍作了研究。**

下面的所有方法和数据成员都在public class JDBCOperation内部。

### (1)定义记录的类（可选） ###

这样做主要是为了便于操作和接口定义，是非必须的。

![复制代码][copycode.gif]

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;
            }
    }

![复制代码][copycode.gif]

### (2)连接的获取 ###

在操作前必须先获取与数据库的连接。

driver、url的格式同样可以参考[各种数据库对应的jar包、驱动类名和URL格式][jar_URL]。

![复制代码][copycode.gif]

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;
    }

![复制代码][copycode.gif]

### (3)insert ###

![复制代码][copycode.gif]

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;
    }

![复制代码][copycode.gif]

### (4)update ###

![复制代码][copycode.gif]

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;
    }

![复制代码][copycode.gif]

### (5)select ###

以select \* from XXX为例。

![复制代码][copycode.gif]

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;
    }

![复制代码][copycode.gif]

### (6)delete ###

![复制代码][copycode.gif]

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;
    }

![复制代码][copycode.gif]

## 四、测试 ##

在测试前，需要在系统中打开对应数据库的服务。MySQL在Windows下的启动命令为

net start mysql

测试代码

![复制代码][copycode.gif]

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();
    }

![复制代码][copycode.gif]

Eclipse中的输出

![复制代码][copycode.gif]

============================
    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    
    ============================

![复制代码][copycode.gif]

## 五、代码分析 ##

在上述对数据库进行增删改查的过程中，可以发现其共性部分，即通用的流程：

(1)创建Connection对象、SQL查询命令字符串；

(2)对Connection对象传入SQL查询命令，获得PreparedStatement对象；

(3)对PreparedStatement对象执行executeUpdate()或executeQurey()获得结果；

(4)先后关闭PreparedStatement对象和Connection对象。

可见，使用JDBC时，最常打交道的是Connection、PreparedStatement这两个类，以及select中的ResultSet类。查阅Java API手册可以了解其具体的意义和方法。

下面引用的Java API的资料出自[http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/index.html][http_download.oracle.com_technetwork_java_javase_6_docs_zh_api_index.html]。

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` 对象中。然后可以使用此对象多次高效地执行该语句。
> 
>  
> 
> 常用方法
> 
>  boolean  execute()
> 
>           在此 PreparedStatement 对象中执行 SQL 语句，该语句可以是任何种类的 SQL 语句。
> 
>  ResultSet  executeQuery()
> 
>           在此 PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象。
> 
>  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。具体转化规则应该和数据库有关。

作者：[五岳][Link 4]   
出处：http://www.cnblogs.com/wuyuegb2312/p/3872607.html\#

[JDBC_MySQL]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html
[JDBC]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle0
[MySQL]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle1
[jar]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle2
[JDBC 1]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle3
[1]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle31
[2]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle32
[3_insert]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle33
[4_update]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle34
[5_select]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle35
[6_delete]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle36
[Link 1]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle4
[Link 2]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle5
[Link 3]: http://www.cnblogs.com/wuyuegb2312/p/3872607.html#tittle6
[mysql_ mysql]: http://www.jb51.net/article/23876.htm
[21_ MySQL]: http://www.cnblogs.com/mr-wid/archive/2013/05/09/3068229.html
[MySQL 1]: http://www.cnblogs.com/shockerli/p/1000-plus-line-mysql-notes.html
[281032291805275.png]: https://images0.cnblogs.com/i/228024/201407/281032291805275.png
[jar_URL]: http://www.cnblogs.com/kunpengit/archive/2011/12/13/2285933.html
[281057300244359.jpg]: https://images0.cnblogs.com/i/228024/201407/281057300244359.jpg
[copycode.gif]: https://common.cnblogs.com/images/copycode.gif
[http_download.oracle.com_technetwork_java_javase_6_docs_zh_api_index.html]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/index.html
[Wrapper]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/java/sql/Wrapper.html
[Statement]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/java/sql/Statement.html
[CallableStatement]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/java/sql/CallableStatement.html
[CachedRowSet]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/rowset/CachedRowSet.html
[FilteredRowSet]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/rowset/FilteredRowSet.html
[JdbcRowSet]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/rowset/JdbcRowSet.html
[JoinRowSet]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/rowset/JoinRowSet.html
[RowSet]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/RowSet.html
[SyncResolver]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/rowset/spi/SyncResolver.html
[WebRowSet]: http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/javax/sql/rowset/WebRowSet.html
[Link 4]: http://www.cnblogs.com/wuyuegb2312