Module: JunglePath::DBAccess::IO

Defined in:
lib/jungle_path/db_access/io.rb,
lib/jungle_path/db_access/io/db.rb,
lib/jungle_path/db_access/io/copy.rb,
lib/jungle_path/db_access/io/config.rb,
lib/jungle_path/db_access/io/delete.rb,
lib/jungle_path/db_access/io/insert.rb,
lib/jungle_path/db_access/io/schema.rb,
lib/jungle_path/db_access/io/select.rb,
lib/jungle_path/db_access/io/update.rb,
lib/jungle_path/db_access/io/init_db.rb,
lib/jungle_path/db_access/io/chunked_file_reader.rb

Defined Under Namespace

Modules: InitDB Classes: ChunkedFileReader, Config, Copy, DB, Delete, Insert, Schema, Select, Update

Class Method Summary collapse

Class Method Details

.clone_config(config) ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
77
 
# File 'lib/jungle_path/db_access/io.rb', line 66

def self.clone_config(config)
	JunglePath::DBAccess::IO::Config.new(
		name: config.name,
		type: config.type,
		user_name: config.user_name,
		password: config.password,
		host: config.host,
		extensions: config.extensions,
		port: config.port,
		options: config.options
	)
end

.connection(database_type:, user_name:, database_name:, host: "localhost", extensions: [], password: nil, port: nil, options: nil) ⇒ Object 



79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/jungle_path/db_access/io.rb', line 79

def self.connection(database_type:, user_name:, database_name:, host: "localhost", extensions: [], password: nil, port: nil, options: nil)
	Sequel.default_timezone = :utc
	colon_port = ":#{port}" if port
	options = {} unless options
	if password
		puts "Using db connection with explicit password!"
		connection_string = "#{database_type}://#{user_name}:#{password}@#{host}#{colon_port}/#{database_name}"
		puts "connection_string: #{connection_string}."
		db = Sequel.connect(connection_string, options)
		puts "connected."
	else
		puts "no explicit pw."
		connection_string = "#{database_type}://#{user_name}@#{host}#{colon_port}/#{database_name}"
		puts "connection_string: #{connection_string}."
		db = Sequel.connect(connection_string, options)
		puts "connected."
	end
	extensions.each do |extension|
		puts "Adding Sequel extension: #{extension}."
		db.extension extension
	end
	db
end

.connection_from_config(config) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/jungle_path/db_access/io.rb', line 17

def self.connection_from_config(config)
	connection(
		database_type: config.type,
		user_name: config.user_name,
		database_name: config.name,
		host: config.host,
		extensions: config.extensions,
		password: config.password,
		port: config.port,
		options: config.options
	)
end

.connection_from_config_unknown_database(config) ⇒ Object 



30
31
32
33
34
35
36
37
38
 
# File 'lib/jungle_path/db_access/io.rb', line 30

def self.connection_from_config_unknown_database(config)
	if config.type == 'postgres'
		connection_from_config_use_postgres_db(config)
	elsif config.type == 'tinytds'
		connection_from_config_use_ms_sql_server_db(config)
	else
		throw "Unknown database type: #{config.type}."
	end
end

.connection_from_config_use_ms_sql_server_db(config) ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/jungle_path/db_access/io.rb', line 40

def self.connection_from_config_use_ms_sql_server_db(config)
	db = connection(
		database_type: config.type,
		user_name: config.user_name,
		database_name: 'master',
		host: config.host,
		extensions: config.extensions,
		password: config.password,
		port: config.port,
		options: config.options
	)
end

.connection_from_config_use_postgres_db(config) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/jungle_path/db_access/io.rb', line 53

def self.connection_from_config_use_postgres_db(config)
	db = connection(
		database_type: config.type,
		user_name: config.user_name,
		database_name: 'postgres',
		host: config.host,
		extensions: config.extensions,
		password: config.password,
		port: config.port,
		options: config.options
	)
end