Discussion :

[wmenant]

Bonjour à tous,

J'espère poster dans la bonne section. Voici mon problème. Je développe actuellement un programme de récupération des emails avec insertion dans une base de données PostgreSQL. J'utilise le multithreading pour pouvoir améliorer les performances, et extraire les message de plusieurs utilisateurs en même temps.
Mon soucis et qu'il m'arrive d'avoir une incohérence dans ma base de données du fait du multithreading. Par exemple, j'ai dans ma table 60 messages, il arrive parfois qu'a la même seconde, mes 2 threads font une requete pour compter le nombre de messages dans la table avant insertion, et du coup, insère le même n°ID dans ma table

J'espère que je suis assez claire dans ma description, car c'est vraiment un phénomène bizarre que je n'arrive pas à comprendre.

Avez vous une théorie pour contrer ce problème ?

Merci à tous.

[DonQuiche]

Ne pourrais-tu pas simplement utiliser une colonne auto-incrémentée pour l'ID ?

Sinon, puisque ta DB ne semble être pilotée que par une unique copie de ton application, plutôt que d'utiliser une requête du nombre de lignes pour déterminer le nouvel ID, tu pourrais simplement maintenir un champ que tu mettrais à jour via la classe Interlocked ou des verrous.

[wmenant]

Merci pour ta réponse.

Si je ne confond pas, les verrous sont mis en place par des transactions c'est bien ça ? Si c'est le cas, je dois voir si c'est faisable avec mon ODBC vers Postgresql... pourrais tu m'en dire un peu plus sur ces verrous ou une classe Interlocked ?

Merci beaucoup.

[DonQuiche]

Bonjour.

Non, pas ces verrous-là. Je pensais aux primitives de synchronisation dotnet (les instructions "lock", les classes Monitor, Interlocked). Aucun rapport les mécanismes de concurrence des DB. Encore une fois, ceci ne serait valable que si ta DB n'est consommée que par une seule copie d'une seule application mais, si c'est le cas, ce serait le plus efficace.

Si ce n'est pas le cas et qu'un champ autoincrémenté n'est pas possible, le plus simple est de retenter la transaction jusqu'à ce que ça passe (concurrence optimiste, idéal quand tu as peu d'accès simultanés).

Code :

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

1
2
3
4
5
6
 
while(true)
{
    int id = NbLignes() + 1;
    if (EssayerInsertion(id) == "success") break;
}

Tu peux aussi tenter une requête imbriquée, avec "VALUES((SELECT COUNT(*) FROM matable), 'dupont', 'jean')" mais je ne crois pas que ça fonctionne.

[Pol63]

le mieux reste le champ auto incrément sinon :

Code :

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

insert into table (ch1, ch2) values ((select max(ch1) +1 from table), vCh2)

[wmenant]

Merci pour ces informations.

Malheureusement, le champ autoincrémenté n'est pas possible et la DB n'est pas consommée que par une seule copie d'une seule application.

En général, l'insertion passe toujours, mais mon problème se situe au niveau du multithreads. C'est a dire que 2 threads insère une ligne en même temps, et comme je fais un SELECT COUNT(*) juste avant pour récupérer le nombre d'éléments dans ma table, les 2 threads insérent le même id en même temps...

Je vais essayer de gérer ça par des transactions ou avec BULK, peut être que c'est une possibilité.