Changed DuplicateCommit queries for #16

We need to create unique id on BuckedId+StreamId+CommitId Closes #16
NEventStore · Apr 13, 2016 · bee8fa3 · bee8fa3
1 parent bf1600e
commit bee8fa3
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">
@@ -224,7 +223,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