Class: DB::MariaDB::Connection
- Inherits:
-
Async::Pool::Resource
- Object
- Async::Pool::Resource
- DB::MariaDB::Connection
- Defined in:
- lib/db/mariadb/connection.rb
Overview
This implements the interface between the underyling native interface interface and “standardised” connection interface.
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/mariadb/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/mariadb/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 << escape_identifier(part) end else buffer << 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/mariadb/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/mariadb/connection.rb', line 44 def append_string(value, buffer = String.new) buffer << "'" << @native.escape(value) << "'" return buffer end |
#close ⇒ Object
38 39 40 41 42 |
# File 'lib/db/mariadb/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 |
# File 'lib/db/mariadb/connection.rb', line 84 def key_column(name = 'id', primary: true, null: false) buffer = String.new append_identifier(name, buffer) buffer << " BIGINT AUTO_INCREMENT" if primary buffer << " PRIMARY KEY" elsif !null buffer << " NOT NULL" end return buffer end |
#next_result ⇒ Object
110 111 112 |
# File 'lib/db/mariadb/connection.rb', line 110 def next_result @native.next_result end |
#send_query(statement) ⇒ Object
104 105 106 107 108 |
# File 'lib/db/mariadb/connection.rb', line 104 def send_query(statement) @native.discard_results @native.send_query(statement) end |
#status ⇒ Object
100 101 102 |
# File 'lib/db/mariadb/connection.rb', line 100 def status @native.status end |