6

我有这段代码试图在数据库中插入一条记录：

try {
 Connection conn = getConnection();

 String sql = 
   "INSERT INTO myTable(userId,content,timestamp) VALUES(?,?,NOW())";
 PreparedStatement st = 
    conn.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);

 st.setLong(1, userId);
 st.setString(2, content);
 id = st.executeUpdate(); //this is the problem line            
} catch(Exception e) {}

问题是，虽然记录插入正确，但我想id包含刚刚插入的记录的主键 + auto_increment id。但是，由于某种原因，它总是返回 '1' 作为 id，可能是因为userId在插入期间 的值为 1。

我的表是 InnoDB。起初userId是另一个表的外键，因为我已经删除了外键甚至 userId 列上的索引，但我仍然得到 1 作为返回值。

任何想法我做错了什么？

4

5 回答 5

8

PreparedStatment.executeUpdate()

返回：
(1) SQL 数据操作语言 (DML) 语句的行数或 (2) 0 用于不返回任何内容的 SQL 语句

您需要使用execute()并获得ResultSetwith getGeneratedKeys(); 它将包含您想要的数据。

编辑添加：我读了你的问题，因为表中有一个自动增量字段不是 userId

于 2013-02-13T01:19:40.250 回答
7

Brian Roach 接受的答案是正确的。我正在添加一些想法和一个带有完整代码的示例。

RETURN_GENERATED_KEYS并不意味着“返回生成的密钥”</h1 >

原来的海报似乎被国旗的措辞弄糊涂了，这是可以理解的Statement.RETURN_GENERATED_KEYS。与直觉相反，传递此标志不会改变方法的行为PreparedStatement::executeUpdate。该方法总是返回一个int，即受执​​行的 SQL 影响的行数。“executeUpdate”方法从不返回生成的密钥。

int countRowsAffected = pstmt.executeUpdate();  // Always return number of rows affected, *not* the generated keys.

问，你就会收到

如果您想要生成的密钥，您必须执行两个步骤：

  1. 传递旗帜，然后
  2. 请求ResultSet由仅包含生成的键值的行组成。

这种安排允许您添加取回生成的键的行为，同时保持其他所需的行为，计算受影响的行数。

示例代码

这是一个几乎真实的示例，取自 Java 8 应用程序，该应用程序从数据馈送中抓取数据。我认为在这种情况下，一个完整的例子可能比一个最小的例子更有用。

次要细节……这段代码在语法或其他方面可能并不完美，因为我复制粘贴修改过的真实源代码。我使用UUID 数据类型而不是整数作为表的代理主键。这些课程是我自己的CharHelper，DBHelper这里的细节并不重要。x和y变量是我自己的应用程序有意义的数据的替代品。我的日志调用是对SLF4J框架进行的。UUID 十六进制字符串是将日志中的报告链接回原始源代码的便捷方式。数据库是Postgres，但这种代码应该适用于任何支持生成密钥报告的数据库。

