Class: Turso::AR::Connection

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/turso/ar/connection.rb

Constant Summary collapse

DEFAULT_BUSY_TIMEOUT_MS = 
5000
DEFAULT_QUERY_TIMEOUT_MS = 
30_000

Instance Method Summary collapse

Constructor Details

#initialize(config) ⇒ Connection

Returns a new instance of Connection.



16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/turso/ar/connection.rb', line 16

def initialize(config)
  @config = config
  db_opts = {
    busy_timeout: config[:busy_timeout] || config[:timeout] || DEFAULT_BUSY_TIMEOUT_MS,
    query_timeout: config[:query_timeout] || DEFAULT_QUERY_TIMEOUT_MS
  }
  db_opts[:experimental_features] = config[:experimental_features] if config[:experimental_features]
  database = ::Turso::Database.new(config[:database].to_s, **db_opts)
  @db = database.connection
  @db.busy_timeout = db_opts[:busy_timeout]
  @db.query_timeout = db_opts[:query_timeout]
end

Instance Method Details

#disconnect! ⇒ Object 



37
38
39
 
# File 'lib/turso/ar/connection.rb', line 37

def disconnect!
  @db.close unless @db.closed?
end

#execute(sql, binds = []) ⇒ Object 



41
42
43
44
 
# File 'lib/turso/ar/connection.rb', line 41

def execute(sql, binds = [])
  @db.execute(sql, *normalize_binds(binds))
  nil
end

#execute_batch(sql) ⇒ Object 



50
51
52
 
# File 'lib/turso/ar/connection.rb', line 50

def execute_batch(sql)
  @db.execute_batch(sql)
end

#open? ⇒ Boolean

Returns:

  • (Boolean) 


33
34
35
 
# File 'lib/turso/ar/connection.rb', line 33

def open?
  !@db.closed?
end

#query(sql, params = []) ⇒ Object 



46
47
48
 
# File 'lib/turso/ar/connection.rb', line 46

def query(sql, params = [])
  @db.query(sql, *normalize_binds(params))
end

#raw_connection ⇒ Object 



29
30
31
 
# File 'lib/turso/ar/connection.rb', line 29

def raw_connection
  @db
end