Contents

class ThinkingSphinx::Deletion
  delegate :name, :to => :index

  def self.perform(index, instance)
    {
      'plain' => PlainDeletion,
      'rt'    => RealtimeDeletion
    }[index.type].new(index, instance).perform
  rescue Mysql2::Error => error
    # This isn't vital, so don't raise the error.
  end

  def initialize(index, instance)
    @index, @instance = index, instance
  end

  private

  attr_reader :index, :instance

  def connection
    @connection ||= ThinkingSphinx::Connection.new
  end

  def document_id_for_key
    index.document_id_for_key instance.id
  end

  def execute(statement)
    ThinkingSphinx::Connection.pool.take do |connection|
      connection.execute statement
    end
  end

  class RealtimeDeletion < ThinkingSphinx::Deletion
    def perform
      execute Riddle::Query::Delete.new(name, document_id_for_key).to_sql
    end
  end

  class PlainDeletion < ThinkingSphinx::Deletion
    def perform
      execute Riddle::Query.update(
        name, document_id_for_key, :sphinx_deleted => true
      )
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
thinking-sphinx-3.0.4	lib/thinking_sphinx/deletion.rb