[Java/PostgreSQL] Transactions functioneren niet

[Gardocki]

Ik ben aan het proberen om transactions werkend te krijgen in Java. Dit staat hier uitgelegd. Nu is mijn probleem dat het niet wil werken. Ik doe expres het 2e statement fout, zodat 'ie in principe een rollback zou moeten uitvoeren. Helaas voert hij de eerste statement gewoon uit als de 2e fout is, er word geen rollback uitgevoerd.

Java:

public static String testTrans() throws Exception {
        
    Class.forName("org.postgresql.Driver").newInstance();
    Connection con = DriverManager.getConnection("jdbc:"+u+""+d+"?user="+l+"&password="+p+"");
    con.setAutoCommit(false);
    try {
    String query1 = "UPDATE table1 SET blaat = 'blaat' WHERE id = 1";
    PreparedStatement st1 = con.prepareStatement(query1);
    int result1 = st1.executeUpdate(); 
        
    } catch(SQLException ex) {
        con.rollback();
    } 
    try {
        // expres een niet bestaande id:    
        String query2 = "UPDATE table1 SET blaat = 'blaat' WHERE id = 765";
        PreparedStatement st2 = con.prepareStatement(query2);
        int result2 = st2.executeUpdate();
    } catch(SQLException ex) {
        con.rollback();
    } 
    con.commit();
    con.setAutoCommit(true);
    return "gelukt";
        
        
}

Iemand een idee wat ik fout doe?

Ik draai PostgreSQL 8.0.0 beta 5 met de bijbehorende JDBC-connector, die transactions gewoon ondersteunt.

[Onno]

Om te beginnen is je opzet niet goed. Je doet een rollback per mislukt statement. Bekijk nou eens wat er gebeurt als statement 1 mislukt maar statement 2 niet. Dat voert ie 2 vrolijk uit, en die wordt daarna netjes gecommit. Dat is niet het idee van transactions.

Verder geeft statement 2 helemaal geen fout, met een update waarbij 0 records geüpdate worden is niets mis.

[Gardocki]

Onno schreef op zaterdag 22 januari 2005 @ 14:58:
Verder geeft statement 2 helemaal geen fout, met een update waarbij 0 records geüpdate worden is niets mis.

Dat was idd mijn fout. Ik heb het nu zo gedaan:

Java:

public static String testTrans() throws Exception {
        
        Class.forName("org.postgresql.Driver").newInstance();
        Connection con = DriverManager.getConnection("jdbc:"+u+""+d+"?user="+l+"&password="+p+"");
        con.setAutoCommit(false);
        
        String query1 = "UPDATE table1 SET blaat = 'blaat' WHERE auteur_nr = 1";
        PreparedStatement st1 = con.prepareStatement(query1);
        int result1 = st1.executeUpdate();
        
        String query2 = "UPDATE table1 SET blaat = 'blaat' WHERE auteur_nr = 546";
        PreparedStatement st2 = con.prepareStatement(query2);
        int result2 = st2.executeUpdate();
        
        if (result1 != 0 && result2 != 0) {
            con.commit();
            System.out.println("Commit!");
        } else {
            con.rollback();
            System.out.println("Rollback!");
        }
        
        con.setAutoCommit(true);
        return "gelukt";
}

Thanks