Class: DB::Postgres::Connection
- Inherits:
-
Async::Pool::Resource
- Object
- Async::Pool::Resource
- DB::Postgres::Connection
- Defined in:
- lib/db/postgres/connection.rb
Overview
This implements the interface between the underlying
Instance Method Summary collapse
- #append_identifier(value, buffer = String.new) ⇒ Object
- #append_literal(value, buffer = String.new) ⇒ Object
- #append_string(value, buffer = String.new) ⇒ Object
- #close ⇒ Object
-
#initialize(**options) ⇒ Connection
constructor
A new instance of Connection.
- #key_column(name = 'id', primary: true, null: false) ⇒ Object
- #next_result ⇒ Object
- #send_query(statement) ⇒ Object
- #status ⇒ Object
Constructor Details
#initialize(**options) ⇒ Connection
Returns a new instance of Connection.
32 33 34 35 36 |
# File 'lib/db/postgres/connection.rb', line 32 def initialize(**) @native = Native::Connection.connect(**) super() end |
Instance Method Details
#append_identifier(value, buffer = String.new) ⇒ Object
67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 |
# File 'lib/db/postgres/connection.rb', line 67 def append_identifier(value, buffer = String.new) case value when Array first = true value.each do |part| buffer << '.' unless first first = false buffer << @native.escape_identifier(part) end else buffer << @native.escape_identifier(value) end return buffer end |
#append_literal(value, buffer = String.new) ⇒ Object
50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File 'lib/db/postgres/connection.rb', line 50 def append_literal(value, buffer = String.new) case value when Numeric buffer << value.to_s when TrueClass buffer << 'TRUE' when FalseClass buffer << 'FALSE' when nil buffer << 'NULL' else append_string(value, buffer) end return buffer end |
#append_string(value, buffer = String.new) ⇒ Object
44 45 46 47 48 |
# File 'lib/db/postgres/connection.rb', line 44 def append_string(value, buffer = String.new) buffer << @native.escape_literal(value) return buffer end |
#close ⇒ Object
38 39 40 41 42 |
# File 'lib/db/postgres/connection.rb', line 38 def close @native.close super end |
#key_column(name = 'id', primary: true, null: false) ⇒ Object
84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
# File 'lib/db/postgres/connection.rb', line 84 def key_column(name = 'id', primary: true, null: false) buffer = String.new append_identifier(name, buffer) if primary buffer << " BIGSERIAL" else buffer << " BIGINT" end if primary buffer << " PRIMARY KEY" elsif !null buffer << " NOT NULL" end return buffer end |
#next_result ⇒ Object
114 115 116 |
# File 'lib/db/postgres/connection.rb', line 114 def next_result @native.next_result end |
#send_query(statement) ⇒ Object
108 109 110 111 112 |
# File 'lib/db/postgres/connection.rb', line 108 def send_query(statement) @native.discard_results @native.send_query(statement) end |
#status ⇒ Object
104 105 106 |
# File 'lib/db/postgres/connection.rb', line 104 def status @native.status end |