public UUID dbWrite (  String x , String y , DateTime whenRetrievedArg ) {
    if ( whenRetrievedArg == null ) {
        logger.error( "Passed null for whenRetrievedArg. Message # 2112ed1a-4612-4d5d-8cc5-bf27087a350d." );
        return null;
    }

    Boolean rowInsertComplete = Boolean.FALSE; // Might be used for debugging or logging or some logic in other copy-pasted methods.

    String method = "Method 'dbWrite'";
    String message = "Insert row for some_table_ in " + method + ". Message # edbea872-d3ed-489c-94e8-106a8e3b58f7.";
    this.logger.trace( message );

    String tableName = "some_table_";

    java.sql.Timestamp tsWhenRetrieved = new java.sql.Timestamp( whenRetrievedArg.getMillis() );  // Convert Joda-Time DatTime object to a java.sql.Timestamp object.

    UUID uuidNew = null;

    StringBuilder sql = new StringBuilder( AbstractPersister.INITIAL_CAPACITY_OF_SQL_STRING ); // private final static Integer INITIAL_CAPACITY_OF_SQL_STRING = 1024;
    sql.append( "INSERT INTO " ).append( tableName ).append( CharHelper.CHAR.PAREN_OPEN_SPACED ).append( " x_ , y_ " ).append( CharHelper.CHAR.PAREN_CLOSED ).append( DBHelper.SQL_NEWLINE );
    sql.append( "VALUES ( ? , ? , ?  ) " ).append( DBHelper.SQL_NEWLINE );
    sql.append( ";" );

    try ( Connection conn = DBHelper.instance().dataSource().getConnection() ;

在这里，我们执行第 1 步，传递RETURN_GENERATED_KEYS标志。

            PreparedStatement pstmt = conn.prepareStatement( sql.toString() , Statement.RETURN_GENERATED_KEYS ); ) {

我们继续准备和执行语句。请注意，int countRows = pstmt.executeUpdate();返回受影响行的计数，而不是生成的键。

        pstmt.setString( 1 , x ); 
        pstmt.setString( 2 , y ); 
        pstmt.setTimestamp( 3 , tsWhenRetrieved );  
        // Execute
        int countRows = pstmt.executeUpdate();  // Always returns an int, a count of affected rows. Does *not* return the generated keys.
        if ( countRows == 0 ) {  // Bad.
            this.logger.error( "Insert into database for new " + tableName + " failed to affect any rows. Message # 67e8de7e-67a5-42a6-a4fc-06929211e6e3." );
        } else if ( countRows == 1 ) {  // Good.
            rowInsertComplete = Boolean.TRUE;
        } else if ( countRows > 1 ) {  // Bad.
            rowInsertComplete = Boolean.TRUE;
            this.logger.error( "Insert into database for new " + tableName + " failed, affecting more than one row. Should not be possible. Message # a366e215-6cf2-4e5c-8443-0b5d537cbd68." );
        } else { // Impossible.
            this.logger.error( "Should never reach this Case-Else with countRows value " + countRows + " Message # 48af80d4-6f50-4c52-8ea8-98856873f3bb." );
        }

在这里，我们执行第 2 步，请求生成密钥的 ResultSet。在此示例中，我们插入了一行并期望返回一个生成的密钥。

        if ( rowInsertComplete ) {
            // Return new row’s primary key value.
            ResultSet genKeys = pstmt.getGeneratedKeys();
            if ( genKeys.next() ) {
                uuidNew = ( UUID ) genKeys.getObject( 1 );  // ResultSet should have exactly one column, the primary key of INSERT table.
            } else {
                logger.error( "Failed to get a generated key returned from database INSERT. Message # 6426843e-30b6-4237-b110-ec93faf7537d." );
            }
        }

剩下的就是错误处理和清理。请注意，我们在此代码的底部返回 UUID ，即插入记录的生成主键。

    } catch ( SQLException ex ) {
        // We expect to have occasional violations of unique constraint on this table in this data-scraping app.
        String sqlState = ex.getSQLState();
        if ( sqlState.equals( DBHelper.SQL_STATE.POSTGRES.UNIQUE_CONSTRAINT_VIOLATION ) ) {  // SqlState code '23505' = 'unique_violation'.
            this.logger.trace( "Found existing row when inserting a '" + tableName + "' row for y: " + y + ". Expected to happen on most attempts. Message # 0131e8aa-0bf6-4d19-b1b3-2ed9d333df27." );
            return null; // Bail out.
        } else { // Else any other exception, throw it.
            this.logger.error( "SQLException during: " + method + " for table: " + tableName + ", for y: " + y + ". Message # 67908d00-2a5f-4e4e-815c-5e5a480d614b.\n" + ex );
            return null; // Bail out.
        }
    } catch ( Exception ex ) {
        this.logger.error( "Exception during: " + method + " for table: " + tableName + ", for y: " + y + ". Message # eecc25d8-de38-458a-bb46-bd6f33117969.\n" + ex );
        return null;  // Bail out.
    }

    if ( uuidNew == null ) {
        logger.error( "Returning a null uuidNew var. SQL: {} \nMessage # 92e2374b-8095-4557-a4ed-291652c210ae." , sql );
    }
    return uuidNew;
}
于 2015-07-17T06:57:58.987 回答
2 
String SQLQuery=" ";

