mirror of
https://github.com/scinote-eln/scinote-web.git
synced 2024-11-11 01:44:34 +08:00
80 lines
2.4 KiB
Ruby
80 lines
2.4 KiB
Ruby
class Table < ActiveRecord::Base
|
|
include SearchableModel
|
|
validates :contents,
|
|
presence: true,
|
|
length: { maximum: 20971520 }
|
|
|
|
belongs_to :created_by, foreign_key: 'created_by_id', class_name: 'User'
|
|
belongs_to :last_modified_by, foreign_key: 'last_modified_by_id', class_name: 'User'
|
|
has_one :step_table, inverse_of: :table
|
|
has_one :step, through: :step_table
|
|
|
|
has_one :result_table, inverse_of: :table
|
|
has_one :result, through: :result_table
|
|
has_many :report_elements, inverse_of: :table, dependent: :destroy
|
|
|
|
after_save :update_ts_index
|
|
#accepts_nested_attributes_for :table
|
|
|
|
def self.search(user, include_archived, query = nil, page = 1)
|
|
step_ids =
|
|
Step
|
|
.search(user, include_archived, nil, SHOW_ALL_RESULTS)
|
|
.joins(:step_tables)
|
|
.select("step_tables.id")
|
|
.distinct
|
|
|
|
result_ids =
|
|
Result
|
|
.search(user, include_archived, nil, SHOW_ALL_RESULTS)
|
|
.joins(:result_table)
|
|
.select("result_tables.id")
|
|
.distinct
|
|
|
|
# Trim whitespace and replace it with OR character. Make prefixed
|
|
# wildcard search term and escape special characters.
|
|
# For example, search term 'demo project' is transformed to
|
|
# 'demo:*|project:*' which makes word inclusive search with postfix
|
|
# wildcard.
|
|
s_query = query.gsub(/[!()&|:]/, " ")
|
|
.strip
|
|
.split(/\s+/)
|
|
.map {|t| t + ":*" }
|
|
.join("|")
|
|
.gsub('\'', '"')
|
|
|
|
table_query = Table
|
|
.distinct
|
|
.joins("LEFT OUTER JOIN step_tables ON step_tables.table_id = tables.id")
|
|
.joins("LEFT OUTER JOIN result_tables ON result_tables.table_id = tables.id")
|
|
.joins("LEFT OUTER JOIN results ON result_tables.result_id = results.id")
|
|
.where("step_tables.id IN (?) OR result_tables.id IN (?)", step_ids, result_ids)
|
|
.where("tables.data_vector @@ to_tsquery(?) ", s_query)
|
|
|
|
new_query = table_query
|
|
|
|
# Show all results if needed
|
|
if page == SHOW_ALL_RESULTS
|
|
new_query
|
|
else
|
|
new_query
|
|
.limit(SEARCH_LIMIT)
|
|
.offset((page - 1) * SEARCH_LIMIT)
|
|
end
|
|
end
|
|
|
|
def contents_utf_8
|
|
contents.present? ? contents.force_encoding(Encoding::UTF_8) : nil
|
|
end
|
|
|
|
def update_ts_index
|
|
if contents_changed?
|
|
sql = "UPDATE tables " +
|
|
"SET data_vector = " +
|
|
"to_tsvector(substring(encode(contents::bytea, 'escape'), 9)) " +
|
|
"WHERE id = " + Integer(id).to_s
|
|
Table.connection.execute(sql)
|
|
end
|
|
end
|
|
end
|
|
|