Class: GroongaDelta::MySQLSource

Inherits:
Object
  • Object
show all
Defined in:
lib/groonga-delta/mysql-source.rb

Instance Method Summary collapse

Constructor Details

#initialize(config, status) ⇒ MySQLSource

Returns a new instance of MySQLSource.



24
25
26
27
28
29
30
31
32
 
# File 'lib/groonga-delta/mysql-source.rb', line 24

def initialize(config, status)
  @logger = config.logger
  @writer = Writer.new(@logger, config.delta_dir)
  @config = config.mysql
  @binlog_dir = @config.binlog_dir
  @mapping = config.mapping
  @status = status.mysql
  @tables = {}
end

Instance Method Details

#import ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/groonga-delta/mysql-source.rb', line 34

def import
  case ENV["GROONGA_DELTA_IMPORT_MYSQL_SOURCE_BACKEND"]
  when "mysqlbinlog"
    require "mysql_binlog"
    import_mysqlbinlog
  when "mysql2-replication"
    require "mysql2-replication"
    import_mysql2_replication
  else
    begin
      require "mysql2-replication"
    rescue LoadError
      require "mysql_binlog"
      import_mysqlbinlog
    else
      import_mysql2_replication
    end
  end
end