discourse/lib/db_helper.rb

class DbHelper

  REMAP_SQL ||= "
    SELECT table_name, column_name
      FROM information_schema.columns
     WHERE table_schema = 'public'
       AND is_updatable = 'YES'
       AND (data_type LIKE 'char%' OR data_type LIKE 'text%')
  ORDER BY table_name, column_name"

  def self.remap(from, to, anchor_left = false, anchor_right = false)
    connection = ActiveRecord::Base.connection.raw_connection
    remappable_columns = connection.async_exec(REMAP_SQL).to_a
    args = [from, to, "#{anchor_left ? '' : "%"}#{from}#{anchor_right ? '' : "%"}"]

    remappable_columns.each do |rc|
      table_name = rc["table_name"]
      column_name = rc["column_name"]
      connection.async_exec("UPDATE #{table_name} SET #{column_name} = REPLACE(#{column_name}, $1, $2) WHERE #{column_name} LIKE $3", args) rescue nil
    end

    SiteSetting.refresh!
  end

  def self.find(needle, anchor_left = false, anchor_right = false)
    connection = ActiveRecord::Base.connection.raw_connection
    text_columns = connection.async_exec(REMAP_SQL).to_a
    args = ["#{anchor_left ? '' : "%"}#{needle}#{anchor_right ? '' : "%"}"]
    found = {}

    text_columns.each do |rc|
      table_name = rc["table_name"]
      column_name = rc["column_name"]
      result = connection.async_exec("SELECT #{column_name} FROM #{table_name} WHERE #{column_name} LIKE $1", args) rescue nil
      if result&.ntuples > 0
        found["#{table_name}.#{column_name}"] = result.map { |r| r[column_name] }
      end
    end
    found
  end

end