【JAVA基礎】JDBC編程——基於JAVA訪問數據庫

時間 2020-11-30

標籤 html java mysql sql 數據庫編程 dom post 學習網站欄目 Java 简体版

原文原文鏈接

0 前言

Java爲關係數據庫定義了一套標準的訪問接口：JDBC（Java Database Connectivity），使咱們能夠基於JDBC訪問數據庫，實現數據的增刪改查。html

本文將以PostgreSQL爲例，展現JDBC的一些基本操做，其中以實操代碼爲主，關於基本概念的講解詳見參考文獻。java

提示：在開始學習JDBC編程以前，務必先學習下SQL基礎。mysql

1 配置MAVEN

<dependency>
   <groupId>org.postgresql</groupId>
   <artifactId>postgresql</artifactId>
   <version>42.2.18</version>
   <scope>runtime</scope>
</dependency>

<dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
    <version>3.4.5</version>
</dependency>

配置項包括兩個jar包：
一、postgresql：PostgreSQL的JDBC驅動
二、HikariCP：JDBC鏈接池（javax.sql.DataSource）的實現類sql

注意:
postgresql中的scope應該爲runtime，由於只在運行期才使用。若是把runtime改爲compile，雖然也能正常編譯，可是在IDE裏寫程序的時候，會多出來一大堆相似com.mysql.jdbc.Connection這樣的類，很是容易與Java標準庫的JDBC接口混淆，因此堅定不要設置爲compile。數據庫

2 鏈接數據庫

import java.sql.*;
public class Test {
    // JDBC鏈接的URL, 不一樣數據庫有不一樣的格式:
    static final String URL = "jdbc:postgresql://localhost:3306/test";
    static final String USER = "sde";
    static final String PASSWORD = "123456";
    public static void main(String[] args) {
        // 獲取鏈接:
        try (Connection conn = DriverManager.getConnection(URL, USER, PASSWORD)) {
            System.out.println("數據庫鏈接成功！");
        }catch(SQLException e){
            e.printStackTrace();
        }
    }
}

核心代碼是DriverManager提供的靜態方法getConnection()。DriverManager會自動掃描classpath，找到全部的JDBC驅動，而後根據咱們傳入的URL自動挑選一個合適的驅動。由於JDBC鏈接是一種昂貴的資源，因此使用後要及時釋放（經過try-with-resources的方式）。編程

注意：代碼中的URL、USER、PASSWORD是數據庫的信息，填寫你本身的。dom

3 建立表

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class Test {
    // 不一樣數據庫有不一樣的格式
    static final String URL = "jdbc:postgresql://localhost:3306/test";
    static final String USER = "sde";
    static final String PASSWORD = "123456";
    public static void main(String[] args) {
        // 獲取鏈接:
        try (Connection conn = DriverManager.getConnection(URL, USER, PASSWORD)) {
            // Statement對象用於執行SQL語句
            try (Statement stmt = conn.createStatement()) {
                String sql = "CREATE TABLE public.javaBuild" +
                        " (id serial PRIMARY KEY NOT NULL," +
                        " name text ," +
                        " age  int," +
                        " gender char(1))";
                stmt.executeUpdate(sql);
            }
            System.out.println("JAVA建表成功！");
        }catch(SQLException e){
            e.printStackTrace();
        }
    }
}

Postgre 中主鍵設定爲serial類型，在後續插入時，主鍵就會自增。post

4 增刪改查

import java.sql.*;
public class Test {
    // 不一樣數據庫有不一樣的格式
    static final String URL = "jdbc:postgresql://localhost:3306/test";
    static final String USER = "sde";
    static final String PASSWORD = "123456";
    public static void main(String[] args) {
        // 獲取鏈接:
        try (Connection conn = DriverManager.getConnection(URL, USER, PASSWORD)) {
            // Statement對象用於執行SQL語句
            try (Statement stmt = conn.createStatement()) {
                // 插入
                String sql = "INSERT INTO public.javaBuild (name,age,gender) VALUES ('Tom',12,'M'),('Ming',13,'W'),('Wang',12,'M')";
                stmt.executeUpdate(sql);
                // 刪除
                String delete = "DELETE FROM public.javaBuild WHERE name='Tom'";
                stmt.executeUpdate(delete);
                // 查詢
                String query= "SELECT * FROM public.javaBuild";
                try (ResultSet rs = stmt.executeQuery(query)) {
                    while (rs.next()) {
                        System.out.println(rs.getInt("id") + rs.getString("name") + rs.getInt("age") + rs.getInt("gender"));
                    }
                }
            }
        }catch(SQLException e){
            e.printStackTrace();
        }
    }
}

