Problème avec mon thread

Version imprimable

Salut à tous,
Je développe un thread qui compare le nombre de lignes de ma base de données à chaque 7 secondes dont le code est le suivant:

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
 
public void run(){
 
      String query = "select count(*) from produit ";
      try{
             ResultSet rs=cn.getResultat(query);
          while (rs.next()) {
           nblignes = rs.getInt(1);
                }
                rs.close();
          } catch (Exception e) {
      JOptionPane.showMessageDialog(null, "Erreur lors de l'exécution de la requête recherche nombre enregistrement client");
           }
    while (isAlive()){
          if (verifier(nblignes)==false){
               JOptionPane.showMessageDialog(null, "Une modification a été effectué sur la table produit");
 
          }
                   try {
                   Thread.sleep(7000);
                      } catch (InterruptedException ex) {
              Logger.getLogger(EspionProduit.class.getName()).log(Level.SEVERE, null, ex);
             }
 
        }

le code de la méthode verifier():

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
 public boolean verifier(int x) {
        String query2 = "select count(*) from produit ";
      try{
             ResultSet rs=cn.getResultat(query2);
          while (rs.next()) {
           nblignes2 = rs.getInt(1);
                }
                rs.close();
          } catch (Exception e) {
      JOptionPane.showMessageDialog(null, "Erreur lors de l'exécution de la requête recherche du nouveau nombre enregistrement client");
            }
 
         if( nblignes2 != x) {
                    //System.exit(-1);
 
                    return false;
                }
         else
 
                return true;
            }

et quand j'exécute ce thread dans ma page principale à travers:

Code:

1
2
3
 EspionProduit thread = new EspionProduit();
        // Activation du Thread
        thread.start();

et j'insère par la suite une nouvelle ligne dans notre base, le thread m'affiche qu'une modification a était lieu mais ce message s'affiche toute les 7 secondes :calim2: ... Alors que je voulais qu'il me l'affiche une seule fois et la nouvelle valeur(=du nombre de lignes) devient celle que le thread va la comparer avec la sienne.... :roll:
J'espère que vous m'avez compris ... Que dois-je faire?
Mrci pour votre coopération ... :aie:

16/11/2009, 16h47
publicStaticVoidMain

Juste une question, est ce normal que tu fasses 2 fois la meme requete.
Une dans la méthode run de ton thread et l'autre dans la méthode vérifier??
16/11/2009, 16h53
Bbaboulinet

Salut,

tu fais :

Code:

if(verifier(nblignes)==false)){}

Mais quand es que tu redonne la nouvelle valeur de nblignes ?
16/11/2009, 19h17
L'aigle de Carthage

Citation:

Envoyé par publicStaticVoidMain

Juste une question, est ce normal que tu fasses 2 fois la meme requete.
Une dans la méthode run de ton thread et l'autre dans la méthode vérifier??

Je veut que le thread récupère la valeur de nblignes dés son déclenchement (par la méthode start ()) et puis il va invoquer la méthode vérifier danslaquelle on va obtenir la nouvelle valeur et puis on fait la comparaison entre les 2 valeurs ... c'est ça mon principe :oops:
16/11/2009, 19h18
L'aigle de Carthage

Citation:

Envoyé par Bbaboulinet

Salut,

tu fais :

Code:

if(verifier(nblignes)==false)){}

Mais quand es que tu redonne la nouvelle valeur de nblignes ?

C'est ça mon problème, j'ai pas su ou dois-je mettre l'instruction d'affectation de la nouvelle valeur ... :calim2:

Citation:

Je veut que le thread récupère la valeur de nblignes dés son déclenchement (par la méthode start ()) et puis il va invoquer la méthode vérifier danslaquelle on va obtenir la nouvelle valeur et puis on fait la comparaison entre les 2 valeurs ... c'est ça mon principe

Pour cela, tu peux initialiser ton compteur nbLignes au demarrage de ton thread.

Apres au lieu de renvoyer un boolean avec verifier(nbLignes) tu peux renvoyer le resultat de la lecture comme ceci:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
public int lectureNbLignesBD(final Connection connection)
{
    int nbLignes = -1;
    String query = "select count(*) from produit ";
    try
    {
        ResultSet rs=connection.getResultat(query);
        while (rs.next()) 
        {
            nbLignes = rs.getInt(1);
        }
        rs.close();
    }
    catch (Exception e)
    {
        JOptionPane.showMessageDialog(null, "Erreur lors de l'exécution de la requête recherche nombre enregistrement client");
    }
    return nbLignes;
}

Et ton thread comme ceci

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
 
public void run()
{
    int nbLignes =lectureNbLignesBD(cn);
 
    while (isAlive())
    {
        if ((nbLignes > 0) && (lectureNbLignesBD(cn) != nbLignes))
        {
            JOptionPane.showMessageDialog(null, "Une modification a été effectué sur la table produit");
        }
        try
        {
            Thread.sleep(7000);
        }
        catch (InterruptedException ex) 
        {
            Logger.getLogger(EspionProduit.class.getName()).log(Level.SEVERE, null, ex);
        }
    }      
}

17/11/2009, 17h38
professeur shadoko

j'ai pas lu ton code mais j'ai tiqué sur le while(isAlive()) ....
tu attends quoi?
quand on est mort c'est pour la vie! comment peut-on être mort et vivant en même temps?

y a queque chose qui m'échappe ...

salut
la souris de La Marsa

Merci pour votre réponse ...

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
public int lectureNbLignesBD(final Connection connection)
{
    int nbLignes = -1;
    String query = "select count(*) from produit ";
    try
    {
        ResultSet rs=connection.getResultat(query);
        while (rs.next()) 
        {
            nbLignes = rs.getInt(1);
        }
        rs.close();
    }
    catch (Exception e)
    {
        JOptionPane.showMessageDialog(null, "Erreur lors de l'exécution de la requête recherche nombre enregistrement client");
    }
    return nbLignes;
}

Et ton thread comme ceci

[/QUOTE]
Pourquoi tu entres en paramètre une variable de type connexion, en quoi ça va m'aider? :roll: