认识 JDBC

JDBC 简介

JDBC 的全称是 Java Database Connectivity，叫做 Java 数据库连接。它包括了一组与数据库交互的 api，还有与数据库进行通信的驱动程序。

我们要写涉及到数据库的程序，是通过 C 语言或者 C++ 语言直接访问数据库的接口，如下图所示。

对于不同的数据库，我们需要知道不同数据库对外提供的系统 API，这就影响了我们程序的扩展和跨平台的实现。

那么有没有一种方法来对不同的数据库接口进行统一呢？那么这里木木就要向大家介绍分层的思想。我们只需要和最上层接口进行交互，剩下的部分就交给其他各层去处理，我们的任务就变的轻松简单许多。

ODBC 是 Open Database Connect 即开放数据库互连的简称，它是微软于 1991 年提出的一个用于访问数据库的统一接口标准，是应用程序和数据库系统之间的中间层。我们的应用程序在调用数据的时候，就无需去管具体的数据库，直接由应用程序访问 ODBC 就可以了。

而在 Java 上面只有一种数据库连接统一接口——JDBC。JDBC 为数据库开发人员提供了一个标准的 API，据此可以构建更高级的工具和接口使数据库开发人员能够用纯 Java API 编写数据库应用程序。

对于数据库的操作我们肯定是需要结构化查询语句 SQL

这里我们就回顾一下 SQL 语句，但不会做过多的详细介绍，如果需要更系统的学习，请参照我们的?MySQL 基础课程。

2.2.1 创建数据库

CREATE DATABASE 语句用于创建一个新的数据库。语法是：

SQL> CREATE DATABASE DATABASE_NAME;

例子，创建一个名为 EXAMPLE 数据库：

SQL> CREATE DATABASE EXAMPLE;

2.2.2 删除数据库

使用 DROP DATABASE 语句用于删除现有的数据库。语法是：

SQL> DROP DATABASE DATABASE_NAME;

注意：要创建或删除，应该有数据库服务器上管理员权限。请注意，删除数据库将损失所有存储在数据库中的数据。

例子，删除我们刚刚建好的数据库：

SQL> DROP DATABASE EXAMPLE;

2.2.3 创建表

CREATE TABLE 语句用于创建一个新表。语法是：

SQL> CREATE TABLE table_name
(
   column_name column_data_type,
   column_name column_data_type
   ...
);

例子，下面的 SQL 语句创建一个有四个属性的 Students 表：

SQL> CREATE TABLE Students
(
   id INT NOT NULL,
   age INT NOT NULL,
   name VARCHAR(255),
   major VARCHAR(255),
   PRIMARY KEY ( id )
);

2.2.4 删除表

DROP TABLE 语句用于删除现有的表。语法是：

SQL> DROP TABLE table_name;

例子，下面的 SQL 语句删除一个名为 Students 表：

SQL> DROP TABLE Students;

2.2.5 插入数据

语法 INSERT 如下，其中 column1, column2 ，依此类推的属性值：

SQL> INSERT INTO table_name VALUES (column1, column2, ...);

例子，下面的 INSERT 语句中插入先前创建的 Students 表：

SQL> INSERT INTO Students VALUES (1, 18, 'Mumu', 'Java');

2.2.6 查询数据

SELECT 语句用于从数据库中检索数据。该语法的 SELECT 是：

SQL> SELECT column_name, column_name, ...
     FROM table_name
     WHERE conditions;

WHERE 子句可以使用比较操作符例如 =, !=, <, >, <=, >=, 以及 BETWEEN 和 LIKE 等操作符。

例子，下面的 SQL 语句从 Students 表选择 id 为 1 的学生，并将该学生的姓名和年龄显示出来：

SQL> SELECT name, age
     FROM Students
     WHERE id = 1;

下面的 SQL 语句从 Students 表中查询姓名中有?om?字样的学生，并将学生的姓名和专业显示出来：

SQL> SELECT name, major
     FROM Students
     WHERE name LIKE '%om%';

2.2.7 更新数据

UPDATE 语句用于更新数据。UPDATE 语法为：

SQL> UPDATE table_name
     SET column_name = value, column_name = value, ...
     WHERE conditions;

