[Problème] LECTURE de fichier .txt / INSERTION de données dans BDD

Version imprimable

Bonjour à tous,
Alors j'ai un petit problème que je ne comprends pas... je m'explique:

Dans mon appli, une partie est dédiée à la récupération de données contenues dans des fichiers textes, puis à leur insertion dans la base de données.
Alors en gros voilà comment ça marche:

OpenFiledialog / sélection de 1 ou plusieurs fichiers texte / OK / et op' ça lis le 1er fichier, récupère des données spécifiques (StreamReader) stockées dans des variables / les variables sont insérées dans la requête SQL pour aller dans la BDD.

Maintenant, dans une autre partie de mon appli, je refait la même chose mise à part que TOUT est automatique: on clique sur un bouton, ça utilise des paramètres pop de connection à un serveur mail, je récupère les pièces jointes des mails spécifiques (intitulé clé), qui vont direct se placer dans un répertoire défini dans les paramètres, et avant de passer au 2nd mail avec l'intitulé clé, je pratique mes fonctions cités au début pour insérer les données dans la BDD.

Donc le seul changement en interne de ces fonctions, c'est que au lieu de choisir les fichiers avec OpenfileDialog, le chemin des fichiers est spécifié.

Le problème: je n'y arrive pas :cry:
J'ai beau juste définir le chemin complet du fichier, ça ne marche pas!

Alors voilà mon code, et si quelqu'un a une idée de ce qui cloche...

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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
 
        string path = "";
        string var1, var2, var3, var4, var5;
        private MySqlConnection Connection = new MySqlConnection();
        private MySqlDataAdapter MyAdapter = new MySqlDataAdapter();
 
private void LecturePJ()
        {
            path = "C:\\Documents and Settings\\***\\Mes documents\\TempFiles\\Nouveaux.txt";
 
            //donne le chemin et le nom du fichier au constructeur StreamReader
            FileStream fs = new FileStream(path, FileMode.Open);
            StreamReader sr = new StreamReader(fs, Encoding.UTF8);
            string ligne;
 
            //lit la première ligne du texte
            ligne = sr.ReadLine();
 
            if (ligne == "***")
            {
                //continue de lire jusqu'à la fin du fichier
                while (ligne != null)
                {
                    var1 = ""; var2 = ""; var3 = ""; var4 = ""; var5 = "";
 
                    //on passe à la ligne suivante
                    ligne = sr.ReadLine();
 
                    if (ligne == "***")
                    {
                        // Boucle de récupération par redondance des intervals de lignes
                        for (int compteur = 0; compteur < 52; ligne = sr.ReadLine(), compteur++)
 
                            switch (compteur)
                            {
                                case 1:
                                    var1 = ligne;
                                    break;
                                case 2:
                                    var2 = ligne;
                                    break;
                                case 3:
                                    var5 = ligne;
                                    break;
                                case 13:
                                    var3 = ligne;
                                    double.Parse(var3);
                                    break;
                                case 51:
                                    var4 = ligne;
                                    break;
 
 
                            }
 
                        // Appel de la méthode Populate
                        PopulateDataGridView2();
                    }
                }
            }
            else
            {
                Console.WriteLine("Le fichier suivant est invalide!\n" + path + "\n");
            }
            //ferme le fichier
            sr.Close();
            fs.Close();
        }
 
 
 
private void PopulateDataGridView2()
        {
            // mise en tableau des 3 données
            string[] row0 = { var1, var2, var3, var4, var5 };
 
            //Paramètres de connexion
            Connect();
 
            //Définition des SQLParameters
            MySqlParameter param*** = new MySqlParameter("@***", MySqlDbType.String, 50);
            //On associe à la variable récupérée précédemment
            param***.Value = row0[0];
 
            MySqlParameter param*** = new MySqlParameter("@***", MySqlDbType.String, 100);
            param***.Value = row0[1];
 
            MySqlParameter param***= new MySqlParameter("@***", MySqlDbType.Double);
            param***.Value = row0[2];
 
            DateTime madate = DateTime.ParseExact(row0[3], "ddMMyy", null);
            MySqlParameter param*** = new MySqlParameter("@***", MySqlDbType.Date);
            param***.Value = madate;
 
            MySqlParameter param*** = new MySqlParameter("@***", MySqlDbType.String, 40);
            param***.Value = row0[4];
 
            //On définit la requête SQL
            ...***...
            MySqlCommand cmd = new MySqlCommand(sql1.ToString(), Connection);
            //On ajoute les paramètres définis à la commande SQL
            cmd.Parameters.Add(param***);
            cmd.Parameters.Add(param***);
 
           ...***...
            MySqlCommand cmd2 = new MySqlCommand(sql2.ToString(), Connection);
            cmd2.Parameters.Add(param***);
            cmd2.Parameters.Add(param***);
            cmd2.Parameters.Add(param***);
 
            ...***...
            MySqlCommand cmd3 = new MySqlCommand(sql3.ToString(), Connection);
            //On ajoute les paramètres définis à la commande SQL
            cmd3.Parameters.Add(param***);
            cmd3.Parameters.Add(param***);
 
            try
            {
                Connection.Open();
                //Exécution requête
                cmd.ExecuteNonQuery();
                cmd3.ExecuteNonQuery();
                //ExecuteSqlNQ(cmd);
                Connection.Close();
 
            }
 
            catch
            {
                // Si la connexion a échoué, message d'erreur                
                Connection.Close();
            }
            try
            {
 
                Connection.Open();
                //Exécution requête            
                cmd2.ExecuteNonQuery();
                //ExecuteSqlNQ(cmd2);
                Connection.Close();
            }
            catch
            {
                Console.WriteLine("Echec d'insertion de " + var2 + "\n" + "(Une duplication de produit est impossible!)\n");
                Connection.Close();
            }
        }

