[java] Statement.RETURN_GENERATED_KEYS가있는 PreparedStatement

Program / 글쓴이

일부 JDBC 드라이버가 반환하는 유일한 방법 Statement.RETURN_GENERATED_KEYS은 다음 중 하나를 수행하는 것입니다.

long key = -1L;
Statement statement = connection.createStatement();
statement.executeUpdate(YOUR_SQL_HERE, Statement.RETURN_GENERATED_KEYS);
ResultSet rs = statement.getGeneratedKeys();
if (rs != null && rs.next()) {
    key = rs.getLong(1);
}

똑같이 할 수있는 방법이 PreparedStatement있습니까?

편집하다

내가 똑같이 할 수 있는지 물은 이유 PreparedStatement는 다음 시나리오 를 고려하십시오.

private static final String SQL_CREATE =
            "INSERT INTO
            USER(FIRST_NAME, MIDDLE_NAME, LAST_NAME, EMAIL_ADDRESS, DOB)
            VALUES (?, ?, ?, ?, ?)";

에서 USER표 A 거기 PRIMARY KEY (USER_ID)a는이다 BIGINT AUTOINCREMENT(따라서 왜 당신은 그것을 볼 수 없습니다 SQL_CREATE문자열.

이제 ?사용하여 PreparedStatement.setXXXX(index, value). 나는 돌아가고 싶다 ResultSet rs = PreparedStatement.getGeneratedKeys(). 어떻게하면 되나요?

답변

prepareStatement추가 int매개 변수를 사용하는 방법을 사용할 수 있습니다.

PreparedStatement ps = con.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)

일부 JDBC 드라이버 (예 : Oracle)의 경우 생성 된 키의 열 이름 또는 인덱스를 명시 적으로 나열해야합니다.

PreparedStatement ps = con.prepareStatement(sql, new String[]{"USER_ID"})

답변

이런 뜻인가요? 

long key = -1L;

PreparedStatement preparedStatement = connection.prepareStatement(YOUR_SQL_HERE, PreparedStatement.RETURN_GENERATED_KEYS);
preparedStatement.setXXX(index, VALUE);
preparedStatement.executeUpdate();

ResultSet rs = preparedStatement.getGeneratedKeys();

if (rs.next()) {
    key = rs.getLong(1);
}

답변

지금 내가 컴파일러를 가지고 있지 않다면 질문으로 대답하겠습니다.

이거 해봤 어? 작동합니까?

long key = -1L;
PreparedStatement statement = connection.prepareStatement();
statement.executeUpdate(YOUR_SQL_HERE, PreparedStatement.RETURN_GENERATED_KEYS);
ResultSet rs = statement.getGeneratedKeys();
if (rs != null && rs.next()) {
    key = rs.getLong(1);
}

면책 조항 : 분명히, 나는 이것을 컴파일하지 않았지만 당신은 아이디어를 얻었습니다.

PreparedStatement 는 Statement 의 하위 인터페이스 이므로 일부 JDBC 드라이버가 버그가 아닌 경우 이것이 작동하지 않는 이유를 알 수 없습니다.

답변

String query = "INSERT INTO ....";
PreparedStatement preparedStatement = connection.prepareStatement(query, PreparedStatement.RETURN_GENERATED_KEYS);

preparedStatement.setXXX(1, VALUE);
preparedStatement.setXXX(2, VALUE);
....
preparedStatement.executeUpdate();

ResultSet rs = preparedStatement.getGeneratedKeys();
int key = rs.next() ? rs.getInt(1) : 0;

if(key!=0){
    System.out.println("Generated key="+key);
}

답변

private void alarmEventInsert(DriveDetail driveDetail, String vehicleRegNo, int organizationId) {

    final String ALARM_EVENT_INS_SQL = "INSERT INTO alarm_event (event_code,param1,param2,org_id,created_time) VALUES (?,?,?,?,?)";
    CachedConnection conn = JDatabaseManager.getConnection();
    PreparedStatement ps = null;
    ResultSet generatedKeys = null;
    try {
        ps = conn.prepareStatement(ALARM_EVENT_INS_SQL, ps.RETURN_GENERATED_KEYS);
        ps.setInt(1, driveDetail.getEventCode());
        ps.setString(2, vehicleRegNo);
        ps.setString(3, null);
        ps.setInt(4, organizationId);
        ps.setString(5, driveDetail.getCreateTime());
        ps.execute();
        generatedKeys = ps.getGeneratedKeys();
        if (generatedKeys.next()) {
            driveDetail.setStopDuration(generatedKeys.getInt(1));
        }
    } catch (SQLException e) {
        e.printStackTrace();
        logger.error("Error inserting into alarm_event : {}", e
                .getMessage());
        logger.info(ps.toString());
    } finally {
        if (ps != null) {
            try {

                if (ps != null)
                    ps.close();
            } catch (SQLException e) {
                logger.error("Error closing prepared statements : {}", e
                        .getMessage());
            }
        }
    }
    JDatabaseManager.freeConnection(conn);
}

답변