Skip to content

Commit 98f9328

Browse files
authored
Remove invalid syntax from delete statements (#1737)
1 parent 97aeb84 commit 98f9328

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/DotNetCore.CAP.PostgreSql/IDataStorage.PostgreSql.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,7 @@ public async Task<IEnumerable<MediumMessage>> GetReceivedMessagesOfNeedRetry(Tim
234234

235235
public async Task<int> DeleteReceivedMessageAsync(long id)
236236
{
237-
var sql = $@"DELETE FROM {_recName} WHERE ""Id""={id} FOR DELETE SKIP LOCKED";
237+
var sql = $@"DELETE FROM {_recName} WHERE ""Id""={id}";
238238

239239
var connection = _options.Value.CreateConnection();
240240
await using var _ = connection.ConfigureAwait(false);
@@ -244,7 +244,7 @@ public async Task<int> DeleteReceivedMessageAsync(long id)
244244

245245
public async Task<int> DeletePublishedMessageAsync(long id)
246246
{
247-
var sql = $@"DELETE FROM {_pubName} WHERE ""Id""={id} FOR DELETE SKIP LOCKED";
247+
var sql = $@"DELETE FROM {_pubName} WHERE ""Id""={id}";
248248

249249
var connection = _options.Value.CreateConnection();
250250
await using var _ = connection.ConfigureAwait(false);

0 commit comments

Comments
 (0)