Resend because of scrubbing of list ... <br><br><div class="gmail_quote">On Tue, Dec 8, 2009 at 9:18 PM, Bart Gauquie <span dir="ltr"><<a href="mailto:bart.gauquie@gmail.com">bart.gauquie@gmail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;"><div>Dear all,<br clear="all"></div><div><br></div><div>I've been trying out the MagmaCommitConflictError in Magma. I'm experiencing following which I do not understand. </div>
<div>I've attached a changeset with a test case reproducing the behaviour I do not understand.</div>
<div><br></div><div>If I follow the steps outlined at: <a href="http://wiki.squeak.org/squeak/2636" target="_blank">http://wiki.squeak.org/squeak/2636</a><b> </b>a MagmaCommitConflictError is thrown.</div><div>(see testTriggerACommitConflictSequenceAsDescribedOnWiki and a little modification on that: testTriggerACommitConflictLoadObjectBeforeStartingATransaction)</div>
<div><br></div><div>If I however execute </div><div><br></div><div>testTriggerACommitConflictUsersCommitAfterEachOtherButWithTheSameVersionOfObjectInitiallyLoaded<br> </div><div><br></div><div>|firstSession secondSession mockObjectRefByFirstSession mockObjectRefBySecondSession|<br>
[firstSession :=<br> (MagmaRemoteLocation<br> host: 'localhost'<br> port: self databasePort) newSession.<br> firstSession connectAs: 'firstSessionUser'.<br> firstSession commit: [<br>
firstSession root<br> at: 'mockObject'<br> put: (SomeMockDomainObject new aField: 'aField content'; yourself)].<br> <br> secondSession := <br> (MagmaRemoteLocation<br> host: 'localhost'<br>
port: self databasePort) newSession.<br> secondSession connectAs: 'secondSessionUser'.<br> <br> mockObjectRefByFirstSession := firstSession root at: 'mockObject'. "User 1 is loading the object"<br>
mockObjectRefBySecondSession := secondSession root at: 'mockObject'. "User 2 is loading the same version of the object as User 1" <br> <br> firstSession begin. "1. User 1 begins a transaction."<br>
mockObjectRefByFirstSession aField: 'aField updated by user 1'. "3. User 1 changes Object A."<br> firstSession commit. "4. User 1 commits his transaction."<br><br> secondSession begin. "2. User 2 begins a transaction."<br>
mockObjectRefBySecondSession aField: 'aField updated by user 2'. "5. User 2 changes Object A."<br> <br> self should: [secondSession commit. "6.7. User 2 commits his transaction"]<br> raise: MagmaCommitConflictError.<br>
</div><div><br></div><div>firstSession refresh.</div><div><br></div><div>self assert: 'aField updated by user 1' equals: ((firstSession root at: 'mockObject') aField).<br> self assert: 'aField updated by user 1' equals: ((secondSession root at: 'mockObject') aField).<br>
self assert: 'aField updated by user 1' equals: (mockObjectRefBySecondSession aField).<br><br> ] ensure: [[firstSession commit: [<br> firstSession root removeAll].<br> firstSession disconnect] <br> ensure: <br>
[secondSession disconnect]]<br> <br>It failes and I dont understand why. The test is what you get in a typical web application. User 1 has a session on the database. User 2 has another session. Both opened an item. Both are editing it and then first user1 commits his changes. User 2 wants to commit his changes but did not see the updated data of User 1. The test failes at : </div>
<div><br></div><div>self should: [secondSession commit. "6.7. User 2 commits his transaction"] raise: MagmaCommitConflictError. </div><div><br></div><div>=> MagmaCommitConflictError is not thrown. Which is something I do not understand. User 2 is trying to commit a change on an object some other session already changed. So User 2 is trying to update a stale version. Is there a reason why no MagmaCommitConflictError is thrown? Furthermore, if you proceed on the failing MagmaCommitConflictError; refresh the firstSession; i notice that the changes made by Session2 effectively got committed; which surprises me even more. Because that means that the changes made by User 1 got overridden by the changes of User 2 without User 2 even knowing.</div>
<div><br></div><div>If I read the information on the wiki, this behaviour is correct since Magma will only detect if during a transaction (after begin has been called) some other session has committed changes on the object being changed. Off course this is not the kind of behaviour you have if you're developing web applications since there, the transactions are very short.</div>
<div><br></div><div>Is there a way to detect if an object was updated by another transaction, but not within my own transaction; so that stale updates do not happen. I suppose there is some version on a persisted object you can check and if the last committed version of an object is higher than the version in the current session, this also means a magmacommitconflicterror? But I havent found any info about that yet?</div>
<div><br></div><div>Thanks for any help.</div><div><br></div><div>Kind Regards,</div><div><br></div><div>Bart</div><br></blockquote></div><div><br></div><div>Attachment:<br></div><div><br></div><div>'From Pharo1.0rc1 of 19 October 2009 [Latest update: #10493] on 8 December 2009 at 9:10:53 pm'!<br>
TestCase subclass: #BMTTryingToUnderstandMagmaCommitConflictsTest<br> instanceVariableNames: 'magmaServerConsole'<br> classVariableNames: ''<br> poolDictionaries: ''<br> category: 'BkbagMagmaTesting-Model-Magma-IntegrationTests'!<br>
Object subclass: #SomeMockDomainObject<br> instanceVariableNames: 'aField'<br> classVariableNames: ''<br> poolDictionaries: ''<br> category: 'BkbagMagmaTesting-Model-Magma-IntegrationTests'!<br>
<br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'tests' stamp: 'TestRunner 12/8/2009 20:19'!<br>testTriggerACommitConflictLoadObjectBeforeStartingATransaction<br> |firstSession secondSession mockObjectRefByFirstSession mockObjectRefBySecondSession|<br>
[firstSession :=<br> (MagmaRemoteLocation<br> host: 'localhost'<br> port: self databasePort) newSession.<br> firstSession connectAs: 'firstSessionUser'.<br> firstSession commit: [<br>
firstSession root<br> at: 'mockObject'<br> put: (SomeMockDomainObject new aField: 'aField content'; yourself)].<br> <br> secondSession := <br> (MagmaRemoteLocation<br> host: 'localhost'<br>
port: self databasePort) newSession.<br> secondSession connectAs: 'secondSessionUser'.<br> <br> mockObjectRefByFirstSession := firstSession root at: 'mockObject'. "User 1 is loading the object"<br>
mockObjectRefBySecondSession := secondSession root at: 'mockObject'. "User 2 is loading the same version of the object as User 1" <br> <br> firstSession begin. "1. User 1 begins a transaction."<br>
secondSession begin. "2. User 2 begins a transaction."<br> <br> mockObjectRefByFirstSession aField: 'aField updated by user 1'. "3. User 1 changes Object A."<br> firstSession commit. "4. User 1 commits his transaction."<br>
<br> mockObjectRefBySecondSession aField: 'aField updated by user 2'. "5. User 2 changes Object A."<br> <br> self should: [secondSession commit. "6.7. User 2 commits his transaction"]<br> raise: MagmaCommitConflictError.<br>
<br> self assert: 'aField updated by user 1' equals: ((firstSession root at: 'mockObject') aField).<br> self assert: 'aField updated by user 1' equals: ((secondSession root at: 'mockObject') aField).<br>
self assert: 'aField updated by user 1' equals: (mockObjectRefBySecondSession aField).<br><br> ] ensure: [[firstSession commit: [<br> firstSession root removeAll].<br> firstSession disconnect] <br> ensure: <br>
[secondSession disconnect]]<br> <br> <br> ! !<br><br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'tests' stamp: 'TestRunner 12/8/2009 20:17'!<br>testTriggerACommitConflictSequenceAsDescribedOnWiki<br>
|firstSession secondSession mockObjectRefByFirstSession mockObjectRefBySecondSession|<br> [firstSession :=<br> (MagmaRemoteLocation<br> host: 'localhost'<br> port: self databasePort) newSession.<br>
firstSession connectAs: 'firstSessionUser'.<br> firstSession commit: [<br> firstSession root<br> at: 'mockObject'<br> put: (SomeMockDomainObject new aField: 'aField content'; yourself)].<br>
<br> secondSession := <br> (MagmaRemoteLocation<br> host: 'localhost'<br> port: self databasePort) newSession.<br> secondSession connectAs: 'secondSessionUser'.<br> <br> firstSession begin. "1. User 1 begins a transaction."<br>
secondSession begin. "2. User 2 begins a transaction."<br> <br> mockObjectRefByFirstSession := firstSession root at: 'mockObject'. "User 1 is loading the object"<br> mockObjectRefBySecondSession := secondSession root at: 'mockObject'. "User 2 is loading the same version of the object as User 1"<br>
<br> mockObjectRefByFirstSession aField: 'aField updated by user 1'. "3. User 1 changes Object A."<br> firstSession commit. "4. User 1 commits his transaction."<br> <br> mockObjectRefBySecondSession aField: 'aField updated by user 2'. "5. User 2 changes Object A."<br>
<br> self should: [secondSession commit. "6.7. User 2 commits his transaction"]<br> raise: MagmaCommitConflictError.<br> <br> self assert: 'aField updated by user 1' equals: ((firstSession root at: 'mockObject') aField).<br>
self assert: 'aField updated by user 1' equals: ((secondSession root at: 'mockObject') aField).<br> self assert: 'aField updated by user 1' equals: (mockObjectRefBySecondSession aField).<br><br>
] ensure: [[firstSession commit: [<br> firstSession root removeAll].<br> firstSession disconnect] <br> ensure: <br> [secondSession disconnect]]<br> <br> <br> ! !<br><br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'tests' stamp: 'TestRunner 12/8/2009 20:47'!<br>
testTriggerACommitConflictUsersCommitAfterEachOtherButWithTheSameVersionOfObjectInitiallyLoaded<br> |firstSession secondSession mockObjectRefByFirstSession mockObjectRefBySecondSession|<br> [firstSession :=<br> (MagmaRemoteLocation<br>
host: 'localhost'<br> port: self databasePort) newSession.<br> firstSession connectAs: 'firstSessionUser'.<br> firstSession commit: [<br> firstSession root<br> at: 'mockObject'<br>
put: (SomeMockDomainObject new aField: 'aField content'; yourself)].<br> <br> secondSession := <br> (MagmaRemoteLocation<br> host: 'localhost'<br> port: self databasePort) newSession.<br> secondSession connectAs: 'secondSessionUser'.<br>
<br> mockObjectRefByFirstSession := firstSession root at: 'mockObject'. "User 1 is loading the object"<br> mockObjectRefBySecondSession := secondSession root at: 'mockObject'. "User 2 is loading the same version of the object as User 1" <br>
<br> firstSession begin. "1. User 1 begins a transaction."<br> mockObjectRefByFirstSession aField: 'aField updated by user 1'. "3. User 1 changes Object A."<br> firstSession commit. "4. User 1 commits his transaction."<br>
<br> secondSession begin. "2. User 2 begins a transaction."<br> mockObjectRefBySecondSession aField: 'aField updated by user 2'. "5. User 2 changes Object A."<br> <br> self should: [secondSession commit. "6.7. User 2 commits his transaction"]<br>
raise: MagmaCommitConflictError.<br> <br> firstSession refresh.<br> <br> self assert: 'aField updated by user 1' equals: ((firstSession root at: 'mockObject') aField).<br> self assert: 'aField updated by user 1' equals: ((secondSession root at: 'mockObject') aField).<br>
self assert: 'aField updated by user 1' equals: (mockObjectRefBySecondSession aField).<br><br> ] ensure: [[firstSession commit: [<br> firstSession root removeAll].<br> firstSession disconnect] <br> ensure: <br>
[secondSession disconnect]]<br> <br> <br> ! !<br><br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'running' stamp: 'TestRunner 12/8/2009 19:49'!<br>setUp<br> super setUp.<br> self ensureRepositoryCreated.<br>
magmaServerConsole := <br> MagmaServerConsole new<br> open: self databasePath;<br> processOn: self databasePort;<br> yourself.<br> <br> ! !<br><br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'running' stamp: 'TestRunner 12/8/2009 16:21'!<br>
tearDown<br> super tearDown.<br> magmaServerConsole shutdown.! !<br><br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'helper' stamp: 'TestRunner 12/8/2009 16:20'!<br>databasePath<br> ^'tryingToUnderStandMagmaCommitConflicts'! !<br>
<br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'helper' stamp: 'TestRunner 12/8/2009 16:26'!<br>databasePort<br> ^55789<br> <br> ! !<br><br>!BMTTryingToUnderstandMagmaCommitConflictsTest methodsFor: 'helper' stamp: 'TestRunner 12/8/2009 16:21'!<br>
ensureRepositoryCreated<br> ((FileDirectory forFileName: '') directoryExists: self databasePath)<br> ifFalse: <br> [MagmaRepositoryController<br> create: self databasePath<br> root: Dictionary new]. ! !<br>
<br><br>!SomeMockDomainObject methodsFor: 'accessing' stamp: 'TestRunner 12/8/2009 16:24'!<br>aField<br> ^ aField! !<br><br>!SomeMockDomainObject methodsFor: 'accessing' stamp: 'TestRunner 12/8/2009 16:24'!<br>
aField: anObject<br> aField := anObject! !<br><br>BMTTryingToUnderstandMagmaCommitConflictsTest removeSelector: #testTriggerACommitConflict!<br>BMTTryingToUnderstandMagmaCommitConflictsTest removeSelector: #testTriggerACommitConflict2!<br>
<br>!BMTTryingToUnderstandMagmaCommitConflictsTest reorganize!<br>('tests' testTriggerACommitConflictLoadObjectBeforeStartingATransaction testTriggerACommitConflictSequenceAsDescribedOnWiki testTriggerACommitConflictUsersCommitAfterEachOtherButWithTheSameVersionOfObjectInitiallyLoaded)<br>
('running' setUp tearDown)<br>('helper' databasePath databasePort ensureRepositoryCreated)<br>!<br><br><br></div>