Sha256: ec9e461c5b60e013a6747bca3a7101d1cf7741347432ad70bb75a0eb72db7010

Contents?: true

Size: 771 Bytes

Versions: 1

Compression:

Stored size: 771 Bytes

Contents

unless defined? $__rq_queryier__
  module RQ 
#{{{
    LIBDIR = File::dirname(File::expand_path(__FILE__)) + File::SEPARATOR unless
      defined? LIBDIR

    require LIBDIR + 'mainhelper'

    class Querier < MainHelper
#{{{
      def query
    #{{{
        set_q
        where_clause = @argv.join ' '
        if where_clause.empty? or not STDIN.tty?
          debug{ "reading where_clause from STDIN" }
          while((buf = STDIN.gets))
            buf.strip!
            buf.gsub! %r/#.*$/o, ''
            next if buf.empty?
            where_clause << "#{ buf } "
          end
        end
        @q.qdb.transaction_retries = 1
        @q.query where_clause
    #}}}
      end
#}}}
    end # class Queryier
#}}}
  end # module RQ
$__rq_queryier__ = __FILE__ 
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
rq-0.1.7 lib/rq-0.1.7/querier.rb