String generatedKeys[]= {"column_name"};//'column_name' auto-increment column

prepSt = Connection.prepareStatement(SQLQuery,generatedKeys);

prepSt.setInt(1, 1234); 

.....

.....

....


prepSt.executeUpdate();

ResultSet rs = prepSt.getGeneratedKeys; // used same PreparedStatement object as used   for Insert .


if(rs.next()) {


int id=rs.getLong("column_name");


System.out.println(id);


}
} catch (SQLException e) {
}
于 2014-04-27T22:04:09.917 回答
1

你得到的是“插入行”的通知（对于 INSERT 语句）。我们使用这种方法来知道我们的 DML 查询是否成功。以下是使用 [prepareStatement(yourSQL, Statement.RETURN_GENERATED_KEYS)] 获取自动生成 ID 的方法。请注意，此方法仅返回您一个 RowID 参考。要获得实际 val，请参考方法 2。

（方法一）

Try{
String yourSQL="insert into Table1(Id,Col2,Col3) values(SEQ.nextval,?,?)";
myPrepStatement = <Connection>.prepareStatement(yourSQL, Statement.RETURN_GENERATED_KEYS);
myPrepStatement.setInt(1, 123); 
myPrepStatement.setInt(2, 123); 

myPrepStatement.executeUpdate();
ResultSet rs = getGeneratedKeys;
if(rs.next()) {
  java.sql.RowId rid=rs.getRowId(1); 
  //what you get is only a RowId ref, try make use of it anyway U could think of
  System.out.println(rid);
}
} catch (SQLException e) {
}

（方法二）

Try{
String yourSQL="insert into Table1(Id,Col2,Col3) values(SEQ.nextval,?,?)";
//IMPORTANT: here's where other threads don tell U, you need to list ALL cols 
//mentioned in your query in the array
myPrepStatement = <Connection>.prepareStatement(yourSQL, new String[]{"Id","Col2","Col3"});
myPrepStatement.setInt(1, 123); 
myPrepStatement.setInt(2, 123); 
myPrepStatement.executeUpdate();
ResultSet rs = getGeneratedKeys;
if(rs.next()) {
//In this exp, the autoKey val is in 1st col
  int id=rs.getLong(1);
  //now this's a real value of col Id
  System.out.println(id);
}
} catch (SQLException e) {
}

基本上，如果您只想要 SEQ.Nextval 的值，请尝试不使用 Method1，b'cse 它只返回 RowID ref，您可能会想办法使用它，这也不适合您尝试转换的所有数据类型它到！这在 MySQL、DB2 中可能工作正常（返回实际 val），但在 Oracle 中不行。

重要提示：在调试时关闭 SQL Developer、Toad 或任何使用相同登录会话执行 INSERT 的客户端。它可能不会每次都影响你（调试调用）......直到你发现你的应用程序无一例外地冻结了一段时间。是的……毫无例外地停止！

于 2013-06-24T08:09:00.797 回答
1

如果您已userId在数据库中设置了自动增量，则不应尝试自行添加。你应该插入NULL，它会为你自动增加！（线索就在名字里！）

此外，您不是在更新您的表格，而是在插入表格。所以你不执行Update()。尝试...

PreparedStatement pst = conn.prepareStatement("INSERT INTO myTable(userId,content,timestamp) VALUES(NULL,?,NOW())");
pst.setString(1, content);
pst.executeQuery();
于 2013-02-13T01:20:35.723 回答