如何使用 JDBC 獲取 Statement 生成的自動遞增值?


在建立表時,在某些情況下,我們需要為某些列(例如 ID)生成/自動遞增值。各種資料庫以不同的方式支援此功能。

在 **MySQL** 資料庫中,您可以使用以下語法宣告一個列為自動遞增。

CREATE TABLE table_name(
   ID INT PRIMARY KEY AUTO_INCREMENT,
   column_name1 data_type1,
   column_name2 data_type2,
   column_name3 data_type3,
   column_name4 data_type4,
   ............ ...........
);

在向表中插入記錄時,無需在自動遞增列下插入值。這些將自動生成。

例如,如果表中有一列名為 **ID**,資料型別為 INT,並且是自動遞增的,並且該表中已經有 6 條記錄。當您使用 INSERT 語句插入下一條記錄時,新記錄的 ID 值將為 7,其下一條記錄的 ID 值將為 8。

(您可以為這些自動遞增列指定初始值和間隔)。

檢索 Statement 物件生成的自動遞增值

如果您使用 **Statement** 物件將記錄插入到包含自動遞增列的表中。

您可以使用 **getGeneratedKeys()** 方法檢索當前 Statement 物件生成的該特定列的值。

示例

讓我們在 MySQL 資料庫中建立一個名為 **sales** 的表,其中一列為自動遞增,使用如下所示的 CREATE 語句:

CREATE TABLE Sales(
   ID INT PRIMARY KEY AUTO_INCREMENT,
   ProductName VARCHAR (20),
   CustomerName VARCHAR (20),
   DispatchDate date,
   DeliveryTime time,
   Price INT,
   Location VARCHAR(20)
);

現在,要透過使用 **Statement** 物件執行多行 INSERT 語句將多條記錄插入此表,並檢索由此生成的自動遞增值:

  • 使用 DriverManager 類的 **registerDriver()** 方法或名為 Class 的類的 forName() 方法註冊所需資料庫的 Driver 類。
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
  • 透過將資料庫的 URL、資料庫中使用者的使用者名稱和密碼(以字串格式)作為引數傳遞給 DriverManager 類的 **getConnection()** 方法,建立一個 Connection 物件。
Connection mysqlCon = DriverManager.getConnection(mysqlUrl, "root", "password");
  • 使用連線介面的 **createStatement()** 方法建立一個 **Statement** 物件。
//Creating the Statement object
Statement stmt = con.createStatement();
  • 使用 **executeUpdate()** 方法執行多行 INSERT 查詢。為此方法傳遞以字串格式的多行 **INSERT** 語句作為引數,以及 Statement.RETURN_GENERATED_KEYS 作為另一個引數,如下所示:
//Executing the INSERT statement
stmt.executeUpdate(insertQuery, Statement.RETURN_GENERATED_KEYS);
  • 最後,使用 **getGeneratedKeys()** 方法獲取此 PreparedStatement 物件生成的自動遞增鍵。
ResultSet rs = pstmt.getGeneratedKeys();
while (rs.next()) {
   System.out.println("rs.getInt(1));
}

以下 JDBC 程式使用 **Statement** 將 5 條記錄插入到 Sales 表(如上所述建立)中,並檢索並顯示由此生成的自動遞增值。

示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class RetrievingData_AutoIncrement {
   public static void main(String args[]) throws SQLException {
      //Registering the Driver
      DriverManager.registerDriver(new com.mysql.jdbc.Driver());
      //Getting the connection String mysqlUrl = "jdbc:mysql:///sample_database";
      Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
      System.out.println("Connection established......");
      //Creating the Statement object Statement stmt = con.createStatement();
      //Query to insert multiple rows
      String insertQuery = "insert into sales (ProductName, CustomerName, DispatchDate, DeliveryTime, Price, Location) values"
      + "('Key-Board', 'Raja', DATE('2019-09-01'), TIME('11:00:00'), 7000, 'India'), "
      + "('Earphones', 'Roja', DATE('2019-05-01'), TIME('11:00:00'), 2000, 'Vishakhapatnam'), "
      + "('Mouse', 'Puja', DATE('2019-03-01'), TIME('10:59:59'), 3000, 'Vijayawada'), "
      + "('Mobile', 'Vanaja', DATE('2019-03-01'), TIME('10:10:52'), 9000, 'Chennai'), "
      + "('Headset', 'Jalaja', DATE('2019-04-06'), TIME('11:08:59'), 6000, 'Goa')";
      //Executing the INSERT statement stmt.executeUpdate(insertQuery, Statement.RETURN_GENERATED_KEYS);
      System.out.println("Records inserted......");
      //Retrieving the auto-generated (auto-incremented) keys  ResultSet rs = stmt.getGeneratedKeys();
      System.out.println("Values of auto-generated keys: ");
      while(rs.next()) {
         System.out.println(rs.getInt(1));
      }
   }
}

輸出

Connection established......
Records inserted......
Values of generated keys:
1
2
3
4
5

更新於: 2019-07-30

227 次瀏覽

開啟你的 職業生涯

透過完成課程獲得認證

開始學習
廣告

© . All rights reserved.