JDBC中如何获取插入ID？

Question

我想使用 Java 中的 JDBC 在数据库（在我的例子中是 Microsoft SQL Server）中INSERT一条记录。同时我想获取插入ID。如何使用 JDBC API 实现此目的？

Answer 1

如果它是自动生成的密钥，那么您可以使用 Statement#getGenerateKeys() 为此。您需要在与用于 INSERT 的语句相同的 Statement 上调用它。您首先需要使用Statement.RETURN_GENERATED_KEYS 通知 JDBC 驱动程序返回密钥。

下面是一个基本示例：

public void create(User user) throws SQLException {
    try (
        Connection connection = dataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement(SQL_INSERT,
                                      Statement.RETURN_GENERATED_KEYS);
    ) {
        statement.setString(1, user.getName());
        statement.setString(2, user.getPassword());
        statement.setString(3, user.getEmail());
        // ...

        int affectedRows = statement.executeUpdate();

        if (affectedRows == 0) {
            throw new SQLException("Creating user failed, no rows affected.");
        }

        try (ResultSet generatedKeys = statement.getGeneratedKeys()) {
            if (generatedKeys.next()) {
                user.setId(generatedKeys.getLong(1));
            }
            else {
                throw new SQLException("Creating user failed, no ID obtained.");
            }
        }
    }
}

请注意，您依赖 JDBC 驱动程序来确定它是否有效。目前，大多数最新版本都可以工作，但如果我是正确的，Oracle JDBC 驱动程序在这方面仍然有些麻烦。 MySQL 和 DB2 已经支持它很长时间了。 PostgreSQL不久前开始支持它。我无法评论 MSSQL，因为我从未使用过它。

对于 Oracle，您可以使用 RETURNING 子句或 SELECT CURRVAL(sequencename)（或任何特定于数据库的语法来执行此操作）调用 CallableStatement ) 直接在同一事务中的 INSERT 之后获取最后生成的密钥。另请参阅此答案。

Answer 2

1. 创建生成列

   String generatedColumns[] = { "ID" };
   

2. 将此生成的列传递到您的语句

   PreparedStatement stmtInsert = conn.prepareStatement(insertSQL, generatedColumns);
   

3. 使用ResultSet对象获取语句上的GenerateKeys

   ResultSet rs = stmtInsert.getGenerateKeys();
   
   如果 (rs.next()) {
       长 id = rs.getLong(1);
       System.out.println("插入的ID -" + id); // 显示插入的记录
   }
   

Answer 3

使用 Statement.RETURN_GENERATED_KEYS 时遇到“不支持的功能”错误时，请尝试以下操作：

String[] returnId = { "BATCHID" };
String sql = "INSERT INTO BATCH (BATCHNAME) VALUES ('aaaaaaa')";
PreparedStatement statement = connection.prepareStatement(sql, returnId);
int affectedRows = statement.executeUpdate();

if (affectedRows == 0) {
    throw new SQLException("Creating user failed, no rows affected.");
}

try (ResultSet rs = statement.getGeneratedKeys()) {
    if (rs.next()) {
        System.out.println(rs.getInt(1));
    }
    rs.close();
}

其中 BATCHID 是自动生成的 ID。

Answer 4

我从基于 JDBC 的单线程应用程序访问 Microsoft SQL Server 2008 R2，并在不使用 RETURN_GENERATED_KEYS 属性或任何PreparedStatement 的情况下拉回最后一个 ID。看起来像这样：

private int insertQueryReturnInt(String SQLQy) {
    ResultSet generatedKeys = null;
    int generatedKey = -1;

    try {
        Statement statement = conn.createStatement();
        statement.execute(SQLQy);
    } catch (Exception e) {
        errorDescription = "Failed to insert SQL query: " + SQLQy + "( " + e.toString() + ")";
        return -1;
    }

    try {
        generatedKey = Integer.parseInt(readOneValue("SELECT @@IDENTITY"));
    } catch (Exception e) {
        errorDescription = "Failed to get ID of just-inserted SQL query: " + SQLQy + "( " + e.toString() + ")";
        return -1;
    }

    return generatedKey;
} 

