Contents

require 'open3'
require 'flydata/command/sync'
require 'flydata-core/mysql/command_generator'

module Flydata
  module Command

    class Mysql < Sync
      def run
        de = retrieve_sync_data_entry
        de['mysql_data_entry_preference'].delete('tables')
        cmd = FlydataCore::Mysql::CommandGenerator::generate_mysql_cmd(de['mysql_data_entry_preference'])
        if $stdin.tty?
          # interactive shell
          system cmd
        else
          # execute queries given to $stdin
          Open3.popen2e(cmd) do |i, o, wt|
            $stdin.each_line do |line|
              i.print line
            end
            i.close
            while line = o.gets
              print line
            end
          end
        end
      end

      def flush; end
      def reset; end
      def skip; end
      def generate_table_ddl; end
      def fix_binlogpos; end
    end

  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
flydata-0.5.13	lib/flydata/command/mysql.rb
flydata-0.5.12	lib/flydata/command/mysql.rb
flydata-0.5.11	lib/flydata/command/mysql.rb
flydata-0.5.10	lib/flydata/command/mysql.rb
flydata-0.5.9	lib/flydata/command/mysql.rb
flydata-0.5.8	lib/flydata/command/mysql.rb
flydata-0.5.7	lib/flydata/command/mysql.rb
flydata-0.5.6	lib/flydata/command/mysql.rb
flydata-0.5.5	lib/flydata/command/mysql.rb
flydata-0.5.4	lib/flydata/command/mysql.rb
flydata-0.5.3	lib/flydata/command/mysql.rb
flydata-0.5.2	lib/flydata/command/mysql.rb
flydata-0.5.1	lib/flydata/command/mysql.rb
flydata-0.5.0	lib/flydata/command/mysql.rb
flydata-0.4.3	lib/flydata/command/mysql.rb
flydata-0.4.2	lib/flydata/command/mysql.rb
flydata-0.4.1	lib/flydata/command/mysql.rb