App Engine JDO Transaction sur plusieurs many-to-one

Question

J'ai un modèle simple de domaine comme suit

Driver - clé (chaîne), exécutez comptage, comptage piste unique

Track - clé (chaîne), exécutez comptage, comptage pilote unique, le meilleur temps

Run - clé(), pilote-clé, piste clé, le temps, booléen-pilote de mise à jour, mise à jour piste booléenne

Je dois pouvoir mettre à jour un Run et un Driver dans la même transaction; ainsi qu'un Run et un Track dans la même transaction (évidemment pour m'assurer que je ne mets pas à jour les statistiques deux fois, ou manquer un compteur d'incrément)

Maintenant j'ai essayé d'assigner comme clé de course, une clé faite up de driver-key/track-key/run-key (chaîne)

Cela me permettra de mettre à jour en une transaction l'entité Run et l'entité Driver. Mais si j'essaie de mettre à jour les entités Run et Track ensemble, il se plaindra qu'il ne peut pas transiter sur plusieurs groupes. Il dit qu'il a à la fois le conducteur et le camion dans la transaction et il ne peut pas fonctionner à la fois ...

 
tx.begin(); 

run = pmf.getObjectById(Run.class, runKey); 
track = pmf.getObjectById(Track.class, trackKey); 
//This is where it fails; 

incrementCounters(); 
updateUpdatedFlags(); 
tx.commit(); 

Bizarrement quand je fais une chose semblable à mettre à jour Exécuter et pilote, il fonctionne très bien.

Des suggestions sur la façon dont je peux mapper mon modèle de domaine pour obtenir la même fonctionnalité?

Answer 1

Je pense avoir trouvé une solution latérale mais toujours propre qui a toujours du sens dans mon modèle de domaine.

Le modèle de domaine change légèrement comme suit:

Driver - clé (string-id), pilote-stats - ex. id = "Michael", exécute = 17

Track - clé (identificateur de chaîne), track-stats - ex. id = "Monza", bestTime = 157

RunData - clé (identificateur de chaîne), données-stat - ex. id = "Michael-Monza-20101010", time = 148

TrackRun - clé (Piste/identificateur de chaîne), track-stats-updated - ex. id = "Monza/Michael-Monza-20101010", track-stats-updated = false

DriverRun - clé (Pilote/identifiant-de-chaîne), driver-stats-updated - ex. id = « Michael/Michael-Monza-20101010 », pilote-stats-mis à jour = true

Je peux maintenant mettre à jour atomiquement (c. précisément) les statistiques d'une piste avec les statistiques d'une course, immédiatement ou dans mon propre temps. (Et même avec les statistiques Driver/Run).

Donc, fondamentalement, je dois développer un peu la façon dont je modélise mon problème, d'une manière relationnelle non conventionnelle. Qu'est-ce que tu penses?

Answer 2

Avec Google App Engine, all of the datastore operations must be on entities in the same entity group. En effet, vos données sont généralement stockées sur plusieurs tables et Google App Engine ne peut pas effectuer de transactions sur plusieurs tables.

Entités avec des relations un-à-un et un-à-plusieurs propriétaires are automatically in the same entity group. Ainsi, si une entité contient une référence à une autre entité, ou une collection d'entités, vous pouvez lire ou écrire dans les deux transactions. Pour les entités qui n'ont pas de relation de propriétaire, vous pouvez créer une entité avec un parent de groupe d'entités explicite.

Vous pouvez placer tous les objets dans le même groupe d'entités, mais vous risquez de rencontrer des conflits si trop d'utilisateurs tentent de modifier des objets dans un groupe d'entités en même temps. Si chaque objet appartient à son propre groupe d'entités, vous ne pouvez pas effectuer de transactions significatives. Vous voulez faire quelque chose entre les deux.

Une solution consiste à avoir Track and Run dans le même groupe d'entités. Vous pouvez le faire en ayant Track contient une liste d'exécutions (si vous faites cela, alors Track peut-être pas besoin de run-count, unique-driver-count et best-time, ils pourraient être calculés en cas de besoin). Si vous ne voulez pas que Track ait une liste d'exécutions, vous pouvez utiliser un unowned one-to-many relationship et spécifier le parent du groupe d'entités de l'exécution de sa piste (voir "Création d'entités avec des groupes d'entités" au this page). Quoi qu'il en soit, si une exécution est dans le même groupe d'entités que sa piste, vous pouvez effectuer des transactions qui impliquent une exécution et certaines/toutes ses pistes.

Pour de nombreux systèmes de grande taille, au lieu d'utiliser des transactions pour la cohérence, les modifications sont effectuées en effectuant des opérations idempotent. Par exemple, si Pilote et Exécuter ne faisaient pas partie du même groupe d'entités, vous pouvez mettre à jour le nombre d'exécutions pour un Pilote en faisant d'abord une requête pour obtenir le décompte de toutes les exécutions avant une date passée, puis, dans une transaction, mettre à jour le pilote avec le nouveau compte et la date à laquelle il a été calculé pour la dernière fois.Gardez à l'esprit lorsque vous utilisez des dates que les machines peuvent avoir une sorte de dérive d'horloge, c'est pourquoi j'ai suggéré d'utiliser une date dans le passé.

Answer 3

réaliser ce retard, mais ..

Avez-vous vu cette méthode pour les transferts de compte bancaire? http://blog.notdot.net/2009/9/Distributed-Transactions-on-App-Engine

Il me semble que vous pourriez faire quelque chose de similaire en brisant vos compteurs d'incrément en deux étapes comme IncrementEntity et processus qui, ramasser les morceaux plus tard, si une transaction échoue, etc.

Depuis le blog :

1. Dans une transaction, déduire le montant du compte payant nécessaire et créer une entité enfant de transfert à record cette, en spécifiant le Fich compte dans le champ "cible" et maintenant le champ "Autre" vide pour maintenant.
2. Dans une deuxième transaction, ajoutez le montant requis pour la réception de compte , et créer un enfant de transfert entité pour enregistrer ce, en spécifiant le compte payant dans le champ « cible », et l'entité de transfert créée en étape 1 dans le champ 'autre'.
3. Enfin, mettre à jour l'entité de transfert créée en étape 1, définissant le champ «autre» à le transfert que nous avons créé à l'étape 2.

Le blog a des exemples de code en Python, mais devrait être facile à adapter

Answer 4

Il y a un Google intéressant io séance sur ce sujet http://www.google.com/events/io/2010/sessions/high-throughput-data-pipelines-appengine.html

Je suppose que vous pouvez mettre à jour les Run stats et puis lancez deux tâches pour mettre à jour le pilote et la piste individuellement.