这篇博客文章很好地隔离了三个主要的 SQL Server“最后 ID”选项：
http://msjawahar.wordpress.com/2008/01/25/how-to-find-the-last-identity-value-inserted-in-the-sql-server/ - 避风港'还不需要另外两个。

Answer 5

我只想回答，而不是 评论邮政。

---

接口java. sql.PreparedStatement

1. columnIndexes « 您可以使用接受columnIndexes 和SQL 语句的prepareStatement 函数。
   其中columnIndexes允许的常量标志是Statement.RETURN_GENERATED_KEYS1< /a> 或 Statement.NO_GENERATED_KEYS[2]，可能包含一个或多个“?”的 SQL 语句IN 参数占位符。

   语法 «

   Connection.prepareStatement(String sql, int autoGenerateKeys)
   Connection.prepareStatement(String sql, int[] columnIndexes)
   

   示例：

   PreparedStatement pstmt = 
       conn.prepareStatement( insertSQL, Statement.RETURN_GENERATED_KEYS );
   

---

2. columnNames « 列出列名称，如 'id'、'uniqueID'、...。在包含应返回的自动生成键的目标表中。如果 SQL 语句不是 INSERT 语句，驱动程序将忽略它们。

   语法 «

   Connection.prepareStatement(String sql, String[] columnNames)
   

   示例：

   String columnNames[] = new String[] { "id" };
   PreparedStatement pstmt = conn.prepareStatement( insertSQL, columnNames );
   

---

完整示例：

public static void insertAutoIncrement_SQL(String UserName, String Language, String Message) {
    String DB_URL = "jdbc:mysql://localhost:3306/test", DB_User = "root", DB_Password = "";

    String insertSQL = "INSERT INTO `unicodeinfo`( `UserName`, `Language`, `Message`) VALUES (?,?,?)";
            //"INSERT INTO `unicodeinfo`(`id`, `UserName`, `Language`, `Message`) VALUES (?,?,?,?)";
    int primkey = 0 ;
    try {
        Class.forName("com.mysql.jdbc.Driver").newInstance();
        Connection conn = DriverManager.getConnection(DB_URL, DB_User, DB_Password);

        String columnNames[] = new String[] { "id" };

        PreparedStatement pstmt = conn.prepareStatement( insertSQL, columnNames );
        pstmt.setString(1, UserName );
        pstmt.setString(2, Language );
        pstmt.setString(3, Message );

        if (pstmt.executeUpdate() > 0) {
            // Retrieves any auto-generated keys created as a result of executing this Statement object
            java.sql.ResultSet generatedKeys = pstmt.getGeneratedKeys();
            if ( generatedKeys.next() ) {
                primkey = generatedKeys.getInt(1);
            }
        }
        System.out.println("Record updated with id = "+primkey);
    } catch (InstantiationException | IllegalAccessException | ClassNotFoundException | SQLException e) {
        e.printStackTrace();
    }
}

Answer 6

我正在使用 SQLServer 2008，但我有一个开发限制：我无法为其使用新的驱动程序，我必须使用“com.microsoft.jdbc.sqlserver.SQLServerDriver”（我无法使用“ com.microsoft.sqlserver.jdbc.SQLServerDriver”）。

这就是为什么解决方案 conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS) 为我引发了 java.lang.AbstractMethodError 。
在这种情况下，我发现的一种可能的解决方案是微软建议的旧方案：
如何使用 JDBC 检索 @@IDENTITY 值

import java.sql.*; 
import java.io.*; 

