43 lines
1.3 KiB
Ruby
43 lines
1.3 KiB
Ruby
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)
|
|
connection = ActiveRecord::Base.connection.raw_connection
|
|
remappable_columns = connection.async_exec(REMAP_SQL).to_a
|
|
args = [from, to, "%#{from}%"]
|
|
|
|
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)
|
|
connection = ActiveRecord::Base.connection.raw_connection
|
|
text_columns = connection.async_exec(REMAP_SQL).to_a
|
|
args = ["%#{needle}%"]
|
|
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
|