Class: Moneta::Adapters::DataMapper
- Inherits:
-
Object
- Object
- Moneta::Adapters::DataMapper
- Includes:
- Defaults
- Defined in:
- lib/moneta/adapters/datamapper.rb
Overview
Datamapper backend
Defined Under Namespace
Classes: Store
Instance Method Summary collapse
-
#clear(options = {}) ⇒ void
Clear all keys in this store.
-
#create(key, value, options = {}) ⇒ Boolean
Atomically sets a key to value if it’s not set.
-
#delete(key, options = {}) ⇒ Object
Delete the key from the store and return the current value.
-
#initialize(options = {}) ⇒ DataMapper
constructor
A new instance of DataMapper.
-
#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
#[], #[]=, #close, #decrement, #features, #fetch, included, #increment, #supports?
Methods included from OptionSupport
#expires, #prefix, #raw, #with
Constructor Details
#initialize(options = {}) ⇒ DataMapper
Returns a new instance of DataMapper.
24 25 26 27 28 29 30 |
# File 'lib/moneta/adapters/datamapper.rb', line 24 def initialize( = {}) raise ArgumentError, 'Option :setup is required' unless [:setup] @repository = (.delete(:repository) || :moneta).to_sym Store.storage_names[@repository] = (.delete(:table) || :moneta).to_s ::DataMapper.setup(@repository, [:setup]) context { Store.auto_upgrade! } end |
Instance Method Details
#clear(options = {}) ⇒ void
This method returns an undefined value.
Clear all keys in this store
84 85 86 87 |
# File 'lib/moneta/adapters/datamapper.rb', line 84 def clear( = {}) context { Store.all.destroy! } self end |
#create(key, value, options = {}) ⇒ Boolean
Not every Moneta store implements this method, a NotImplementedError is raised if it is not supported.
Atomically sets a key to value if it’s not set.
61 62 63 64 65 66 67 68 69 70 |
# File 'lib/moneta/adapters/datamapper.rb', line 61 def create(key, value, = {}) context do Store.create(k: key, v: value) true end rescue # 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
73 74 75 76 77 78 79 80 81 |
# File 'lib/moneta/adapters/datamapper.rb', line 73 def delete(key, = {}) context do if record = Store.get(key) value = record.v record.destroy! value end end end |
#key?(key, options = {}) ⇒ Boolean
Exists the value with key
33 34 35 |
# File 'lib/moneta/adapters/datamapper.rb', line 33 def key?(key, = {}) context { Store.get(key) != nil } end |
#load(key, options = {}) ⇒ Object
Fetch value with key. Return nil if the key doesn’t exist
38 39 40 41 42 43 |
# File 'lib/moneta/adapters/datamapper.rb', line 38 def load(key, = {}) context do record = Store.get(key) record && record.v end end |
#store(key, value, options = {}) ⇒ Object
Store value with key
46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/moneta/adapters/datamapper.rb', line 46 def store(key, value, = {}) context do if record = Store.get(key) record.update(k: key, v: value) else Store.create(k: key, v: value) end value end rescue tries ||= 0 (tries += 1) < 10 ? retry : raise end |