Package org.hibernate.envers.synchronization

Examples of org.hibernate.envers.synchronization.AuditSync.addWorkUnit()

146
147
148
149
150
151
152
153
154
155
156
        if (verCfg.getEntCfg().isVersioned(entityName)) {
            AuditSync verSync = verCfg.getSyncManager().get(event.getSession());

            AuditWorkUnit workUnit = new AddWorkUnit(event.getSession(), event.getPersister().getEntityName(), verCfg,
                    event.getId(), event.getPersister(), event.getState());
            verSync.addWorkUnit(workUnit);

            if (workUnit.containsWork()) {
                generateBidirectionalCollectionChangeWorkUnits(verSync, event.getPersister(), entityName, event.getState(),
                        null, event.getSession());
            }
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
        if (verCfg.getEntCfg().isVersioned(entityName)) {
            AuditSync verSync = verCfg.getSyncManager().get(event.getSession());

            AuditWorkUnit workUnit = new ModWorkUnit(event.getSession(), event.getPersister().getEntityName(), verCfg,
                    event.getId(), event.getPersister(), event.getState(), event.getOldState());
            verSync.addWorkUnit(workUnit);

            if (workUnit.containsWork()) {
                generateBidirectionalCollectionChangeWorkUnits(verSync, event.getPersister(), entityName, event.getState(),
                        event.getOldState(), event.getSession());
            }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
        if (verCfg.getEntCfg().isVersioned(entityName)) {
            AuditSync verSync = verCfg.getSyncManager().get(event.getSession());

            AuditWorkUnit workUnit = new DelWorkUnit(event.getSession(), event.getPersister().getEntityName(), verCfg,
                    event.getId(), event.getPersister(), event.getDeletedState());
            verSync.addWorkUnit(workUnit);

            if (workUnit.containsWork()) {
                generateBidirectionalCollectionChangeWorkUnits(verSync, event.getPersister(), entityName, null,
                        event.getDeletedState(), event.getSession());
            }
View Full Code Here
271
272
273
274
275
276
277
278
279
280
281
                        referencingPropertyName, event, rd);
            } else {
                PersistentCollectionChangeWorkUnit workUnit = new PersistentCollectionChangeWorkUnit(event.getSession(),
                        entityName, verCfg, newColl, collectionEntry, oldColl, event.getAffectedOwnerIdOrNull(),
                        referencingPropertyName);
                verSync.addWorkUnit(workUnit);

                if (workUnit.containsWork()) {
                    // There are some changes: a revision needs also be generated for the collection owner
                    verSync.addWorkUnit(new CollectionChangeWorkUnit(event.getSession(), event.getAffectedOwnerEntityName(),
                            verCfg, event.getAffectedOwnerIdOrNull(), event.getAffectedOwnerOrNull()));
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
                        referencingPropertyName);
                verSync.addWorkUnit(workUnit);

                if (workUnit.containsWork()) {
                    // There are some changes: a revision needs also be generated for the collection owner
                    verSync.addWorkUnit(new CollectionChangeWorkUnit(event.getSession(), event.getAffectedOwnerEntityName(),
                            verCfg, event.getAffectedOwnerIdOrNull(), event.getAffectedOwnerOrNull()));

                    generateBidirectionalCollectionChangeWorkUnits(verSync, event, workUnit, rd);
                }
            }
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
        if (verCfg.getEntCfg().isVersioned(entityName)) {
            AuditSync verSync = verCfg.getSyncManager().get(event.getSession());

            AuditWorkUnit workUnit = new AddWorkUnit(event.getSession(), event.getPersister().getEntityName(), verCfg,
                    event.getId(), event.getPersister(), event.getState());
            verSync.addWorkUnit(workUnit);

            if (workUnit.containsWork()) {
                generateBidirectionalCollectionChangeWorkUnits(verSync, event.getPersister(), entityName, event.getState(),
                        null, event.getSession());
            }
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
        if (verCfg.getEntCfg().isVersioned(entityName)) {
            AuditSync verSync = verCfg.getSyncManager().get(event.getSession());

            AuditWorkUnit workUnit = new ModWorkUnit(event.getSession(), event.getPersister().getEntityName(), verCfg,
                    event.getId(), event.getPersister(), event.getState(), event.getOldState());
            verSync.addWorkUnit(workUnit);

            if (workUnit.containsWork()) {
                generateBidirectionalCollectionChangeWorkUnits(verSync, event.getPersister(), entityName, event.getState(),
                        event.getOldState(), event.getSession());
            }
View Full Code Here
179
180
181
182
183
184
185
186
187
188
189
        if (verCfg.getEntCfg().isVersioned(entityName)) {
            AuditSync verSync = verCfg.getSyncManager().get(event.getSession());

            AuditWorkUnit workUnit = new DelWorkUnit(event.getSession(), event.getPersister().getEntityName(), verCfg,
                    event.getId(), event.getPersister(), event.getDeletedState());
            verSync.addWorkUnit(workUnit);

            if (workUnit.containsWork()) {
                generateBidirectionalCollectionChangeWorkUnits(verSync, event.getPersister(), entityName, null,
                        event.getDeletedState(), event.getSession());
            }
View Full Code Here
270
271
272
273
274
275
276
277
278
279
280
                        referencingPropertyName, event, rd);
            } else {
                PersistentCollectionChangeWorkUnit workUnit = new PersistentCollectionChangeWorkUnit(event.getSession(),
                        entityName, verCfg, newColl, collectionEntry, oldColl, event.getAffectedOwnerIdOrNull(),
                        referencingPropertyName);
                verSync.addWorkUnit(workUnit);

                if (workUnit.containsWork()) {
                    // There are some changes: a revision needs also be generated for the collection owner
                    verSync.addWorkUnit(new CollectionChangeWorkUnit(event.getSession(), event.getAffectedOwnerEntityName(),
                            verCfg, event.getAffectedOwnerIdOrNull(), event.getAffectedOwnerOrNull()));
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
                        referencingPropertyName);
                verSync.addWorkUnit(workUnit);

                if (workUnit.containsWork()) {
                    // There are some changes: a revision needs also be generated for the collection owner
                    verSync.addWorkUnit(new CollectionChangeWorkUnit(event.getSession(), event.getAffectedOwnerEntityName(),
                            verCfg, event.getAffectedOwnerIdOrNull(), event.getAffectedOwnerOrNull()));

                    generateBidirectionalCollectionChangeWorkUnits(verSync, event, workUnit, rd);
                }
            }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.