Sha256: a48326dbdcdea2259d2bdb13ff7026ab2ef23a100ed0e3688065f0cc7e9f1ff8
Contents?: true
Size: 843 Bytes
Versions: 18
Compression:
Stored size: 843 Bytes
Contents
#!/usr/bin/env ruby require 'pg' require 'stringio' # Using COPY asynchronously $stderr.puts "Opening database connection ..." conn = PG.connect( :dbname => 'test' ) conn.setnonblocking( true ) socket = IO.for_fd( conn.socket ) $stderr.puts "Running COPY command ..." buf = '' conn.transaction do conn.send_query( "COPY logs TO STDOUT WITH csv" ) buf = nil # #get_copy_data returns a row if there's a whole one to return, false # if there isn't one but the COPY is still running, or nil when it's # finished. begin $stderr.puts "COPY loop" conn.consume_input while conn.is_busy $stderr.puts " ready loop" select( [socket], nil, nil, 5.0 ) or raise "Timeout (5s) waiting for query response." conn.consume_input end buf = conn.get_copy_data $stdout.puts( buf ) if buf end until buf.nil? end conn.finish
Version data entries
18 entries across 18 versions & 1 rubygems