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
|
# frozen_string_literal: true
require 'spec_helper'
describe "Merging indices", :live => true do
let(:connection) { Mysql2::Client.new :host => '127.0.0.1', :port => 9306 }
let(:path) { "spec/fixtures/sphinx/spec.conf" }
let(:configuration) do
Riddle::Configuration::Parser.new(File.read(path)).parse!
end
let(:controller) { Riddle::Controller.new configuration, path }
let(:sphinx) { Sphinx.new }
def record_matches?(index, string)
select = Riddle::Query::Select.new
select.from index
select.matching string
select.to_sql
!!connection.query(select.to_sql).first
end
before :each do
controller.bin_path = sphinx.bin_path
sphinx.mysql_client.execute "USE riddle"
sphinx.mysql_client.execute "DELETE FROM articles"
end
it "merges in new records" do
controller.index
sphinx.mysql_client.execute <<-SQL
INSERT INTO articles (title, delta) VALUES ('pancakes', 1)
SQL
controller.index "article_delta"
sleep 1.5
expect(record_matches?("article_delta", "pancakes")).to eq(true)
expect(record_matches?("article_core", "pancakes")).to eq(false)
controller.merge "article_core", "article_delta"
sleep 1.5
expect(record_matches?("article_core", "pancakes")).to eq(true)
end
it "merges in existing records" do
sphinx.mysql_client.execute <<-SQL
INSERT INTO articles (title, delta) VALUES ('pancakes', 0)
SQL
controller.index
sleep 1.5
expect(record_matches?("article_core", "pancakes")).to eq(true)
expect(record_matches?("article_delta", "pancakes")).to eq(false)
sphinx.mysql_client.execute <<-SQL
UPDATE articles SET title = 'waffles', delta = 1 WHERE title = 'pancakes'
SQL
controller.index "article_delta"
sleep 1.5
expect(record_matches?("article_delta", "waffles")).to eq(true)
expect(record_matches?("article_core", "waffles")).to eq(false)
expect(record_matches?("article_core", "pancakes")).to eq(true)
id = connection.query("SELECT id FROM article_core").first["id"]
connection.query "UPDATE article_core SET deleted = 1 WHERE id = #{id}"
expect(
connection.query("SELECT id FROM article_core WHERE deleted = 1").to_a
).to_not be_empty
controller.merge "article_core", "article_delta",
:filters => {:deleted => 0}
sleep 1.5
expect(record_matches?("article_core", "pancakes")).to eq(false)
expect(record_matches?("article_core", "waffles")).to eq(true)
expect(
connection.query("SELECT id FROM article_core WHERE deleted = 1").to_a
).to be_empty
end
end unless RUBY_PLATFORM == 'java'
|
