class Dataflow::Adapters::MysqlAdapter

Interface between a data node and mongodb. We use mongodb to perform all the store/retrieve operations.

Public Instance Methods

regex_case_insensitive_op() click to toggle source
# File lib/dataflow/adapters/mysql_adapter.rb, line 24
def regex_case_insensitive_op
  'REGEXP'
end
regex_case_senstive_op() click to toggle source
# File lib/dataflow/adapters/mysql_adapter.rb, line 20
def regex_case_senstive_op
  raise NotImplementedError, 'Mysql does not support a case sensitive regex matching operator'
end
usage(dataset:) click to toggle source
# File lib/dataflow/adapters/mysql_adapter.rb, line 7
def usage(dataset:)
  size = client["SELECT data_length + index_length as size from information_schema.TABLES WHERE table_schema = '#{settings.db_name}' and table_name = '#{dataset}'"].first[:size]
  {
    memory: size,
    storage: size
  }
rescue Sequel::DatabaseError => e
  {
    memory: 0,
    storage: 0
  }
end