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.



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

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]
  @db = ::Turso::DB.new(config[:database].to_s, **db_opts)
end

Instance Method Details

#busy_timeout=(ms) ⇒ Object 



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

def busy_timeout=(ms)
  @db.busy_timeout = ms.to_i
end

#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
53
54
 
# File 'lib/turso/ar/connection.rb', line 50

def execute_batch(sql)
  split_batch(sql).each do |stmt|
    @db.execute(stmt)
  end
end

#interrupt ⇒ Object 



68
69
70
 
# File 'lib/turso/ar/connection.rb', line 68

def interrupt
  @db.interrupt
end

#last_insert_rowid ⇒ Object 



25
26
27
 
# File 'lib/turso/ar/connection.rb', line 25

def last_insert_rowid
  query("SELECT last_insert_rowid()").first&.values&.first.to_i
end

#open? ⇒ Boolean

Returns:

  • (Boolean) 


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

def open?
  !@db.closed?
end

#prepare(sql) ⇒ Object 



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

def prepare(sql)
  @db.prepare(sql)
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

#query_timeout=(ms) ⇒ Object 



64
65
66
 
# File 'lib/turso/ar/connection.rb', line 64

def query_timeout=(ms)
  @db.query_timeout = ms.to_i
end

#raw_connection ⇒ Object 



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

def raw_connection
  @db
end