Class: Moneta::Adapters::Sequel
- Inherits:
-
Object
- Object
- Moneta::Adapters::Sequel
- Includes:
- Defaults
- Defined in:
- lib/moneta/adapters/sequel.rb
Overview
Sequel backend
Instance Attribute Summary collapse
- #backend ⇒ Object readonly
Instance Method Summary collapse
-
#clear(options = {}) ⇒ void
Clear all keys in this store.
-
#close ⇒ Object
Explicitly close the store.
-
#create(key, value, options = {}) ⇒ Object
Store value with key.
-
#delete(key, options = {}) ⇒ Object
Delete the key from the store and return the current value.
-
#increment(key, amount = 1, options = {}) ⇒ Object
Atomically increment integer value with key.
-
#initialize(options = {}) ⇒ Sequel
constructor
A new instance of Sequel.
-
#key?(key, options = {}) ⇒ Boolean
Exists the value with key.
-
#load(key, options = {}) ⇒ Object
Fetch value with key.
-
#store(key, value, options = {}) ⇒ Object
Store value with key.
Methods included from Defaults
#[], #[]=, #decrement, #features, #fetch, included, #supports?
Methods included from OptionSupport
#expires, #prefix, #raw, #with
Constructor Details
#initialize(options = {}) ⇒ Sequel
Returns a new instance of Sequel.
18 19 20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/moneta/adapters/sequel.rb', line 18 def initialize( = {}) table = (.delete(:table) || :moneta).to_sym @backend = [:backend] || begin raise ArgumentError, 'Option :db is required' unless db = .delete(:db) ::Sequel.connect(db, ) end @backend.create_table?(table) do String :k, :null => false, :primary_key => true String :v end @table = @backend[table] end |
Instance Attribute Details
#backend ⇒ Object (readonly)
11 12 13 |
# File 'lib/moneta/adapters/sequel.rb', line 11 def backend @backend end |
Instance Method Details
#clear(options = {}) ⇒ void
This method returns an undefined value.
Clear all keys in this store
95 96 97 98 |
# File 'lib/moneta/adapters/sequel.rb', line 95 def clear( = {}) @table.delete self end |
#close ⇒ Object
Explicitly close the store
101 102 103 104 |
# File 'lib/moneta/adapters/sequel.rb', line 101 def close @backend.disconnect nil end |
#create(key, value, options = {}) ⇒ Object
Store value with key
57 58 59 60 61 62 63 64 |
# File 'lib/moneta/adapters/sequel.rb', line 57 def create(key, value, = {}) @table.insert(:k => key, :v => value) true rescue ::Sequel::DatabaseError # FIXME: This catches too many errors # it should only catch a not-unique-exception false end |
#delete(key, options = {}) ⇒ Object
Delete the key from the store and return the current value
87 88 89 90 91 92 |
# File 'lib/moneta/adapters/sequel.rb', line 87 def delete(key, = {}) if value = load(key, ) @table.filter(:k => key).delete value end end |
#increment(key, amount = 1, options = {}) ⇒ Object
Not every Moneta store implements this method, a NotImplementedError is raised if it is not supported.
Atomically increment integer value with key
This method also accepts negative amounts.
67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 |
# File 'lib/moneta/adapters/sequel.rb', line 67 def increment(key, amount = 1, = {}) @backend.transaction do locked_table = @table.for_update if record = locked_table[:k => key] value = Utils.to_int(record[:v]) + amount locked_table.where(:k => key).update(:v => value.to_s) value else locked_table.insert(:k => key, :v => amount.to_s) amount end end rescue ::Sequel::DatabaseError # FIXME: This catches too many errors # it should only catch a not-unique-exception tries ||= 0 (tries += 1) < 10 ? retry : raise end |
#key?(key, options = {}) ⇒ Boolean
Exists the value with key
33 34 35 |
# File 'lib/moneta/adapters/sequel.rb', line 33 def key?(key, = {}) @table[:k => key] != nil end |
#load(key, options = {}) ⇒ Object
Fetch value with key. Return nil if the key doesn’t exist
38 39 40 41 |
# File 'lib/moneta/adapters/sequel.rb', line 38 def load(key, = {}) record = @table[:k => key] record && record[:v] end |
#store(key, value, options = {}) ⇒ Object
Store value with key
44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/moneta/adapters/sequel.rb', line 44 def store(key, value, = {}) begin @table.insert(:k => key, :v => value) rescue ::Sequel::DatabaseError @table.where(:k => key).update(:v => value) end value rescue ::Sequel::DatabaseError tries ||= 0 (tries += 1) < 10 ? retry : raise end |