Discussion :

[vinzzzz]

Hello,

J'ai un bout de code qui execute à la chaine une même requête (extraction de lignes de manière aléatoire) sur une même connection (et un même statement).

voici le worflow simplifié:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
Connection c = getConnection();
Statement stmt = c.createStatement() ;
 
String query = getQuery() ;
for(int i = 0 ; i < n ; i++) {
    ResultSet rs = stmt.executeQuery(query) ;
    while(rs.next()) {
        // do something
    }
    rs.close() ;
}

problème: lorsque j'execute la requête a la première itération, tout est OK, mais à la deuxième, je recoit une exception m'indiquant que la connection a été fermée.

Un petit println(c.isClosed()) me montre qu'en effet, la connection devient fermée après avoir executé la requête pour la première fois...

Quelqu'un aurait-il une idée de ce que ca pourrait être ? J'utilise le dernier driver JDBC de mysql et je n'ai jusque là jamais rencontré ce type d'erreur.

Merci d'avance...

[tchize_]

c'est que le code a appelé close() sur le resultSet ou sur le stmt.

[vinzzzz]

Ouai j'aimerai bien que ca soit ca, mais non...

En tout cas pas explicitement dans mon code: j'utilise un pool de connections (http://www.snaq.net/java/DBPool/), et si au lieu d'utiliser la connection récupérée par getConnection(), j'en crée une nouvelle toute fraiche, mon code tourne sans problème...

[tchize_]

quelle est la durée de votre traitement par row? Un timeout peut-il en être la cause?

[vinzzzz]

J'en doute fortement... Ma requête est simplissime, je récupère 100 lignes sur deux colonnes dans une table sans aucune jointure...

La connection se ferme juste après le premier appel à stmt.executeQuery(query)... Aucune exception rien (sauf celle m'indiquant que la connection est fermée lorsque j'essai à nouveau d'executer la requête).

Et encore une fois, si j'utilise une connection nouvellement créee, ou si j'appele à nouveau getConnection() (et donc je récupère une autre connection dans le pool), ca passe nickel...

[OButterlin]

Il faudrait avoir le code complet, là, ça restera pure spéculation...

[vinzzzz]

Voici une version épurée (sans commentaires, sans print, sans log) du 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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
/**
 *
 * @author vince
 */
public class ComputeHullWorker extends SwingWorker<Integer, Object>
{
    public static final Logger logger = Logger.getLogger(
                            ComputeHullWorker.class.getCanonicalName());
 
    private final SADB sadb;
    private final HullCreator hullCreator;
 
    public ComputeHullWorker(SADB sadb, HullCreator hullCreator) {
        this.sadb = sadb ;
        this.hullCreator = hullCreator ;
 
        logger.setLevel(SAProperties.instance().logLevel()) ;
    }
 
    @Override
    protected Integer doInBackground()
            throws Exception {
 
        Connection c = sadb.getConnection();
        Statement s = null ;
 
        int dbId = -1 ;
        try {
            c.setAutoCommit(false) ;
            s = c.createStatement() ;
 
            String query = " SELECT mol_x,mol_y FROM CSCoords ORDER BY RAND() LIMIT 100";
 
            List<ConvexHull2D> hulls = new ArrayList<ConvexHull2D>(10);
            for(int i = 0 ; i < 10 ; i++) {
                List<double[]> coords = new ArrayList<double[]>(subsetsSize) ;
 
                ResultSet rs = s.executeQuery(query) ;
                while(rs.next()) {
                    coords.add(new double[]{rs.getDouble(1), rs.getDouble(2)}) ;
                }
                rs.close();
 
                if(coords.size() < 3) {
                    throw new Exception(
                            "Cannot compute convex hull: not enough coordinates found in the database!") ;
                }
 
                hulls.add(hullCreator.getHull_(coords)) ;
            }
 
            ConvexHull2D consensus = ConvexHull2D.getAverageHull(hulls, 360);
 
            dbId = sadb.getHullDAO().insertHull(consensus);
 
            c.commit();
        }
        catch(Exception e) {
            logger.log(Level.SEVERE, "Error while computing convex hull", e);
            c.rollback();
            throw e ;
        }
        finally {
            DBUtils.close(c);
        }
 
        return dbId;
    }
}

L'ensemble de mes SwingWorkers fonctionnent sur cette base (récupération d'une connection, traitement etc...) sans aucun soucis.

Autre chose à savoir, ce worker fait partis d'un processus qui execute deux autres SwingWorker avant celui-ci, mais il n'y a aucune intéraction entre eux et leur execution est séquentielle donc je doute que ca ai une quelconque importance...

Par ailleurs, lorsque je modifie le code ci-dessus et que je remplace juste par l'execution de deux requêtes bidons à la suite, même problème: dès qu'une requête est exectuée, la connection se ferme...

Ca semble donc être l'objet connection que je récupère qui est corrompu (si j'utilise une connection toute fraiche ca marche), mais aucune idée de pourquoi, et c'est d'autant plus bizard que ca me le fait à chaque execution du programme et toujours pour ce worker là...

[adiGuba]

Salut,



A quoi correspond le code de SADB.getConnection() ?

Au passage tu devrais aussi utiliser les try/finally pour fermer le ResultSet et le Statement...


a++

[vinzzzz]

sadb.getConnection() me renvoi une connection à la base de donnée courante. En pratique, j'utilise DBPool pour stocker un certain nombre de connections pré-ouvertes.

[hibour]

Peux tu montrer le code de la métode getConnection();
Peut être c'est un problème de concurrence. ajoute synchronized à la méthode pour voir.

[tchize_]

il nous faudrait le stacktrace complet et la ligne qui correspond à l'erreur (car on a pas tes numéros de lignes ).

Est-ce sur le next(), sur le getDouble(), sur le executeQuery() qu'a lieu l'exception?

[vinzzzz]

Problème réglé non sans mal:

Pour mémoire, j'execute 3 SwingWorkers à la suite. Chacun de ces workers récupére une connection dans le pool, l'utilise, et la ferme quand il a terminé. L'execution de ces worker est séquentielle dans le thread appelant: je fait appel à la méthode get() de chacun des worker juste après avoir lancé leur execution.

Dans mon implémentation initiale, j'avais surchargé la méthode done() de chaque SwingWorker dans laquelle je fermais la connection utilisée durant le traitement.

Le problème était le suivant: dans thread3, je récupére une connection C du pool, qui se trouve être celle utilisée et fermée (remise dans le pool) par thread2 juste avant.

Thread3 travail donc dessus, mais grace à un println salvateur, je remarque que la méthode done() se retrouve appelée PENDANT l'execution de thread3 (alors que je pensais que l'appel à get() suffisait à garantir la fin du worker).

Du coup, ce get() ayant pour but de fermer la connection de thread2, et celle-ci ayant été récupérée entre temps par thread3, je me retrouve avec l'exception décrite plus haut...

Conclusion: bien lire la doc du SwingWorker et se souvenir que done() est executé dans le Event Dispatch Thread !