1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
# frozen-string-literal: true
module Sequel
module Plugins
# Base for other optimistic locking plugins
module OptimisticLockingBase
# Load the instance_filters plugin into the model.
def self.apply(model)
model.plugin :instance_filters
end
module ClassMethods
# The column holding the version of the lock
attr_accessor :lock_column
Plugins.inherited_instance_variables(self, :@lock_column=>nil)
end
module InstanceMethods
# Add the lock column instance filter to the object before destroying it.
def before_destroy
lock_column_instance_filter
super
end
# Add the lock column instance filter to the object before updating it.
def before_update
lock_column_instance_filter
super
end
private
# Add the lock column instance filter to the object.
def lock_column_instance_filter
instance_filter(model.lock_column=>lock_column_instance_filter_value)
end
# Use the current value of the lock column
def lock_column_instance_filter_value
public_send(model.lock_column)
end
# Clear the instance filters when refreshing, so that attempting to
# refresh after a failed save removes the previous lock column filter
# (the new one will be added before updating).
def _refresh(ds)
clear_instance_filters
super
end
end
end
end
end
|
