From 714ffa324f5959f6d6e3d6779e42722ec054f076 Mon Sep 17 00:00:00 2001
From: Damian Hickey <dhickey@gmail.com>
Date: Wed, 4 Sep 2013 00:01:19 +0100
Subject: [PATCH] Oracle custom Persist Commit statment returns the Checkpoint
 number

---
 .../OracleNativeStatements.Designer.cs        | 44 ++++++++++--------
 .../SqlDialects/OracleNativeStatements.resx   | 45 +++++++++++--------
 2 files changed, 51 insertions(+), 38 deletions(-)

diff --git a/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.Designer.cs b/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.Designer.cs
index 9a36c22c8..0834091cb 100644
--- a/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.Designer.cs
+++ b/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.Designer.cs
@@ -274,28 +274,34 @@ internal class OracleNativeStatements {
         
         /// <summary>
         ///   Looks up a localized string similar to /*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
-        ///).
+        ///    :BucketId,
+        ///    :StreamId, 
+        ///    :StreamIdOriginal, 
+        ///    :CommitId, 
+        ///    :CommitSequence, 
+        ///    :StreamRevision, 
+        ///    :Items, 
+        ///    :CommitStamp, 
+        ///    :Headers, 
+        ///    :Payload
+        ///)
+        ///RETURNING CheckpointNumber INTO checkPointNum [rest of string was truncated]&quot;;.
         /// </summary>
         internal static string PersistCommit {
             get {
diff --git a/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.resx b/src/NEventStore/Persistence/SqlPersistence/SqlDialects/OracleNativeStatements.resx
index 59ce6a76c..1137e4c9e 100644
--- 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*/