public class IdentitySample
{
    public static void main(String args[])
    {
        try
        {
            String URL = "jdbc:microsoft:sqlserver://yourServer:1433;databasename=pubs";
            String userName = "yourUser";
            String password = "yourPassword";

            System.out.println( "Trying to connect to: " + URL); 

            //Register JDBC Driver
            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();

            //Connect to SQL Server
            Connection con = null;
            con = DriverManager.getConnection(URL,userName,password);
            System.out.println("Successfully connected to server"); 

            //Create statement and Execute using either a stored procecure or batch statement
            CallableStatement callstmt = null;

            callstmt = con.prepareCall("INSERT INTO myIdentTable (col2) VALUES (?);SELECT @@IDENTITY");
            callstmt.setString(1, "testInputBatch");
            System.out.println("Batch statement successfully executed"); 
            callstmt.execute();

            int iUpdCount = callstmt.getUpdateCount();
            boolean bMoreResults = true;
            ResultSet rs = null;
            int myIdentVal = -1; //to store the @@IDENTITY

            //While there are still more results or update counts
            //available, continue processing resultsets
            while (bMoreResults || iUpdCount!=-1)
            {           
                //NOTE: in order for output parameters to be available,
                //all resultsets must be processed

                rs = callstmt.getResultSet();                   

                //if rs is not null, we know we can get the results from the SELECT @@IDENTITY
                if (rs != null)
                {
                    rs.next();
                    myIdentVal = rs.getInt(1);
                }                   

                //Do something with the results here (not shown)

                //get the next resultset, if there is one
                //this call also implicitly closes the previously obtained ResultSet
                bMoreResults = callstmt.getMoreResults();
                iUpdCount = callstmt.getUpdateCount();
            }

            System.out.println( "@@IDENTITY is: " + myIdentVal);        

            //Close statement and connection 
            callstmt.close();
            con.close();
        }
        catch (Exception ex)
        {
            ex.printStackTrace();
        }

        try
        {
            System.out.println("Press any key to quit...");
            System.in.read();
        }
        catch (Exception e)
        {
        }
    }
}

这个解决方案对我有用！

我希望这有帮助！

Answer 7

您可以使用以下 java 代码来获取新插入的 id。

ps = con.prepareStatement(query, Statement.RETURN_GENERATED_KEYS);
ps.setInt(1, quizid);
ps.setInt(2, userid);
ps.executeUpdate();

ResultSet rs = ps.getGeneratedKeys();
if (rs.next()) {
    lastInsertId = rs.getInt(1);
}

Answer 8

也可以将其与普通的 Statement 一起使用（不仅仅是 PreparedStatement）

Statement statement = conn.createStatement();
int updateCount = statement.executeUpdate("insert into x...)", Statement.RETURN_GENERATED_KEYS);
try (ResultSet generatedKeys = statement.getGeneratedKeys()) {
  if (generatedKeys.next()) {
    return generatedKeys.getLong(1);
  }
  else {
    throw new SQLException("Creating failed, no ID obtained.");
  }
}

Answer 9

使用 Hibernate 的 NativeQuery，您需要返回 ResultList 而不是 SingleResult，因为 Hibernate 会修改本机查询，

INSERT INTO bla (a,b) VALUES (2,3) RETURNING id

就像

INSERT INTO bla (a,b) VALUES (2,3) RETURNING id LIMIT 1

您尝试获取单个结果一样，这会导致大多数数据库（至少是 PostgreSQL）抛出语法错误。然后，您可以从列表（通常仅包含一项）中获取结果 id。

Answer 10

大多数其他人建议为此使用 JDBC API，但就我个人而言，我发现对于大多数驱动程序来说这非常痛苦。事实上，您可以只使用本机 T-SQL 功能，OUTPUT 子句：

try (
    Statement s = c.createStatement();
    ResultSet rs = s.executeQuery(
        """
        INSERT INTO t (a, b)
        OUTPUT id
        VALUES (1, 2)
        """
    );
) {
    while (rs.next())
        System.out.println("ID = " + rs.getLong(1));
}

这是 SQL Server 以及其他一些 SQL 方言（例如 Firebird、 MariaDB、PostgreSQL，您可以在其中使用 RETURNING 而不是 OUTPUT）。

我在博客中详细介绍了此主题详细信息请参见此处。

Answer 11

就我而言 ->

