[MySQL5.5][C#] Acces concurrents

Version imprimable

11/03/2011, 21h16
Xploit

[MySQL5.5][C#] Acces concurrents

Salut à tou(te)s !

Voici la situation:

-j'ai un serveur mysql5.5 fraichement installé et configuré. Ainsi que mysql workbench.

-j'ai créé une BDD (moteur innoDB) contenant une table. Dans cette table j'ai une clé formée par un couple (vendor_id, service_id), plus un autre champs qui représente un numéro de série en fonction du couple précédent.

-Le but est de se connecter à la table en question (depuis un client C#) et de pouvoir récupérer un numéro de série puis l'incrémenter. Le numéro de série doit être unique.
ça se complique dès que je veux passer à plusieurs clients qui demandent des numéros de série.
j'ai lancé par exemple deux clients qui demandent un numéro de série (Select sur le champs en question de la base) puis qui incrémentent la valeur du champ en question. Tout ça dans une boucle "for".
Les deux clients que j'ai lancé en simultané se sont jusqu'ici attribué des numéros de série déjà utilisés.

Le problème vient certainement du fait qu'il y a des accès concurrents et qu'entre la lecture du champ et sa mise à jour les autres clients accèdent au champ.
Je n'ai pas réussi pour le moment à locker la ligne entre le moment ou un client la lit et la modifie. De sorte que les autres clients ne puissent pas prendre une valeur non à jour.

J'espère que c'est assez clair, et que vous aurez des idées.

Bonne soirée, et merci d'avance !
11/03/2011, 22h16
Invité

Bonsoir,

Le mieux à mon avis c'est de laisser MySQL affecter le numéro de série lui-même à l'aide d'un auto-incrément.
11/03/2011, 22h35
Xploit

Si je ne me trompe pas, l'auto-incrément s'utilise dans le cas d'un nouvel enregistrement dans la table. Alors l'index de cette table s'auto-incrémente pour la nouvelle ligne.

Dans mon cas, je souhaiterais uniquement modifier l'enregistrement en question (la ligne) en incrémentant le champ représentant le numéro de série. Et non pas créer un nouvel enregistrement dans la table.
11/03/2011, 23h16
CinePhil
Citation:

-Le but est de se connecter à la table en question (depuis un client C#) et de pouvoir récupérer un numéro de série puis l'incrémenter. Le numéro de série doit être unique.

Pourquoi ne pas faire simplement la requête suivante ?
Code:

1 2 3 4 UPDATE ta_table SET num_serie = num_serie + 1 WHERE vendor_id = [l_id_vendeur_voulu] AND service_id = [l_id_service_voulu]

Citation:

Envoyé par CinePhil

Pourquoi ne pas faire simplement la requête suivante ?

Code:

1
2
3
4
UPDATE ta_table
SET num_serie = num_serie + 1
WHERE vendor_id = [l_id_vendeur_voulu]
  AND service_id = [l_id_service_voulu]

Et bien merci pour cette réponse ça marche bien mieux, mais il subsiste un gros problème.

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
 
        static void Main(string[] args)
        {
            string MyConString = "Database=test;Data Source=localhost;User Id=toto;Password=toto";
            MySqlDataAdapter MyAdapter = new MySqlDataAdapter();
		    DataSet ds = new DataSet();
 
            try
            {
                for (int cpt = 0; cpt < 1000; cpt++)
                {
                    string myUpdateQuery = "UPDATE `test`.`nom` SET `serial`= serial +1 WHERE `idnom`='1'";
                    string mySelectQuery = "Select serial from nom where idnom=1 for update";
 
                    MySqlConnection connection = new MySqlConnection(MyConString);
                    MySqlCommand command = new MySqlCommand(mySelectQuery, connection);
                    MySqlCommand cmd = new MySqlCommand(myUpdateQuery, connection);
                    connection.Open();                    
                    MySqlDataReader Reader;
                    Reader = command.ExecuteReader();
                    Console.WriteLine("APPLI 2");
                    while (Reader.Read())
                    {
                        string thisrow = "";
                        for (int i = 0; i < Reader.FieldCount; i++)
                            thisrow += "serial2 : "+Reader.GetValue(i).ToString();
                        Console.WriteLine(thisrow);
                    }
                    Reader.Close();
                    System.Threading.Thread.Sleep(5000);
                    cmd.ExecuteScalar();
                    connection.Close();
                }
 
                Console.Read();
            }
            catch (MySqlException ex) { Console.WriteLine(ex); }
        }

Voici le code C# pour faire mes tests.
J'ai mis délibérément un sleep de 5 secs entre l'envoi des deux requêtes au serveur pour voir si c'est sécurisé.
J'ai deux clients en parallèle avec le même code. Le problème est qu'il n'y a aucune sécurité entre le SELECT pour lire la valeur courante du SN et la requête update. Si mon deuxième client tape en lecture sur la table entre les deux requêtes du premier client il aura un numéro déjà donné au premier client.
N'y a-t-il pas un mécanisme ( transaction ? ) pour verrouiller la table entre ces deux requêtes ?

Bon apparemment j'ai trouvé la solution...
Il fallait désactiver le autocommit en rajoutant un "START TRANSACTION" au debut du script et un "COMMIT" à la fin.
Dites moi ce que vous en pensez...

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
 
 
                for (int cpt = 0; cpt < 1000; cpt++)
                {
string lockQuery = "Start transaction";
string mySelectQuery = "Select serial from nom where idnom=1 for update";
string myUpdateQuery = "UPDATE `test`.`nom` SET `serial`= serial + 1 WHERE `idnom`='1'";
string commitQuery = "Commit";
 
                    MySqlConnection connection = new MySqlConnection(MyConString);
                    MySqlCommand command = new MySqlCommand(mySelectQuery, connection);
                    MySqlCommand cmd = new MySqlCommand(myUpdateQuery, connection);
                    MySqlCommand cmd1 = new MySqlCommand(lockQuery, connection);
                    MySqlCommand cmd2 = new MySqlCommand(commitQuery, connection);
 
                    connection.Open();
 
                    cmd1.ExecuteScalar(); // START TRANSACTION
 
                    MySqlDataReader Reader;
                    Reader = command.ExecuteReader(); // SELECT FOR UPDATE QUERY
                    Console.WriteLine("APPLI 1");
                    while (Reader.Read())
                    {
                        string thisrow = "";
                        for (int i = 0; i < Reader.FieldCount; i++)
                            thisrow += "serial : "+Reader.GetValue(i).ToString();
                        Console.WriteLine(thisrow);
                    }
                    Reader.Close();
                    cmd.ExecuteScalar(); // UPDATE QUERY
                    System.Threading.Thread.Sleep(1000);
                    cmd2.ExecuteScalar();// COMMIT
                    connection.Close();
                }

Ceci a l'air de marcher car lorsque je mets un délai entre le select et le update d'un client, la boucle for du deuxième se synchronise avec le premier. Les requêtes du deuxième client sont bien mises en attente jusqu'à ce que le premier libère la ligne en faisant le "commit".

14/03/2011, 09h36
CinePhil

Ne connaissant pas C# et en regardant rapidement le code, j'ai du mal à comprendre l'utilité du SELECT mais bon...
Si ça fonctionne comme tu le souhaites, n'oublie pas de marquer :resolu:
14/03/2011, 13h16
Xploit

Salut !
Le but premier du client c# est de récupérer le serial number stocké dans la base de données... D'où le sélect...
Ensuite il incrémente la valeur et met a jour la table...