[jdbc] postgresql plantage

Version imprimable

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:

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:

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

Code:

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;
    }

8-)

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

Code:

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)

20/06/2006, 17h02
in

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

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:

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:

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++

21/06/2006, 11h24
stoukou

merci beaucoup
ça marche avec le code de adiGuba

;)