module Myreplicator
  module ImportSql

    def self.load_data_infile *args
      options = args.extract_options!
      sql = ""
    end

    def self.initial_load *args
      options = args.extract_options!
      db = options[:db]
      cmd = ""

      # Destination database host
      db_host = db_configs(db).has_key?("host") ? db_configs(db)["host"] : "127.0.0.1"
      
      cmd = Myreplicator.mysql
      cmd += "-u#{db_configs(db)["username"]} -p#{db_configs(db)["password"]} "
      cmd += "-h#{db_host} " 
      cmd += " -P#{db_configs(db)["port"]} " if db_configs(db)["port"]
      cmd += " #{db} "
      cmd += " #{options[:table_name]} "
      cmd += " < #{options[:filepath]} "
    end

  end
end