如何使用 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://127.0.0.1/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
广告