注意：學習

Statment和ResultSet都是須要關閉的資源。
數據庫的索引是從1開始，而不是0。

使用Statement拼字符串很是容易引起SQL注入的問題，這是由於SQL參數每每是從方法參數傳入的（案例詳見參考文獻2）。所以，使用Java對數據庫進行操做時，必須使用PreparedStatement，嚴禁任何經過參數拼字符串的代碼！網站

具體代碼以下：

import java.sql.*;
public class Test {
    // JDBC鏈接的URL, 不一樣數據庫有不一樣的格式:
    static final String URL = "jdbc:postgresql://localhost:3306/test";
    static final String USER = "sde";
    static final String PASSWORD = "123456";
    public static void main(String[] args) {
        // 初始化須要插入的數據
        Student[] students=new Student[]{new Student("Tom",12,"M"),
                new Student("Ming",13,"W"),new Student("Wang",12,"M")};
        // 獲取鏈接:
        try (Connection conn = DriverManager.getConnection(URL, USER, PASSWORD)) {
            // 插入，其中?表示佔位符
            try (PreparedStatement ps = conn.prepareStatement("INSERT INTO public.javaBuild (name,age,gender) VALUES (?,?,?)")) {
                // 對同一個PreparedStatement反覆設置參數並調用addBatch():
                for (Student student:students){
                    // 設置對應占位符的值
                    ps.setObject(1,student.getName());
                    ps.setObject(2,student.getAge());
                    ps.setObject(3,student.getGender());
                    // 將每一個完整的插入語句放進Batch
 ps.addBatch();
                }
                // 執行batch:
                int[] ns = ps.executeBatch();
                for (int n : ns) {
                    // batch中每一個SQL執行的結果數量
                    System.out.println(n + " has been inserted.");
                }
            }
            // 刪除
            try (PreparedStatement ps = conn.prepareStatement("DELETE FROM public.javaBuild WHERE name='Tom'")) {
                int n = ps.executeUpdate();
                System.out.println(n + " has been deleted.");
            }
            // 查詢
            try (PreparedStatement ps = conn.prepareStatement("SELECT * FROM public.javaBuild")) {
                try (ResultSet rs = ps.executeQuery()) {
                    while (rs.next()) {
                        System.out.println(rs.getInt("id") + rs.getString("name") + rs.getInt("age")+rs.getString("gender"));
                    }
                }
            }
        }catch(SQLException e){
            e.printStackTrace();
        }
    }
}
class Student{
    private String name;
    private int age;
    private String gender;
    public Student(String name, int age, String gender) {
        this.name = name;
        this.age = age;
        this.gender = gender;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    public String getGender() {
        return gender;
    }
    public void setGender(String gender) {
        this.gender = gender;
    }
}

5 事務

在執行SQL語句的時候，某些業務要求，一系列操做必須所有執行，而不能僅執行一部分。

package com.navinfo.csu.domain.broker.htf.jdbcTest;
import scala.xml.Null;
import java.sql.*;
public class Test {
    // JDBC鏈接的URL, 不一樣數據庫有不一樣的格式:
    static final String URL = "jdbc:postgresql://localhost:3306/test";
    static final String USER = "sde";
    static final String PASSWORD = "123456";
    public static void main(String[] args) throws SQLException {
        Connection conn = null;
        Savepoint savepoint =null;
        try{
            // 獲取鏈接
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
            // 設定隔離級別
            conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
            // 關閉自動提交，至關於SQL語句中的BEGAIN
            conn.setAutoCommit(false);
            // 插入操做1
            try (PreparedStatement ps = conn.prepareStatement("INSERT INTO public.javaBuild (name,age,gender) VALUES ('Huang',12,'M')")) {
                ps.executeUpdate();
            }
            // 設置保存點
            savepoint = conn.setSavepoint("Savepoint");
            // 插入操做2
            try (PreparedStatement ps = conn.prepareStatement("INSERT INTO public.javaBuild (name,age,gender) VALUES ('Dong',12,11111)")) {
                ps.executeUpdate();
            }
            // 提交事務
 conn.commit();
            // 查詢
 try (PreparedStatement ps = conn.prepareStatement("SELECT * FROM public.javaBuild")) {
                try (ResultSet rs = ps.executeQuery()) {
                    while (rs.next()) {
                        System.out.println(rs.getInt("id") + rs.getString("name") + rs.getInt("age")+rs.getString("gender"));
                    }
                }
            }
        }catch(SQLException e){
            e.printStackTrace();
            // 回滾事務
 if (conn != null){
                conn.rollback(savepoint);
            }
        }finally {
            if (conn != null) {
                conn.setAutoCommit(true);
                conn.close();
            }
        }
    }
}

默認狀況下，咱們獲取到Connection鏈接後，老是處於「自動提交」模式，也就是每執行一條SQL都是做爲事務自動執行的，即默認爲「隱式事務」。只要關閉了Connection的autoCommit，那麼就能夠在一個事務中執行多條語句，事務以commit()方法結束。

MySQL的默認隔離級別是REPEATABLE READ。

setSavepoint()能夠記錄保存點，當出現異常時，能夠回滾到指定的保存點。

6 鏈接池

在執行JDBC的增刪改查的操做時，若是每一次操做都來一次打開鏈接，操做，關閉鏈接，那麼建立和銷燬JDBC鏈接的開銷就太大了。爲了不頻繁地建立和銷燬JDBC鏈接，咱們能夠經過鏈接池（Connection Pool）複用已經建立好的鏈接。

JDBC鏈接池有一個標準的接口javax.sql.DataSource，注意這個類位於Java標準庫中，但僅僅是接口。要使用JDBC鏈接池，咱們必須選擇一個JDBC鏈接池的實現。經常使用的JDBC鏈接池有：

HikariCP
C3P0
BoneCP
Druid

目前使用最普遍的是HikariCP，代碼案例以下：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import javax.sql.DataSource;
import java.sql.*;
public class Test {
    // JDBC鏈接的URL, 不一樣數據庫有不一樣的格式:
    static final String URL = "jdbc:postgresql://localhost:3306/test";
    static final String USER = "sde";
    static final String PASSWORD = "123456";
    static public HikariConfig config = new HikariConfig();
    public static void main(String[] args) {
        // 初始化鏈接池
        config.setJdbcUrl(URL);
        config.setUsername(USER);
        config.setPassword(PASSWORD);
        config.addDataSourceProperty("connectionTimeout", "1000"); // 鏈接超時：1秒
        config.addDataSourceProperty("idleTimeout", "60000"); // 空閒超時：60秒
        config.addDataSourceProperty("maximumPoolSize", "10"); // 最大鏈接數：10
        DataSource ds = new HikariDataSource(config);
        
        // 獲取鏈接，把DriverManage.getConnection()改成ds.getConnection()
        try (Connection conn = ds.getConnection()) {
            // 查詢
            try (PreparedStatement ps = conn.prepareStatement("SELECT * FROM public.javaBuild")) {
                try (ResultSet rs = ps.executeQuery()) {
                    while (rs.next()) {
                        System.out.println(rs.getInt("id") + rs.getString("name") + rs.getInt("age")+rs.getString("gender"));
                    }
                }
            }
        }catch(SQLException e){
            e.printStackTrace();
        }
    }
}

當咱們調用conn.close()方法時（在try(resource){...}結束處），不是真正「關閉」鏈接，而是釋放到鏈接池中，以便下次獲取鏈接時能直接返回。

所以，鏈接池內部維護了若干個Connection實例，若是調用ds.getConnection()，就選擇一個空閒鏈接，並標記它爲「正在使用」而後返回，若是對Connection調用close()，那麼就把鏈接再次標記爲「空閒」從而等待下次調用。這樣一來，咱們就經過鏈接池維護了少許鏈接，但能夠頻繁地執行大量的SQL語句。