在创建表时,在某些情况下,我们需要自动生成/增加列的值(例如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对象。
您可以使用getGeneratedKeys()方法检索由当前Statement对象生成的特定列的值。
让我们使用CREATE语句在MySQL数据库中创建一个名称为sales的表,其中一列自动递增,如下所示-
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()方法或forName()
名为Class的类的方法注册所需数据库的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 { //注册驱动程序 DriverManager.registerDriver(new com.mysql.jdbc.Driver()); //Getting the connection String mysqlUrl = "jdbc:mysql://localhost/sample_database"; Connection con = DriverManager.getConnection(mysqlUrl, "root", "password"); System.out.println("Connection established......"); //创建Statement对象Statement stmt = con.createStatement(); //查询插入多行 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')"; //执行INSERT语句stmt.executeUpdate(insertQuery,Statement.RETURN_GENERATED_KEYS); System.out.println("Records inserted......"); //检索自动生成的(自动递增的)键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