...Merci d'avance

24/11/2008, 20h58
tomlev

si tu nous dis pas quelle est l'erreur et où elle se produit, on peut pas deviner...

Et bien voilà! Il n'y a aucune erreur, rien qui plante, juste rien qui ne se passe! Pour vérifier que je ne disjonctait pas j'ai créer un nouveau projet à part pour tester, et avec ce code qui devrait normalement marcher!

Voilà mon programme tiers de test:

ma form : un bouton, un datagridview;

variables globales :

Code:

1
2
3
4
5
 
private MySqlConnection Connection = new MySqlConnection();
        private MySqlDataAdapter MyAdapter = new MySqlDataAdapter();
        string var1, var2, var3, var4, var5;    //propres aux lignes récupérées dans le .txt, et le chemin  
        string path = "C:\\Documents and Settings\\***\\Mes documents\\TempFiles\\Nouveaux.txt";

code bouton :

Code:

1
2
3
4
5
 
private void button1_Click(object sender, EventArgs e)
        {
            lecture();
        }

code lecture() :

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
 
//donne le chemin et le nom du fichier au constructeur StreamReader
            FileStream fs = new FileStream(path, FileMode.Open);
            StreamReader sr = new StreamReader(fs, Encoding.UTF8);
            string ligne;
 
            //lit la première ligne du texte
            ligne = sr.ReadLine();
 
            if (ligne == "#***")
            {
                //continue de lire jusqu'à la fin du fichier
                while (ligne != null)
                {
                    var1 = ""; var2 = ""; var3 = ""; var4 = ""; var5 = "";
 
                    //on passe à la ligne suivante
                    ligne = sr.ReadLine();
 
                    if (ligne == "#***")
                    {
                        // Boucle de récupération par redondance des intervals de lignes
                        for (int compteur = 0; compteur < 52; ligne = sr.ReadLine(), compteur++)
 
                            switch (compteur)
                            {
                                case 1:
                                    var1 = ligne;
                                    break;
                                case 2:
                                    var2 = ligne;
                                    break;
                                case 3:
                                    var5 = ligne;
                                    break;
                                case 13:
                                    var3 = ligne;
                                    double.Parse(var3);
                                    break;
                                case 51:
                                    var4 = ligne;
                                    break;
 
 
                            }
 
                        // Appel de la méthode Populate
                        PopulateDataGridView();
                    }
                }
            }
            else
            {
                MessageBox.Show("Le fichier suivant est invalide!\n" + path + "\n");
            }
            //ferme le fichier
            sr.Close();
            fs.Close();
        }

code PopulateDataGridView() :

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
 
