1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
Dir[File.join(File.dirname(__FILE__), '../vendor/*/lib')].each do |path|
$LOAD_PATH.unshift path
end
require 'active_record'
require 'riddle'
require 'after_commit'
require 'thinking_sphinx/core/string'
require 'thinking_sphinx/active_record'
require 'thinking_sphinx/association'
require 'thinking_sphinx/attribute'
require 'thinking_sphinx/collection'
require 'thinking_sphinx/configuration'
require 'thinking_sphinx/facet'
require 'thinking_sphinx/class_facet'
require 'thinking_sphinx/facet_collection'
require 'thinking_sphinx/field'
require 'thinking_sphinx/index'
require 'thinking_sphinx/rails_additions'
require 'thinking_sphinx/search'
require 'thinking_sphinx/deltas'
require 'thinking_sphinx/adapters/abstract_adapter'
require 'thinking_sphinx/adapters/mysql_adapter'
require 'thinking_sphinx/adapters/postgresql_adapter'
ActiveRecord::Base.send(:include, ThinkingSphinx::ActiveRecord)
Merb::Plugins.add_rakefiles(
File.join(File.dirname(__FILE__), "thinking_sphinx", "tasks")
) if defined?(Merb)
module ThinkingSphinx
module Version #:nodoc:
Major = 1
Minor = 1
Tiny = 6
String = [Major, Minor, Tiny].join('.')
end
# A ConnectionError will get thrown when a connection to Sphinx can't be
# made.
class ConnectionError < StandardError
end
# A StaleIdsException is thrown by Collection.instances_from_matches if there
# are records in Sphinx but not in the database, so the search can be retried.
class StaleIdsException < StandardError
attr_accessor :ids
def initialize(ids)
self.ids = ids
end
end
# The collection of indexed models. Keep in mind that Rails lazily loads
# its classes, so this may not actually be populated with _all_ the models
# that have Sphinx indexes.
def self.indexed_models
@@indexed_models ||= []
end
def self.unique_id_expression(offset = nil)
"* #{ThinkingSphinx.indexed_models.size} + #{offset || 0}"
end
# Check if index definition is disabled.
#
def self.define_indexes?
@@define_indexes = true unless defined?(@@define_indexes)
@@define_indexes == true
end
# Enable/disable indexes - you may want to do this while migrating data.
#
# ThinkingSphinx.define_indexes = false
#
def self.define_indexes=(value)
@@define_indexes = value
end
@@deltas_enabled = nil
# Check if delta indexing is enabled.
#
def self.deltas_enabled?
@@deltas_enabled = (ThinkingSphinx::Configuration.environment != 'test') if @@deltas_enabled.nil?
@@deltas_enabled
end
# Enable/disable all delta indexing.
#
# ThinkingSphinx.deltas_enabled = false
#
def self.deltas_enabled=(value)
@@deltas_enabled = value
end
@@updates_enabled = nil
# Check if updates are enabled. True by default, unless within the test
# environment.
#
def self.updates_enabled?
@@updates_enabled = (ThinkingSphinx::Configuration.environment != 'test') if @@updates_enabled.nil?
@@updates_enabled
end
# Enable/disable updates to Sphinx
#
# ThinkingSphinx.updates_enabled = false
#
def self.updates_enabled=(value)
@@updates_enabled = value
end
@@suppress_delta_output = false
def self.suppress_delta_output?
@@suppress_delta_output
end
def self.suppress_delta_output=(value)
@@suppress_delta_output = value
end
# Checks to see if MySQL will allow simplistic GROUP BY statements. If not,
# or if not using MySQL, this will return false.
#
def self.use_group_by_shortcut?
!!(
mysql? && ::ActiveRecord::Base.connection.select_all(
"SELECT @@global.sql_mode, @@session.sql_mode;"
).all? { |key,value| value.nil? || value[/ONLY_FULL_GROUP_BY/].nil? }
)
end
def self.sphinx_running?
!!sphinx_pid && pid_active?(sphinx_pid)
end
def self.sphinx_pid
pid_file = ThinkingSphinx::Configuration.instance.pid_file
cat_command = 'cat'
return nil unless File.exists?(pid_file)
if microsoft?
pid_file.gsub!('/', '\\')
cat_command = 'type'
end
`#{cat_command} #{pid_file}`[/\d+/]
end
def self.pid_active?(pid)
return true if microsoft?
begin
# In JRuby this returns -1 if the process doesn't exist
Process.getpgid(pid.to_i) != -1
rescue Exception => e
false
end
end
def self.microsoft?
RUBY_PLATFORM =~ /mswin/
end
def self.jruby?
defined?(JRUBY_VERSION)
end
def self.mysql?
::ActiveRecord::Base.connection.class.name.demodulize == "MysqlAdapter" || (
jruby? && ::ActiveRecord::Base.connection.config[:adapter] == "jdbcmysql"
)
end
end
|
