Oracle custom Persist Commit statment returns the Checkpoint number

NEventStore · Sep 3, 2013 · 714ffa3 · 714ffa3
1 parent e111a47
commit 714ffa3
Show file tree

Hide file tree

Showing 2 changed files with 51 additions and 38 deletions.
diff --git a/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.Designer.cs b/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.Designer.cs
diff --git a/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.resx b/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.resx
@@ -292,28 +292,35 @@ WHERE ROW_NUMBER_VAL &gt; :Skip AND ROW_NUMBER_VAL &lt;= (:Limit + :Skip)</value
   </data>
   <data name="PersistCommit" xml:space="preserve">
     <value>/*PersistCommit*/
+DECLARE
+   checkPointNumber NUMBER;
+BEGIN
 INSERT INTO Commits (  
-	BucketId, StreamId, 
-	StreamIdOriginal,
-	CommitId, 
-	CommitSequence, 
-	StreamRevision, 
-	Items, 
-	CommitStamp, 
-	Headers, 
-	Payload
+    BucketId,
+    StreamId, 
+    StreamIdOriginal,
+    CommitId, 
+    CommitSequence, 
+    StreamRevision, 
+    Items, 
+    CommitStamp, 
+    Headers, 
+    Payload
 )  
 VALUES ( 
-	:BucketId, :StreamId, 
-	:StreamIdOriginal, 
-	:CommitId, 
-	:CommitSequence, 
-	:StreamRevision, 
-	:Items, 
-	:CommitStamp, 
-	:Headers, 
-	:Payload
-)</value>
+    :BucketId,
+    :StreamId, 
+    :StreamIdOriginal, 
+    :CommitId, 
+    :CommitSequence, 
+    :StreamRevision, 
+    :Items, 
+    :CommitStamp, 
+    :Headers, 
+    :Payload
+)
+RETURNING CheckpointNumber INTO checkPointNumber;
+END;</value>
   </data>
   <data name="PurgeBucket" xml:space="preserve">
     <value>/*PurgeStorage*/