class Mysql2json

Public Class Methods

query(q, client) click to toggle source

# File lib/mysql2json_elasticsearch.rb, line 39
def self.query(q, client)
        results = client.query(q)
        return convert(results)
end

query_export(q, client, filename) click to toggle source

# File lib/mysql2json_elasticsearch.rb, line 44
def self.query_export(q, client, filename)
        results = client.query(q)
        json_data = convert(results)
        file = File.open(filename, 'w+')
        file.write(json_data)
        file.close()
        puts 'Data written to %s' % filename
end