Class: MessageStore::Postgres::Session
- Inherits:
-
Object
- Object
- MessageStore::Postgres::Session
- Includes:
- Log::Dependency, Settings::Setting
- Defined in:
- lib/message_store/postgres/session.rb
Defined Under Namespace
Modules: LogText
Constant Summary collapse
- Error =
Class.new(RuntimeError)
Instance Attribute Summary collapse
-
#connection ⇒ Object
Returns the value of attribute connection.
Class Method Summary collapse
- .build(settings: nil) ⇒ Object
- .build_connection(instance) ⇒ Object
- .configure(receiver, session: nil, settings: nil, attr_name: nil) ⇒ Object
- .logger ⇒ Object
- .settings ⇒ Object
Instance Method Summary collapse
- #close ⇒ Object
- #connected? ⇒ Boolean (also: #open?)
- #execute(sql_command, params = nil) ⇒ Object
- #open ⇒ Object (also: #connect)
- #reset ⇒ Object
- #settings ⇒ Object
- #transaction(&blk) ⇒ Object
Instance Attribute Details
#connection ⇒ Object
Returns the value of attribute connection.
18 19 20 |
# File 'lib/message_store/postgres/session.rb', line 18 def connection @connection end |
Class Method Details
.build(settings: nil) ⇒ Object
20 21 22 23 24 25 |
# File 'lib/message_store/postgres/session.rb', line 20 def self.build(settings: nil) new.tap do |instance| settings ||= Settings.instance settings.set(instance) end end |
.build_connection(instance) ⇒ Object
59 60 61 62 63 64 65 66 67 68 69 |
# File 'lib/message_store/postgres/session.rb', line 59 def self.build_connection(instance) settings = instance.settings logger.trace(tag: :session) { "Building new connection to database (Settings: #{LogText.settings(settings).inspect})" } connection = PG::Connection.open(settings) connection.type_map_for_results = PG::BasicTypeMapForResults.new(connection) logger.debug(tag: :session) { "Built new connection to database (Settings: #{LogText.settings(settings).inspect})" } connection end |
.configure(receiver, session: nil, settings: nil, attr_name: nil) ⇒ Object
27 28 29 30 31 32 33 34 35 36 37 38 39 |
# File 'lib/message_store/postgres/session.rb', line 27 def self.configure(receiver, session: nil, settings: nil, attr_name: nil) attr_name ||= :session if session != nil && settings != nil error_msg = "Session configured with both settings and session arguments. Use one or the other, but not both." logger.error(tag: :session) { error_msg } raise Error, error_msg end instance = session || build(settings: settings) receiver.public_send "#{attr_name}=", instance instance end |
.logger ⇒ Object
131 132 133 |
# File 'lib/message_store/postgres/session.rb', line 131 def self.logger @logger ||= Log.get self end |
Instance Method Details
#close ⇒ Object
85 86 87 88 |
# File 'lib/message_store/postgres/session.rb', line 85 def close connection.close connection = nil end |
#connected? ⇒ Boolean Also known as: open?
71 72 73 74 75 76 77 78 79 80 81 82 |
# File 'lib/message_store/postgres/session.rb', line 71 def connected? return false if connection.nil? status = PG::CONNECTION_OK begin status = connection.status rescue PG::ConnectionBad status = nil end status == PG::CONNECTION_OK end |
#execute(sql_command, params = nil) ⇒ Object
103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 |
# File 'lib/message_store/postgres/session.rb', line 103 def execute(sql_command, params=nil) logger.trace(tag: :session) { "Executing SQL command" } logger.trace(tag: :sql) { sql_command } logger.trace(tag: :data) { params.pretty_inspect } unless connected? connect end if params.nil? connection.exec(sql_command).tap do logger.debug(tag: :session) { "Executed SQL command (no params)" } end else connection.exec_params(sql_command, params).tap do logger.debug(tag: :session) { "Executed SQL command with params" } end end end |
#open ⇒ Object Also known as: connect
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/message_store/postgres/session.rb', line 41 def open logger.trace(tag: :session) { "Connecting to database" } if connected? logger.debug(tag: :session) { "Already connected. A new connection will not be built." } return connection end logger.debug(tag: :session) { "Not connected. A new connection will be built." } connection = self.class.build_connection(self) self.connection = connection logger.debug(tag: :session) { "Connected to database" } connection end |
#reset ⇒ Object
90 91 92 |
# File 'lib/message_store/postgres/session.rb', line 90 def reset connection.reset end |
#settings ⇒ Object
94 95 96 97 98 99 100 101 |
# File 'lib/message_store/postgres/session.rb', line 94 def settings settings = {} self.class.settings.each do |s| val = public_send(s) settings[s] = val unless val.nil? end settings end |
#transaction(&blk) ⇒ Object
123 124 125 126 127 128 129 |
# File 'lib/message_store/postgres/session.rb', line 123 def transaction(&blk) unless connected? connect end connection.transaction(&blk) end |