ConnectionClass objConnectionClass=new ConnectionClass();
con=objConnectionClass.getDataBaseConnection();
pstmtGetAdd=con.prepareStatement(SQL_INSERT_ADDRESS_QUERY,Statement.RETURN_GENERATED_KEYS);
pstmtGetAdd.setString(1, objRegisterVO.getAddress());
pstmtGetAdd.setInt(2, Integer.parseInt(objRegisterVO.getCityId()));
int addId=pstmtGetAdd.executeUpdate();              
if(addId>0)
{
    ResultSet rsVal=pstmtGetAdd.getGeneratedKeys();
    rsVal.next();
    addId=rsVal.getInt(1);
}

Answer 12

如果您使用的是Spring JDBC，则可以使用Spring的生成Keyolder类来获取插入的ID。

看到这个答案...
如何使用Spring jdbctemplate jdbctemplate in .update（字符串SQL，obj ... args）

Answer 13

如果您使用的是JDBC（使用MySQL进行了测试），并且只需要使用最后的插入ID，则有一种简单的方法来获取它。我正在使用的方法如下：（

public static Integer insert(ConnectionImpl connection, String insertQuery){

    Integer lastInsertId = -1;
    try{
        final PreparedStatement ps = connection.prepareStatement(insertQuery);
        ps.executeUpdate(insertQuery);
        final com.mysql.jdbc.PreparedStatement psFinal = (com.mysql.jdbc.PreparedStatement) ps;
        lastInsertId = (int) psFinal.getLastInsertID();
        connection.close();
    } catch(SQLException ex){
        System.err.println("Error: "+ex);
    }

    return lastInsertId;
}

以及以防万一）获取 ConnectionImpl 的方法如下：

public static ConnectionImpl getConnectionImpl(){
    ConnectionImpl conexion = null;

    final String dbName = "database_name";
    final String dbPort = "3306";
    final String dbIPAddress = "127.0.0.1";
    final String connectionPath = "jdbc:mysql://"+dbIPAddress+":"+dbPort+"/"+dbName+"?autoReconnect=true&useSSL=false";
    
    final String dbUser = "database_user";
    final String dbPassword = "database_password";
    try{
        conexion = (ConnectionImpl) DriverManager.getConnection(connectionPath, dbUser, dbPassword);
    }catch(SQLException e){
        System.err.println(e);
    }
    
    return conexion;
}

请记住添加 connector/j 到引用的库中。

就我而言，连接器/J版本是5.1.42。也许如果要使用更现代的连接器/J（例如版本8.0.28），则必须对 ConnectionPath 应用一些更改。

在文件中，请记住导入以下资源：

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import com.mysql.jdbc.ConnectionImpl;

希望这会有所帮助。

Answer 14

您可以使用 executeQuery（query）函数

，然后添加返回 *子句到查询
指定列名称

而是*您可以为示例

create表第一个

CREATE TABLE users (id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL);

创建查询

val query: String = "INSERT INTO users (name) VALUES ("Bob"), ("Makr"), ("Adam") RETURNING id;"

应用查询

val statement = connection.prepareStatement(query)
val result = statement.executeQuery()
val keys = buildList {
    while (result.next()) { add(result.getLong(1)) }
}

键是您的结果。因此，您可以返回任何列集或完整对象

Answer 15

要获取 MSSQL 中表上最后插入的 ID，有多种选项：

我使用的是这个：

IDENT_CURRENT(‘TableName’)

还有一些其他选项，例如 SCOPE_IDENTITY() 和 @@IDENTITY也是如此，但上面的方法要容易得多。

示例：

String sql = "SELECT IDENT_CURRENT('TableName') AS ID;";
try ( ResultSet rs = con.execSQL (sql, sqlParameters)) {
    while (rs.next ()) {
        ret = rs.getInt ("ID");
    }
}
............

有关详细信息

我希望这有帮助......

Answer 16

Connection cn = DriverManager.getConnection("Host","user","pass");
Statement st = cn.createStatement("Ur Requet Sql");
int ret  = st.execute();