diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.Designer.cs b/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.Designer.cs index d0ecc53..0115b01 100644 --- a/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.Designer.cs +++ b/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.Designer.cs @@ -110,7 +110,6 @@ internal static string DropTables { /// FROM Commits /// WHERE BucketId = @BucketId /// AND StreamId = @StreamId - /// AND CommitSequence = @CommitSequence /// AND CommitId = @CommitId;. /// internal static string DuplicateCommit { diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.resx b/src/NEventStore.Persistence.Sql/SqlDialects/CommonSqlStatements.resx index ae9b0dd..a92d17f 100644 --- 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; @@ -224,7 +223,7 @@ FROM Commits WHERE CheckpointNumber > @CheckpointNumber ORDER BY CheckpointNumber LIMIT @Limit OFFSET @Skip; - + 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 index a7d8654..2fdb0e2 100644 --- a/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.Designer.cs +++ b/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.Designer.cs @@ -124,7 +124,6 @@ internal static string DropTables { ///FROM Commits ///WHERE ( /// BucketId = :BucketId AND StreamId = :StreamId - /// AND CommitSequence = :CommitSequence /// AND CommitId = :CommitId ///). /// diff --git a/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.resx b/src/NEventStore.Persistence.Sql/SqlDialects/OracleNativeStatements.resx index 00a99d6..3828e9b 100644 --- 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 ) @@ -185,7 +184,7 @@ FROM Commits WHERE CheckpointNumber > :CheckpointNumber ORDER BY CheckpointNumber WHERE ROWNUM <= :Limit; - + /*GetCommitsFromBucketAndCheckpoint*/ SELECT BucketId, StreamId, StreamIdOriginal, StreamRevision, CommitId, CommitSequence, CommitStamp, CheckpointNumber, Headers, Payload