Changed DuplicateCommit queries for #16

We need to create unique id on BuckedId+StreamId+CommitId
NEventStore · Mar 24, 2016 · 1676c03 · 1676c03
1 parent 31eb65f
commit 1676c03
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 6 deletions.
diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.Designer.cs b/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.Designer.cs
diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.resx b/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.resx
@@ -141,7 +141,6 @@ AND NOT EXISTS
   FROM Commits
  WHERE BucketId = @BucketId 
    AND StreamId = @StreamId
-   AND CommitSequence = @CommitSequence
    AND CommitId = @CommitId;</value>
   </data>
   <data name="GetCommitsFromInstant" xml:space="preserve">
@@ -210,7 +209,7 @@ FROM Commits
 WHERE  CheckpointNumber &gt; @CheckpointNumber
 ORDER BY CheckpointNumber
  LIMIT @Limit OFFSET @Skip;</value>
-  </data>  
+  </data>
   <data name="GetCommitsFromBucketAndCheckpoint" xml:space="preserve">
     <value>SELECT BucketId, StreamId, StreamIdOriginal, StreamRevision, CommitId, CommitSequence, CommitStamp, CheckpointNumber, Headers, Payload
   FROM Commits

diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.Designer.cs b/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.Designer.cs
diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.resx b/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.resx
@@ -157,7 +157,6 @@ SELECT CAST( COUNT(*) AS NUMBER(8,0) )
 FROM Commits 
 WHERE	(
   BucketId = :BucketId AND StreamId = :StreamId
-  AND CommitSequence = :CommitSequence
   AND CommitId = :CommitId
 )</value>
   </data>
@@ -185,7 +184,7 @@ FROM Commits
 WHERE  CheckpointNumber &gt; :CheckpointNumber
 ORDER BY CheckpointNumber
 WHERE ROWNUM &lt;= :Limit;</value>
-  </data>  
+  </data>
   <data name="GetCommitsFromBucketAndCheckpoint" xml:space="preserve">
     <value>/*GetCommitsFromBucketAndCheckpoint*/
 SELECT BucketId, StreamId, StreamIdOriginal, StreamRevision, CommitId, CommitSequence, CommitStamp, CheckpointNumber, Headers, Payload