Как удалить записи с базы используя limit?

Question

[uRoot]

У меня есть таблица:

Таблица

CREATE TABLE public.order_clients (
  order_id int8 NOT NULL,
  client_id int8 NOT NULL,
  linked_at timestamptz DEFAULT now() NOT NULL,
);

В таблице есть дубликаты, и я хочу удалить все не уникальные строки (связка order_id и client_id должна быть уникальной).
Но проблема в том, что я не знаю, как удалить только первые 1000 строк. Таблица огромная, и я должен удалять по 1000 строк за раз. Записи буду удалять скриптом на Node.JS.

Мой старый запрос:

delete from order_clients
where (client_id, order_id, linked_at) not in (
  select client_id, order_id, max(linked_at) as max_linked_at
  from order_clients
  group by client_id, order_id
)

Comments

[Виктор]

А что не так при добавлении LIMIT?

[uRoot]

Виктор, я не могу использовать limit с delete. Если я lomit бахну в подзапрос, то тогда уже логика ломается.

[Виктор]

uRoot,

логика ломается

как ломается?

[uRoot]

Виктор, если выставить лимит 10, то в БД останется 10 записей))

[Виктор]

uRoot, покажите запрос с LIMIT. Подозреваю, что его нужно вставить не внутри подзапроса, а после него, т.е. обернуть подзапрос в еще один подзапрос.

[uRoot]

Виктор, та он выглядит как тот, что я прикрепил.

delete from order_clients
where (client_id, order_id, linked_at) not in (
  select client_id, order_id, max(linked_at) as max_linked_at
  from order_clients
  group by client_id, order_id
  limit 10
)

[Виктор]

uRoot, а если так?

delete from order_clients
where (client_id, order_id, linked_at) not in (
  select client_id, order_id, max_linked_at
  from (
    select client_id, order_id, max(linked_at) as max_linked_at
    from order_clients
    group by client_id, order_id
  ) 'g'
  limit 10
)

[uRoot]

Виктор, удаляет все записи. Та ладно. Решил с другой стороньі зайти

Answer 1

[Rsa97]

PostgreSQL?

DELETE FROM order_clients
  WHERE ctid IN (
    SELECT DISTINCT o.ctid 
      FROM order_clients AS o
      JOIN order_clients AS t
        ON t.client_id = o.client_id AND t.order_id = o.order_id
          AND t.linked_at < o.linked_at
      LIMIT 1000
  );

Comments

[uRoot]

Да, PostgreSQL.
О, интересный подход.

[uRoot]

Вопрос. А если в момент удаления будут добавлены новые записи, то удаление с использованием ctid ничего не сломает?

[Rsa97]

uRoot, По умолчанию каждая команда выполняется в своей транзакции, так что ничего не сломается.