例子，下面的 SQL 的 UPDATE 语句表示将 ID 为 1 的学生的 age 改为 20：

SQL> UPDATE Students SET age=20 WHERE id=1;

2.2.8 删除数据

DELETE 语句用来删除表中的数据。语法 DELETE 是：

SQL> DELETE FROM table_name WHERE conditions;

例子，下面的 SQL DELETE 语句删除 ID 为 1 的学生的记录：

SQL> DELETE FROM Students WHERE id=1;

在本教程中，我们将使用 MySQL 数据库。实验楼已经为大家安装好了 mysql，无需大家再次安装。如需系统学习 mysql 请参考实验楼 mysql 的教程。在此我们回顾一下 mysql 的一些基本操作。

2.3.1 启动 mysql 服务器

sudo service mysql start

2.3.2 连接与断开数据库

连接数据库（实验楼中密码环境为空）：

mysql -u root

退出数据库：

mysql> exit

?接下来我们来学习如何编写一个真正的 JDBC 程序。我们先来浏览一下它的步骤，然后我们在后面的代码中作详细地讲解：

1、导入 JDBC 驱动 打开 terminal，输入命令获取驱动包

wget https://labfile.oss-internal.aliyuncs.com/courses/110/mysql-connector-java-5.1.47.jar

有了驱动就可以与数据库打开一个通信通道

2、打开连接：需要使用 DriverManager.getConnection() 方法创建一个 Connection 对象，它代表与数据库的物理连接

3、执行查询：需要使用类型声明的对象建立并提交一个 SQL 语句到数据库

4、从结果集中提取数据：要求使用适当的关于 ResultSet.getXXX() 方法来检索结果集的数据

5、处理结果集：对得到的结果集进行相关的操作

6、清理环境：需要明确地关闭所有的数据库资源，释放内存

例子：

1、先创建数据库和相应的内容：

sudo service mysql start
mysql -u root

create database EXAMPLE;
use EXAMPLE

create table Students
(
id int not null,
age int not null,
name varchar(255),
primary key(id)
);
insert into Students values(1,18,'Tom'),
(2,20,'Aby'),(4,20,'Tomson');

2、java 程序访问数据库

我们在project目录下创建文件JdbcTest.java

import java.sql.*;

public class JdbcTest {
   // JDBC 驱动器名称 和数据库地址
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
   //数据库的名称为 EXAMPLE
   static final String DB_URL = "jdbc:mysql://localhost/EXAMPLE";

   //  数据库用户和密码
   static final String USER = "root";

   static final String PASS = "";

   public static void main(String[] args) {
       Connection conn = null;
       Statement stmt = null;
       try{
           //注册 JDBC 驱动程序
           Class.forName("com.mysql.jdbc.Driver");

           //打开连接
           System.out.println("Connecting to database...");
           conn = DriverManager.getConnection(DB_URL,USER,PASS);

           //执行查询
           System.out.println("Creating statement...");
           stmt = conn.createStatement();
           String sql;
           sql = "SELECT id, name, age FROM Students";
           ResultSet rs = stmt.executeQuery(sql);

           //得到和处理结果集
           while(rs.next()){
               //检索
               int id  = rs.getInt("id");
               int age = rs.getInt("age");
               String name = rs.getString("name");

               //显示
               System.out.print("ID: " + id);
               System.out.print(", Age: " + age);
               System.out.print(", Name: " + name);
               System.out.println();
           }
           //清理环境
           rs.close();
           stmt.close();
           conn.close();
       }catch(SQLException se){
           // JDBC 操作错误
           se.printStackTrace();
       }catch(Exception e){
           // Class.forName 错误
           e.printStackTrace();
       }finally{
           //这里一般用来关闭资源的
           try{
               if(stmt!=null)
                   stmt.close();
           }catch(SQLException se2){
           }
           try{
               if(conn!=null)
                   conn.close();
           }catch(SQLException se){
               se.printStackTrace();
           }
       }
       System.out.println("Goodbye!");
   }
}

3、最后我们来看看结果吧：

使用命令编译并运行

javac -cp .:mysql-connector-java-5.1.47.jar JdbcTest.java
java -cp .:mysql-connector-java-5.1.47.jar JdbcTest

?