public void PopulateDataGridView()
        {
            // mise en tableau des 3 données
            string[] row0 = { var1, var2, var3, var4, var5 };
 
            //Paramètres de connexion
            Connect();
 
            //Définition des SQLParameters
            MySqlParameter paramref = new MySqlParameter("@ref", MySqlDbType.String, 50);
            //On associe à la variable récupérée précédemment
            paramref.Value = row0[0];
 
            MySqlParameter paramdesign = new MySqlParameter("@design", MySqlDbType.String, 100);
            paramdesign.Value = row0[1];
 
            MySqlParameter paramprix = new MySqlParameter("@prix", MySqlDbType.Double);
            paramprix.Value = row0[2];
 
            DateTime madate = DateTime.ParseExact(row0[3], "ddMMyy", null);
            MySqlParameter paramdate = new MySqlParameter("@date", MySqlDbType.Date);
            paramdate.Value = madate;
 
            MySqlParameter paramfamille = new MySqlParameter("@famille", MySqlDbType.String, 40);
            paramfamille.Value = row0[4];
 
            //On définit la requête SQL
            String sql1 = string.Format("INSERT INTO ***(***, ***) VALUES({0},{1})", paramref.ParameterName, paramdesign.ParameterName);
            MySqlCommand cmd = new MySqlCommand(sql1.ToString(), Connection);
            //On ajoute les paramètres définis à la commande SQL
            cmd.Parameters.Add(paramref);
            cmd.Parameters.Add(paramdesign);
 
            String sql2 = string.Format("INSERT INTO ***(***, ***, ***) VALUES({0},{1},{2})", paramdate.ParameterName, paramprix.ParameterName, paramref.ParameterName);
            MySqlCommand cmd2 = new MySqlCommand(sql2.ToString(), Connection);
            cmd2.Parameters.Add(paramdate);
            cmd2.Parameters.Add(paramref);
            cmd2.Parameters.Add(paramprix);
 
            //On définit la requête SQL
            String sql3 = string.Format("INSERT INTO ***(***, ***) VALUES({0},{1})", paramfamille.ParameterName, paramref.ParameterName);
            MySqlCommand cmd3 = new MySqlCommand(sql3.ToString(), Connection);
            //On ajoute les paramètres définis à la commande SQL
            cmd3.Parameters.Add(paramfamille);
            cmd3.Parameters.Add(paramref);
 
            try
            {
                Connection.Open();
                //Exécution requête
                cmd.ExecuteNonQuery();
                cmd3.ExecuteNonQuery();
                //ExecuteSqlNQ(cmd);
                Connection.Close();
 
            }
 
            catch
            {
                // Si la connexion a échoué, message d'erreur                
                Connection.Close();
            }
            try
            {
 
                Connection.Open();
                //Exécution requête            
                cmd2.ExecuteNonQuery();
                //ExecuteSqlNQ(cmd2);
                Connection.Close();
 
                // mise en grid du tableau
                dataGridView1.Rows.Add(row0);
                dataGridView1.Columns[0].DisplayIndex = 1;
            }
            catch
            {
                Connection.Close();
            }
        }

Et aucune erreur ne se produit, mais rien ne se passe... pourtant c'est la même méthode que dans mon autre partie de mon programme qui marche à merveille... je ne comprend pas!

25/11/2008, 10h51
tomlev

tu as essayé d'exécuter le programme en debug pour voir pas à pas ce qui se passe ? dans un cas comme ça c'est la meilleur façon de repérer le problème...
25/11/2008, 11h01
Saten

C'est déjà fait, là jviens de faire un débug monstrueux pour bien comprendre, toute la partie récupération des variables marche bien (normal j'y ai pas touché depuis mon autre partie de mon appli), puis dans les requetes, les paramètres sont toujours bon, les requetes sont inchangées depuis mon autre partie, et pourtant les requetes ne marchent pas...

Mets la valeur de retour de ExecuteNonQuery dans une variable pour voir combien de lignes ont été affectées

Et dans les blocs catch, il faudrait mettre une messagebox ou quelque chose comme ça, sinon l'erreur passe inaperçue. En plus un catch générique qui ne récupère pas les données de l'erreur n'est pas très utile... fais plutôt comme ça :
Code:

1 2 3 4 5 6 catch(Exception ex) { // Si la connexion a échoué, message d'erreur MessageBox.Show("Erreur: " + ex.ToString()); Connection.Close(); }

Citation:
Envoyé par tomlev
Et dans les blocs catch, il faudrait mettre une messagebox ou quelque chose comme ça, sinon l'erreur passe inaperçue. En plus un catch générique qui ne récupère pas les données de l'erreur n'est pas très utile... fais plutôt comme ça :
Code:

1 2 3 4 5 6 catch(Exception ex) { // Si la connexion a échoué, message d'erreur MessageBox.Show("Erreur: " + ex.ToString()); Connection.Close(); }
T'inquiète c'est volontaire, je m'explique (tu t'attends au pire là non?:P):
Dans l'autre partie de mon application, on insère des données via fichiers texte, cela peut être des nouvelles données, ou des modifications de données datées, donc enfait, le premier try catch s'effectue, et s'il rate, au lieu de m'avertir, c'est normal il passe à la seconde, et s'il réussi il fait quand même le deuxième. Mais j'ai retiré les lignes qu'il y avait dans l'autre partie, c'est à dire l'inscription dans un journal des informations. Donc voilà c'est pour ça!
;)

Citation:

Mets la valeur de retour de ExecuteNonQuery dans une variable pour voir combien de lignes ont été affectées

Comment faire ça? ExecuteNonQuery ne prend pas d'arguments...

25/11/2008, 12h20
tomlev

Citation:

Envoyé par Saten

Comment faire ça? ExecuteNonQuery ne prend pas d'arguments...

Je n'ai pas parlé d'arguments mais de valeur de retour... ExecuteNonQuery renvoie le nombre de lignes insérées, modifiées ou supprimées
25/11/2008, 12h33
Saten

Yataa! C'est bon, en fait j'ai juste disjoncter sur le fait que j'ai modifié une clé étrangère dernière fois lors de l'ajout d'une nouvelle table... :aie: Misère, donc ce qui était censé ne pas marché sur mon premier try/catch pour passer au second ne marchait plus du tout du coup... lol.

Mille excuses, ma faute ma à moi :roll:^^
Merci quand même TomLev ;)