Un Thread Pour enregistrer les informations dans une Base de données

Version imprimable

Bonjour à tous!
Je souhaite exécuter une requête SQL qui enregistre les informations issues d'un fichier dans une Bdd et j'utilise MySQL. Je veux que cette exécution soit surveillée par un Thread pour enfin l'affecter à Une ProgressBar.
Le Thread évolue en fonction de l'évolution des enregistrements fait par la requete.
Donc La progressBar se charger en fonction de l'évolution du Thread.
J'utilise JavaFX.

J'ai fait ce bout de codes pour utiliser gérer la PregressBar avec le Thread sans la requête SLQ, votre assistance m'est indispensable.

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
private void Execution(String file_name){
 
        task = new Task<Void>() {
            @Override
            protected Void call() throws Exception {
 
            String data = null;
            FileInputStream fis = new FileInputStream(file_name);
            BufferedInputStream bis = new BufferedInputStream(fis);
 
            int n = 0;
            byte buff[] = new byte[1024];
            n = bis.read(buff);
            while(n!=-1){
                boolean opt = false;
                for(int i = 0; i<n; i++){
                    data += (char)buff[i];
                }
                n = bis.read(buff);
            }
            String[] tmp = data.split("\n");
 
 
                for (int i = 0; i < tmp.length+1; i++) {
 
                    updateProgress(i, tmp.length);
                    updateMessage(tmp[i]);
                    Thread.sleep(200);
                }
            return null;
            }
        };

06/04/2020, 03h22
bouye

Tutoriel sur l'exécution d'une tâche de fond en JavaFX

Cher Bouye Merci pour votre aide!
Mais je n'ai pas trouvé dans la documentation le cas d'un thread pour la base de données. certes, le principe reste le même, mais j'ai tenté de l'appliquer rien ne marche. voilà pourquoi je reviens encore ici une fois de plus pour la même question avec une amélioration de mes codes sources que je depose ici:

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
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
public void Execution(String file_name, Label label, ProgressBar Progress, ProgressIndicator Indicateur){
        ArrayList<String> arraylist = new ArrayList<>();
          
        Task<Void> task;
        task = new Task<Void>() {
            @Override
            protected Void call() throws Exception {
            
            String data = null;
            FileInputStream fis = new FileInputStream(file_name);
            BufferedInputStream bis = new BufferedInputStream(fis);
            
            int n = 0;
            byte buff[] = new byte[1024];
            n = bis.read(buff);
            while(n!=-1){
                boolean opt = false;
                for(int i = 0; i<n; i++){
                    data += (char)buff[i];
                    //System.out.println(data);
                }
                n = bis.read(buff);
            }
            String[] tmp = data.split("\n");
            
           
        
        
            for (int i = 5; i < tmp.length+1; i++) {
                
               
                
                if(! String.valueOf(tmp[i]).contains(", le")){
                      
                
                String[] une_cote = tmp[i].split(";");
                
                arraylist.add(une_cote[1]);
                
                //  Ceci concerne la base de données


                String requette = "INSERT INTO etudiant(name) values('"+arraylist.get(i-5)+"')";
    
                Statement prepare = getConnection().createStatement();
                
                prepare.executeUpdate(requette);
                
                   
   
                   updateProgress(i-5, tmp.length-7);
                    
                   String messag = (i >= tmp.length)? "OK" : arraylist.get(i-5);
                    
                   updateMessage(messag);
                                        
                   Thread.sleep(100); 
                    
                    }
                }
            return null;
            }
        };
        
        task.messageProperty().addListener(new ChangeListener<String>() {
            @Override
            public void changed(ObservableValue<? extends String> observable, String oldValue, String newValue) {
                
                label.setAlignment(Pos.CENTER);
                label.setText(newValue);
                
            }
        });
        
        Progress.progressProperty().unbind();
        Progress.progressProperty().bind(task.progressProperty());
        
        Indicateur.progressProperty().unbind();
        Indicateur.progressProperty().bind(task.progressProperty());
        
        Thread thred = new Thread(task);
        thred.setDaemon(true);
        thred.start();
    }

public Connection getConnection(){

return DriverManager.getConnection("jdbc:mysql://localhost:3306/essai", "root", "");
}

10/04/2020, 03h06
bouye

Tu n'a pas bien lu l'article ou tu l'as mal compris : la Task doit etre utilisée dans un Service et ce sont les propriétés de ce Service que tu peux binder sur ton UI et non pas celles de la Task.

Cher Bouye!
Merci une fois de plus pour votre observation.
j'ai lu la documentation.
(Suggestion) Loin de moi l'intention d'avoir toujours besoin d'un poisson déjà péché. Mais je pense que le traitement d'un cas spécifique d'une opération sur la bdd pourrait être utile pour nous dont peut-être le niveau en programmation est encore un peu plus bas.
J'ai tenté cette fois-ci d'utiliser le Service dans les codes ci-dessous, mais la solution est loin de venir.

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
40
public void ExecuterService(Label MonLabel, ProgressBar MaProgressBar, ProgressIndicator MonIndicateur){
        Service<Integer> MonService = new Service<Integer>() {
            @Override
            public Task createTask(){
                return new Task<Integer>() {
                    @Override
                public Integer call() throws InterruptedException, SQLException{
                
                int i;
                for (i = 0; i < 1001; i++) {
                    
                    // exemple d'une requette SQL
                String requette = "INSERT INTO etudiant(numero) values('"+i+"')";
    
                Statement prepare = getConnection().createStatement();
                
                prepare.executeUpdate(requette);
                //
                    updateProgress(i,1000);
                    updateMessage(String.valueOf(i));
                    Thread.sleep(10);
                }
            return i;
            }
                };
           }
            };
        
        MaProgressBar.progressProperty().bind(MonService.progressProperty());
        MonIndicateur.progressProperty().bind(MonService.progressProperty());
        MonLabel.textProperty().bind(MonService.messageProperty());
        MonLabel.setAlignment(Pos.CENTER);
        
        }

public Connection getConnection() throws SQLException{

return DriverManager.getConnection("jdbc:mysql://localhost:3306/essai", "root", "");
}

10/04/2020, 14h43
bouye

Et tu le lances ce service à un moment ou à un autre ?

Oui oui! je le lance au niveau du controller après un clic sur un bouton de l'interface graphique. le code est:

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
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
 
public class FormulaireController implements Initializable {
 
    @FXML
    private Button MonBouton;
    @FXML
    private ProgressBar MaProgressBar;
    @FXML
    private Label MonLabel;
    @FXML 
    private ProgressIndicator MonIndicateur;
 
 
    /**
     * Initializes the controller class.
     */
    @Override
    public void initialize(URL url, ResourceBundle rb) {
 
        // TODO 
        MonBouton.setOnMouseClicked(new EventHandler<MouseEvent>() {
            @Override
            public void handle(MouseEvent event) {
 
                  ExecuterService();
 
            }
        });
    }
 
 
public void ExecuterService(){
        Service<Integer> MonService = new Service<Integer>() {
            @Override
            public Task createTask(){
                return new Task<Integer>() {
                    @Override
                public Integer call() throws InterruptedException, SQLException{
 
                int i;
                for (i = 0; i < 1001; i++) {
 
                    // requette SQL
 
                String requette = "INSERT INTO etudiant(name) values('"+i+"')";
 
                Statement prepare = getConnection().createStatement();
 
                prepare.executeUpdate(requette);
                //
                    updateProgress(i,1000);
                    updateMessage(String.valueOf(i));
                    Thread.sleep(10);
                }
            return i;
            }
                };
           }
            };
 
        MaProgressBar.progressProperty().bind(MonService.progressProperty());
        MonIndicateur.progressProperty().bind(MonService.progressProperty());
        MonLabel.textProperty().bind(MonService.messageProperty());
        MonLabel.setAlignment(Pos.CENTER);
 
        }
}

11/04/2020, 01h41
bouye

A aucun moment tu appelles start() :?

Oui oui! je l'ai lancé avec start vers la fin.
Excusez-moi d'avoir oublié de récupérer cette partie du 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
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
71
72
73
74
75
public class FormulaireController implements Initializable {
 
    @FXML
    private Button MonBouton;
    @FXML
    private ProgressBar MaProgressBar;
    @FXML
    private Label MonLabel;
    @FXML 
    private ProgressIndicator MonIndicateur;
 
 
    /**
     * Initializes the controller class.
     */
    @Override
    public void initialize(URL url, ResourceBundle rb) {
 
        // TODO 
        MonBouton.setOnMouseClicked(new EventHandler<MouseEvent>() {
            @Override
            public void handle(MouseEvent event) {
 
                  ExecuterService();
 
            }
        });
    }
 
 
public void ExecuterService(){
        Service<Integer> MonService = new Service<Integer>() {
            @Override
            public Task createTask(){
                return new Task<Integer>() {
                    @Override
                public Integer call() throws InterruptedException, SQLException{
 
                int i;
                for (i = 0; i < 1001; i++) {
 
                    // requette SQL
 
                String requette = "INSERT INTO etudiant(name) values('"+i+"')";
 
                Statement prepare = getConnection().createStatement();
 
                prepare.executeUpdate(requette);
                //
                    updateProgress(i,1000);
                    updateMessage(String.valueOf(i));
                    Thread.sleep(10);
                }
            return i;
            }
                };
           }
            };
 
        MaProgressBar.progressProperty().bind(MonService.progressProperty());
        MonIndicateur.progressProperty().bind(MonService.progressProperty());
        MonLabel.textProperty().bind(MonService.messageProperty());
        MonLabel.setAlignment(Pos.CENTER);
     
          MonService.start();
 
        }


public Connection getConnection() throws SQLException{

return DriverManager.getConnection("jdbc:mysql://localhost:3306/essai", "root", "");
}
}

11/04/2020, 10h48
Fondateur01

Le problème était maintenant loin de mes codes sources!
je viens de suivre de près l'erreur qu'on me renvoie et j'ai compris que je n'avais pas la librairie du middleware jdbc dans mon projet. Après l'avoir importé, tout marche très bien.
Merci cher Bouye pour ta disponibilité hors du commun.
A la prochaine occasion.