Meilleures pratiques pour l'utilisation de sqlite dans une file d'attente de base de données

Question

J'utilise une base de données sqlite pour une file d'attente producteur-consommateur. Un ou plusieurs producteurs INSÉRER une rangée à la fois avec une nouvelle clé primaire auto-incrémentée.

Il y a un consommateur (implémenté dans Java, utilise la bibliothèque sqlite-jdbc) et je veux qu'il lise un lot de lignes et les supprime. Il semble que j'ai besoin de transactions pour le faire, mais essayer d'utiliser SQLite avec des transactions semble ne pas fonctionner correctement. Suis-je en train de penser cela?

Si je finis par avoir besoin de transactions, quelle est la bonne façon de le faire en Java?

Connection conn; 
// assign here 

boolean success = false; 
try { 
    // do stuff 
    success = true; 
} 
finally 
{ 
    if (success) 
     conn.commit(); 
    else 
     conn.rollback(); 
} 

Answer 1

Normalement, avec SQLite, il y a des transactions explicites (non implicites!). Donc, vous avez besoin de quelque chose comme "START TRANSACTION" bien sûr, il se pourrait que votre liaison Java ait ceci intégré - mais les bonnes liaisons ne le font pas. Par conséquent, vous pouvez ajouter le début de transaction nécessaire (il peut y avoir une méthode spéciale dans votre liaison).

Answer 2

Voir this trail pour une introduction sur la gestion des transactions avec Java JDBC. En ce qui concerne votre cas d'utilisation, je pense que vous devriez utiliser les transactions, surtout si le consommateur est complexe. La partie délicate est toujours de décider quand une rangée a été consommée et quand elle devrait être considérée encore. Par exemple, si vous avez une erreur avant que le consommateur puisse réellement faire son travail, vous aurez besoin d'une restauration. Mais si la ligne contient des données illégales (comme un texte dans un champ numérique), l'annulation se transformera en une boucle infinie.