Contents

class Ridgepole::ExternalSqlExecuter
  def initialize(script, logger)
    @script = script
    @logger = logger
  end

  def execute(sql)
    cmd = Shellwords.join([@script, sql, JSON.dump(ActiveRecord::Base.connection_config)])
    @logger.info("Execute #{@script}")
    script_basename = File.basename(@script)

    Open3.popen3(cmd) do |stdin, stdout, stderr, wait_thr|
      stdin.close_write
      files = [stdout, stderr]

      begin
        until files.empty?
          ready = IO.select(files)

          if ready
            readable = ready[0]

            readable.each do |f|
              begin
                data = f.read_nonblock(1024)

                if f == stderr
                  @logger.warn("[WARNING] #{script_basename}: #{data}")
                else
                  @logger.info("#{script_basename}: #{data}")
                end
              rescue EOFError => e
                files.delete f
              end
            end
          end
        end
      rescue EOFError
      end

      unless wait_thr.value.success?
        raise "`#{@script}` execution failed"
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ridgepole-0.6.5.beta6	lib/ridgepole/external_sql_executer.rb