Sha256: a1bd72cdc93ef628c6113b14939ffe179486ad89347fbcf6ea1479d8594cd4c8
Contents?: true
Size: 1.4 KB
Versions: 23
Compression:
Stored size: 1.4 KB
Contents
module Forklift
module Base
class Connection
def initialize(config)
@config = config
end
def config
@config
end
def client
@client
end
def connect
# Will define @client
raise 'not implemented'
end
def disconnect
raise 'not implemented'
end
def read(query)
# will return an array of data rows
raise 'not implemented'
end
def write(data, collection)
# will write array data to collection (table)
raise 'not implemented'
end
def pipe
# when copying within the same connection, this method can be defined to speed things up
raise 'not implemented'
end
def exec(path)
begin
exec!(path)
rescue Exception => e
forklift.logger.log(e)
end
end
def exec!(path)
forklift.logger.log "Running script: #{path}"
extension = path.split(".").last
if(extension == "rb" || extension == "ruby")
exec_ruby(path)
else
exec_script(path)
end
end
def exec_ruby(path)
klass = forklift.utils.class_name_from_file(path)
require path
model = eval("#{klass}.new")
model.do!(self, forklift)
end
def exec_script(path)
raise 'not implemented'
end
end
end
end
Version data entries
23 entries across 23 versions & 1 rubygems