Удаление Solr с пользовательским полным импортом

Вы должны использовать специальные команды обработчика импорта

https://wiki.apache.org/solr/DataImportHandler#Special_Commands

С помощью этих команд вы можете изменить увеличение или удалить документ, поступающий из набора записей полного запроса на импорт. Имейте в виду, что вы должны использовать поле $skipDoc, чтобы избежать повторной индексации документа, и что вы должны повторить идентификатор в поле $deleteDocById.

Вы можете использовать запрос на объединение

select 
  id, 
  text, 
  'false' as [$deleteDocById],
  'false' as [$skipDoc]
from [rows to update or add]
Union Select
   id, 
   '' as text,
   id as [$deleteDocById],
   true as [$skipDoc]

или случай, когда

select
  id,
  text,
  CASE
    when deleted = 1 then id
    else 'false'
  END as [$deleteDocById],
  CASE
    when deleted = 1 then 'true'
    else 'false'
  END as [$skipDoc]
  Where updated > ${dih.last_index_time}

deletedPkQuery запускается как часть обычного вызова delta-import, поэтому вам не нужно ничего запускать дважды (и при выполнении полного импорта нет необходимости запускать deletePkQuery, так как все соединение очищается перед импортом в любом случае).

deletedPkQuery должен быть настроен на тот же элемент, что и ваш основной запрос. Убедитесь, что имена полей точно совпадают, и что id, созданный вашим deletePkQuery, совпадает с именем, предоставленным основным запросом.

Там есть минимальный пример на solr.pl для импорта и удаления полей с использованием той же структуры таблицы delete_entries, что и здесь:

<entity 
  name="album" 
  query="SELECT * from albums"
  deletedPkQuery="SELECT deleted_id as id FROM deletes WHERE deleted_at > '${dataimporter.last_index_time}'"
>

Также убедитесь, что формат поля delete_at сопоставим со значением, созданным last_index_time. По умолчанию yyyy-MM-dd HH:mm:ss.

.. и, наконец, помните, что свойство last_index_time недоступно до второго запуска задачи, поскольку при первом заполнении индекса нет «предыдущего времени индекса» (но deletedPkQuery все равно не должен запускаться до этого ).