[jdbc] postgresql plantage

**stoukou** · 20/06/2006, 11h35

bonjour,

j'ai une application java qui alimente une table postgresql

le vecteur qui est en parametre il a une taille 50000 voila le code

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
public int addTownsTest(Vector arg) {
 
        Connection conn = null;
        PreparedStatement stmt = null;
        Towns supdt = null;
        int rs = 0;
        for (int i = 0; i < arg.size(); i++) {
 
            supdt = (Towns) arg.elementAt(i);
            String query = "INSERT INTO Towns (idtowns,postalcode,town) VALUES(?,?,?)";
            try {
                conn = init();
                stmt = conn.prepareStatement(query);
                stmt.setInt(1, supdt.getIdtown());
                stmt.setString(2, supdt.getCodepostal());
                stmt.setString(3, supdt.getTown());
                rs = stmt.executeUpdate();
                stmt.close();
 
            } catch (SQLException e) {
                System.out.println("Requete ajout towns incorrecte");
                e.printStackTrace();
            } catch (ClassNotFoundException cnf) {
                System.out
                        .println("La classe du driver jdbc n'a pu etre chargee");
                cnf.printStackTrace();
            }
 
            finally{
                 try {
                    conn.close();
 
                } catch (SQLException e) {
                }
            }
        }
        return rs;
    }

et au bout de 3900 ligne inserrées j'ai les messages d'erreurs suivants:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
org.postgresql.util.PSQLException: La tentative de connexion a échoué.
    at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:136)
    at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:66)
    at org.postgresql.jdbc2.AbstractJdbc2Connection.<init>(AbstractJdbc2Connection.java:125)
    at org.postgresql.jdbc3.AbstractJdbc3Connection.<init>(AbstractJdbc3Connection.java:30)
    at org.postgresql.jdbc3.Jdbc3Connection.<init>(Jdbc3Connection.java:24)
    at org.postgresql.Driver.makeConnection(Driver.java:382)
    at org.postgresql.Driver.connect(Driver.java:260)
    at java.sql.DriverManager.getConnection(DriverManager.java:549)
    at java.sql.DriverManager.getConnection(DriverManager.java:181)
    at pack.DriverJDBC.initDriverpgsql(DriverJDBC.java:31)
    at com.vgo.controller.ResellersController.init(ResellersController.java:59)
    at com.vgo.controller.ResellersController.addTownsTest(ResellersController.java:1230)
    at com.vgo.controller.ResellersController.addTowns(ResellersController.java:1209)
    at pack.Mains.main(Mains.java:73)
Caused by: java.net.BindException: Address already in use: connect
    at java.net.PlainSocketImpl.socketConnect(Native Method)Requete ajout towns incorrecte
 
    at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
    at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
    at java.net.Socket.connect(Socket.java:516)
    at java.net.Socket.connect(Socket.java:466)
    at java.net.Socket.<init>(Socket.java:366)
    at java.net.Socket.<init>(Socket.java:179)
    at org.postgresql.core.PGStream.<init>(PGStream.java:60)
    at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:77)
    ... 13 more

est ce qu'il y a quelqu'un qui a une petite idée

merci

**g_rare** · 20/06/2006, 12h39

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
public int addTownsTest(Vector arg) {
        int rs = 0;       
        try {
// utiliser la même connexion (ton erreur venait du fait que la base
// ne pouvait plus te procurer de nouvelles ressources au bout d'un moment)         
        Connection conn = conn = init();         
String query = "INSERT INTO Towns (idtowns,postalcode,town) VALUES(?,?,?)";
        // précompiler une seule fois ta requête dans le moteur de base
        PreparedStatement stmt = conn.prepareStatement(query); 
        for (int i = 0; i < arg.size(); i++) {
            Towns supdt = (Towns) arg.elementAt(i);
            try {                                
                stmt.setInt(1, supdt.getIdtown());
                stmt.setString(2, supdt.getCodepostal());
                stmt.setString(3, supdt.getTown());
                rs += stmt.executeUpdate(); // sinon c'est le nombre de ligne affectées par le dernier update qui est renvoyé 
            } catch (SQLException e) {
                System.out.println("Requete ajout towns incorrecte");
                e.printStackTrace();
            }      
            finally{                
                 try {
                     if (stmt != null) {
                       stmt.close();
                     }
                     if (conn != null) {
                      conn.close();
                    }
                } catch (SQLException e) { // ne rien faire
            }
        }
        } catch (ClassNotFoundException cnf) {
                System.out
                        .println("La classe du driver jdbc n'a pu etre chargee");
                cnf.printStackTrace();
            }        
        return rs;
    }

**stoukou** · 20/06/2006, 15h42

ça marche toujours pas et j'ai ça comme erreur

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
org.postgresql.util.PSQLException: Ce statement a été fermé.
	at org.postgresql.jdbc2.AbstractJdbc2Statement.checkClosed(AbstractJdbc2Statement.java:2409)
	at org.postgresql.jdbc2.AbstractJdbc2Statement.setInt(AbstractJdbc2Statement.java:1132)
	at com.vgo.controller.ResellersController.addTowns(ResellersController.java:1137)
	at pack.Mains.main(Mains.java:75)

in · 20/06/2006, 16h02

ben je dirais qu'il faudrait plutot fermer le statement et la connexion en dehors du for...

**adiGuba** · 20/06/2006, 16h07

Salut,

Tu as cette erreur car tu fermes deux fois le statement...
De plus il vaut mieux utiliser le bloc try/catch un niveau au dessus des try/finally pour bien libéré proprement les resources tout en gérant correctement les exceptions, par exemple :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
    public int addTownsTest(Vector arg) {
        int rs = 0;
        try {
            Connection conn = init();
            try {
                
                String query = "INSERT INTO Towns (idtowns,postalcode,town) VALUES(?,?,?)";
                PreparedStatement stmt = conn.prepareStatement(query);
                try {
                    for (int i = 0; i < arg.size(); i++) {
                        Towns supdt = (Towns) arg.elementAt(i);
                        stmt.setInt(1, supdt.getIdtown());
                        stmt.setString(2, supdt.getCodepostal());
                        rs += stmt.executeUpdate();
                    }
                } finally {
                    stmt.close();
                }
                    
            } finally {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return rs;
    }

Ou mieux, tu peux faire remonter l'exception :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
    public int addTownsTest(Vector arg) throws SQLException {
        int rs = 0;
        Connection conn = init();
        try {
            
            String query = "INSERT INTO Towns (idtowns,postalcode,town) VALUES(?,?,?)";
            PreparedStatement stmt = conn.prepareStatement(query);
            try {
                for (int i = 0; i < arg.size(); i++) {
                    Towns supdt = (Towns) arg.elementAt(i);
                    stmt.setInt(1, supdt.getIdtown());
                    stmt.setString(2, supdt.getCodepostal());
                    rs += stmt.executeUpdate();
                }
            } finally {
                stmt.close();
            }
                
        } finally {
            conn.close();
        }      
        return rs;
    }

a++

**stoukou** · 21/06/2006, 10h24

merci beaucoup
ça marche avec le code de adiGuba

[jdbc] postgresql plantage

JDBC Java

Discussions similaires

Partager

Partager