Class: SCAnalytics::Connections::Oracle

Inherits:
Connection
  • Object
show all
Defined in:
lib/sc_analytics/connections/oracle.rb

Instance Attribute Summary

Attributes inherited from Connection

#host, #port, #service, #username

Instance Method Summary collapse

Constructor Details

#initialize(connection_name, options) ⇒ Oracle 



7
8
9
10
11
12
 
# File 'lib/sc_analytics/connections/oracle.rb', line 7

def initialize(connection_name, options)
	super

	parse_db_url
	connect
end

Instance Method Details

#connect ⇒ Object 



40
41
42
43
44
 
# File 'lib/sc_analytics/connections/oracle.rb', line 40

def connect
	super do
		@client = OCI8.new @username, @password, @db_url
	end
end

#define_col_types_for(query, cursor) ⇒ Object 



14
15
16
17
18
19
20
 
# File 'lib/sc_analytics/connections/oracle.rb', line 14

def define_col_types_for(query, cursor)
	(query.columns_to_cast || {}).each_pair do |type, cols|
		cols.each do |col|
			cursor.define(col, type)
		end
	end
end

#get_cursor_for(query) ⇒ Object 



22
23
24
 
# File 'lib/sc_analytics/connections/oracle.rb', line 22

def get_cursor_for(query)
	cursor = @client.parse(query.sql)
end

#parse_db_url ⇒ Object 



46
47
48
49
50
51
52
53
54
 
# File 'lib/sc_analytics/connections/oracle.rb', line 46

def parse_db_url
	url = []
	url << "//#{@host}" if @host
	url << ":#{@port}" if @port
	url << "/" if @host
	url << @service

	@db_url = url.join
end

#run(query, cursor) ⇒ Object 



26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/sc_analytics/connections/oracle.rb', line 26

def run(query, cursor)
	cursor.exec
	define_col_types_for query, cursor

	headers = cursor.get_col_names
	results = []
	
	while row = cursor.fetch
		results << row
	end

	Struct::QueryResult.new(headers, results)
end