module PgConduit
Constants
- VERSION
Public Class Methods
db_to_db(src, dest)
click to toggle source
Create a new DB -> DB Pipe
@param src [String,Hash] Source database connection params @param dest [String,Hash] Destination database connection params @return [PgConduit::Pipe]
# File lib/pg_conduit.rb, line 22 def db_to_db(src, dest) connections = Connections.new src, dest query_stream = QueryStream.new connections.src_pool db_writer = DBWriter.new connections.dest_pool Pipe.new from: query_stream, to: db_writer end
db_to_file(src, dest)
click to toggle source
Create a new DB -> File Pipe
@param src [String,Hash] Source database connection params @param dest [Sting,Pathname] Path to destination file @return [PgConduit::Pipe]
# File lib/pg_conduit.rb, line 35 def db_to_file(src, dest) pool = Connections.init_pool src query_stream = QueryStream.new pool file_writer = FileWriter.new dest Pipe.new from: query_stream, to: file_writer end
db_to_null(src)
click to toggle source
Create a new DB -> Null pipe
@param src [String,Hash] Source database connection params @return [PgConduit::Pipe]
# File lib/pg_conduit.rb, line 59 def db_to_null(src) pool = Connections.init_pool src query_stream = QueryStream.new pool stdout_writer = NullWriter.new Pipe.new from: query_stream, to: stdout_writer end
db_to_stdout(src)
click to toggle source
Create a new DB -> STDOUT Pipe
@param src [String,Hash] Source database connection params @return [PgConduit::Pipe]
# File lib/pg_conduit.rb, line 47 def db_to_stdout(src) pool = Connections.init_pool src query_stream = QueryStream.new pool stdout_writer = STDOUTWriter.new Pipe.new from: query_stream, to: stdout_writer end