JDBC驱动

用户下载 JDBC 驱动 并导入 jar 包后，即可以使用 JDBC 提供的 API。

示例

以下示例为通过 maven 工程使用 JDBC 进行简单的增删改查操作。

  1. 在 pom.xml 中添加 MySQL JDBC 驱动的依赖，以 mysql-connector-java-5.1.38 为例

    1. <dependencies>
    2.    <dependency>
    3.        <groupId>mysql</groupId>
    4.        <artifactId>mysql-connector-java</artifactId>
    5.        <version>5.1.38</version>
    6.    </dependency>
    7. </dependencies>

  2. 假设本地有默认安装的 MySQL 实例，存在 root 用户密码为 123456，连接到该实例并准备样例使用的数据库 db 和表 tb

    1. CREATE DATABASE db;
    2. USE db;
    3. CREATE TABLE tb (id INT, first_name VARCHAR(128), last_name VARCHAR(128));

  3. 在工程的 src/main/java/com/sequoiadb/sample 目录下添加 JdbcSample.java 文件。

    1. package com.sequoiadb.sample;
    3. import java.sql.*;
    5. public class JdbcSample {
    6. static {
    7.     try {
    8.         Class.forName("com.mysql.jdbc.Driver");
    9.     } catch (ClassNotFoundException e) {
    10.         e.printStackTrace();
    11.     }
    12. }
    14. public static void main(String[] args) throws SQLException {
    15.     String hostName = "127.0.0.1";
    16.     String port = "3306";
    17.     String databaseName = "db";
    18.     String myUser = "root";
    19.     String myPasswd = "123456";
    20.     String url = "jdbc:mysql://" + hostName + ":" + port + "/" + databaseName + "?useSSL=false";
    21.     Connection conn = DriverManager.getConnection(url, myUser, myPasswd);
    23.     System.out.println("---INSERT---");
    24.     String sql = "INSERT INTO tb VALUES(?,?,?)";
    25.     PreparedStatement ins = conn.prepareStatement(sql);
    26.     ins.setInt(1, 1);
    27.     ins.setString(2, "Peter");
    28.     ins.setString(3, "Parcker");
    29.     ins.executeUpdate();
    31.     System.out.println("---UPDATE---");
    32.     sql = "UPDATE tb SET first_name=? WHERE id = ?";
    33.     PreparedStatement upd = conn.prepareStatement(sql);
    34.     upd.setString(1, "Stephen");
    35.     upd.setInt(2, 1);
    36.     upd.executeUpdate();
    38.     System.out.println("---SELECT---");
    39.     Statement stmt = conn.createStatement();
    40.     sql = "SELECT * FROM tb";
    41.     ResultSet rs = stmt.executeQuery(sql);
    42.     boolean isHeaderPrint = false;
    43.     while (rs.next()) {
    44.         ResultSetMetaData md = rs.getMetaData();
    45.         int col_num = md.getColumnCount();
    46.         if (!isHeaderPrint) {
    47.             System.out.print("|");
    48.             for (int i = 1; i <= col_num; i++) {
    49.                 System.out.print(md.getColumnName(i) + "\t|");
    50.                 isHeaderPrint = true;
    51.             }
    52.         }
    53.         System.out.println();
    54.         System.out.print("|");
    55.         for (int i = 1; i <= col_num; i++) {
    56.             System.out.print(rs.getString(i) + "\t|");
    57.         }
    58.         System.out.println();
    59.     }
    60.     stmt.close();
    62.     System.out.println("---DELETE---");
    63.     sql = "DELETE FROM tb WHERE id = ?";
    64.     PreparedStatement del = conn.prepareStatement(sql);
    65.     del.setInt(1, 1);
    66.     del.executeUpdate();
    68.     conn.close();
    69.   }
    70. }

  4. 使用 maven 编译及运行

    1. $ mvn compile 
    2. $ mvn exec:java -Dexec.mainClass="com.sequoiadb.sample.JdbcSample"

    得到如下运行结果：

    1. ---INSERT---
    2. ---UPDATE---
    3. ---SELECT---
    4. |id  |first_name |last_name  |
    5. |1   |Stephen    |Parcker    |
    6. ---DELETE---