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.



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/turso/ar/connection.rb', line 17

def initialize(config)
  @config = config
  @owner = owner_token
  db_opts = {
    busy_timeout: config[:busy_timeout] || config[:timeout] || DEFAULT_BUSY_TIMEOUT_MS,
    query_timeout: config[:query_timeout] || DEFAULT_QUERY_TIMEOUT_MS
  }
  if config[:experimental_features]
    features = Array(config[:experimental_features]).map(&:to_s).reject(&:empty?)
    db_opts[:experimental_features] = features.join(",") unless features.empty?
  end
  @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 



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

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

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



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

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

#execute_batch(sql) ⇒ Object 



59
60
61
 
# File 'lib/turso/ar/connection.rb', line 59

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

#open? ⇒ Boolean

Returns:

  • (Boolean) 


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

def open?
  !@db.closed?
end

#owned_by_current_execution_context? ⇒ Boolean

Returns:

  • (Boolean) 


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

def owned_by_current_execution_context?
  @owner == owner_token
end

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



55
56
57
 
# File 'lib/turso/ar/connection.rb', line 55

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

#raw_connection ⇒ Object 



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

def raw_connection
  @db
end