|
@@ -44,11 +44,6 @@ module Blazer
|
|
|
result.rows.map(&:first)
|
|
|
end
|
|
|
|
|
|
- def schemas
|
|
|
- default_schema = (postgresql? || redshift?) ? "public" : connection_model.connection_config[:database]
|
|
|
- settings["schemas"] || [connection_model.connection_config[:schema] || default_schema]
|
|
|
- end
|
|
|
-
|
|
|
def reconnect
|
|
|
connection_model.establish_connection(settings["url"])
|
|
|
end
|
|
@@ -85,6 +80,11 @@ module Blazer
|
|
|
connection_model.connection.adapter_name
|
|
|
end
|
|
|
|
|
|
+ def schemas
|
|
|
+ default_schema = (postgresql? || redshift?) ? "public" : connection_model.connection_config[:database]
|
|
|
+ settings["schemas"] || [connection_model.connection_config[:schema] || default_schema]
|
|
|
+ end
|
|
|
+
|
|
|
def set_timeout(timeout)
|
|
|
if postgresql? || redshift?
|
|
|
connection_model.connection.execute("SET statement_timeout = #{timeout.to_i * 1000}")
|