Sha256: a58b4d930e7e37dd0c5505f3585b86650944f0a8c7c8384d3ecb21db64da2413
Contents?: true
Size: 669 Bytes
Versions: 79
Compression:
Stored size: 669 Bytes
Contents
require("cipherstash-pg")
require("stringio")
$stderr.puts("Opening database connection ...")
conn = CipherStashPG.connect(:dbname => "test")
conn.setnonblocking(true)
socket = conn.socket_io
$stderr.puts("Running COPY command ...")
buf = ""
conn.transaction do
conn.send_query("COPY logs TO STDOUT WITH csv")
buf = nil
begin
($stderr.puts("COPY loop")
conn.consume_input
while conn.is_busy do
$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
79 entries across 79 versions & 1 rubygems