JDBC: chiave esterna sulla PK creato stessa transazione

Question

Ho due tabelle nel mio database MySQL, che sono stati creati in questo modo:

CREATE TABLE table1 (
    id int auto_increment, 
    name varchar(10), 
    primary key(id) 
) engine=innodb 

e

CREATE TABLE table2 (
    id_fk int, 
    stuff varchar(30), 
    CONSTRAINT fk_id FOREIGN KEY(id_fk) REFERENCES table1(id) ON DELETE CASCADE 
) engine=innodb 

(queste non sono le tavole originali Il punto è che la tabella2 ha una chiave esterna che fa riferimento alla chiave primaria nella tabella 1)

Ora nel mio codice, vorrei aggiungere voci a entrambe le tabelle all'interno di una transazione. Così mi sono messo autoCommit su false:

Connection c = null;   

    PreparedStatement insertTable1 = null; 
    PreparedStatement insertTable2 = null; 

    try { 
     // dataSource was retreived via JNDI 
     c = dataSource.getConnection(); 
     c.setAutoCommit(false); 

     // will return the created primary key 
     insertTable1 = c.prepareStatement("INSERT INTO table1(name) VALUES(?)",Statement.RETURN_GENERATED_KEYS); 
     insertTable2 = c.prepareStatement("INSERT INTO table2 VALUES(?,?)"); 

     insertTable1.setString(1,"hage"); 
     int hageId = insertTable1.executeUpdate(); 

     insertTable2.setInt(1,hageId); 
     insertTable2.setString(2,"bla bla bla"); 
     insertTable2.executeUpdate(); 

     // commit 
     c.commit(); 
    } catch(SQLException e) { 
     c.rollback(); 
    } finally { 
     // close stuff 
    } 

Quando eseguo il codice di cui sopra, ottengo un'eccezione:

MySQLIntegrityConstraintViolationException: Cannot add or update a child row: a foreign key constraint fails 

Sembra che la chiave primaria non è disponibile nella transazione prima di commettere.

Mi manca qualcosa qui? Penso davvero che la chiave primaria generata dovrebbe essere disponibile nella transazione.

il programma viene eseguito su un Glassfish 3.0.1 utilizzando mysql-connector 5.1.14 e MySQL 5.5.8

Ogni aiuto è molto apprezzato!

saluti, Hage

Answer 1

vi siete persi qualcosa per l'id aggiornato restituito, si deve fare in questo modo:

Long hageId = null; 

try { 
    result = insertTable1.executeUpdate(); 
} catch (Throwable e) { 
    ... 
} 

ResultSet rs = null; 

try { 
    rs = insertTable1.getGeneratedKeys(); 
    if (rs.next()) { 
     hageId = rs.getLong(1); 
    } 
... 

Answer 2

Invece di utilizzare executeUpdate() utilizzano execute() e poi tornare la chiave primaria.

http://www.coderanch.com/t/301594/JDBC/java/Difference-between-execute-executeQuery-executeUpdate

Ma io non lavoro con db ... così ho potuto fare un errore