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 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276
|
# frozen-string-literal: true
module Sequel
module Plugins
# The dirty plugin makes Sequel save the initial value of
# a column when setting a new value for the column. This
# makes it easier to see what changes were made to the object:
#
# artist.name # => 'Foo'
# artist.name = 'Bar'
# artist.initial_value(:name) # 'Foo'
# artist.column_change(:name) # ['Foo', 'Bar']
# artist.column_changes # {:name => ['Foo', 'Bar']}
# artist.column_changed?(:name) # true
# artist.reset_column(:name)
# artist.name # => 'Foo'
# artist.column_changed?(:name) # false
#
# It also makes changed_columns more accurate in that it
# can detect when a the column value is changed and then
# changed back:
#
# artist.name # => 'Foo'
# artist.name = 'Bar'
# artist.changed_columns # => [:name]
# artist.name = 'Foo'
# artist.changed_columns # => []
#
# It can handle situations where a column value is
# modified in place:
#
# artist.will_change_column(:name)
# artist.name.gsub!(/o/, 'u')
# artist.changed_columns # => [:name]
# artist.initial_value(:name) # => 'Foo'
# artist.column_change(:name) # => ['Foo', 'Fuu']
#
# It also saves the previously changed values after an update:
#
# artist.update(name: 'Bar')
# artist.column_changes # => {}
# artist.previous_changes # => {:name=>['Foo', 'Bar']}
#
# artist.column_previously_was(:name)
# # => 'Foo'
# artist.column_previously_changed?(:name)
# # => true
# artist.column_previously_changed?(:name, from: 'Foo', to: 'Bar')
# # => true
# artist.column_previously_changed?(:name, from: 'Foo', to: 'Baz')
# # => false
#
# There is one caveat; when used with a column that also uses the
# serialization plugin, setting the column back to its original value
# after changing it is not correctly detected and will leave an entry
# in changed_columns.
#
# Usage:
#
# # Make all model subclass instances record previous values (called before loading subclasses)
# Sequel::Model.plugin :dirty
#
# # Make the Album class record previous values
# Album.plugin :dirty
module Dirty
module InstanceMethods
# A hash of previous changes before the object was
# saved, in the same format as #column_changes.
# Note that this is not necessarily the same as the columns
# that were used in the update statement.
attr_reader :previous_changes
# Reset the initial values after saving.
def after_save
super
reset_initial_values
end
# Save the current changes so they are available after updating. This happens
# before after_save resets them.
def after_update
super
@previous_changes = column_changes
end
# An array with the initial value and the current value
# of the column, if the column has been changed. If the
# column has not been changed, returns nil.
#
# column_change(:name) # => ['Initial', 'Current']
def column_change(column)
[initial_value(column), get_column_value(column)] if column_changed?(column)
end
# A hash with column symbol keys and pairs of initial and
# current values for all changed columns.
#
# column_changes # => {:name => ['Initial', 'Current']}
def column_changes
h = {}
initial_values.each do |column, value|
h[column] = [value, get_column_value(column)]
end
h
end
# Either true or false depending on whether the column has
# changed. Note that this is not exactly the same as checking if
# the column is in changed_columns, if the column was not set
# initially.
#
# column_changed?(:name) # => true
def column_changed?(column)
initial_values.has_key?(column)
end
# Whether the column was previously changed.
# Options:
# :from :: If given, the previous initial value of the column must match this
# :to :: If given, the previous changed value of the column must match this
#
# update(name: 'Current')
# previous_changes # => {:name=>['Initial', 'Current']}
# column_previously_changed?(:name) # => true
# column_previously_changed?(:id) # => false
# column_previously_changed?(:name, from: 'Initial', to: 'Current') # => true
# column_previously_changed?(:name, from: 'Foo', to: 'Current') # => false
def column_previously_changed?(column, opts=OPTS)
return false unless (pc = @previous_changes) && (val = pc[column])
if opts.has_key?(:from)
return false unless val[0] == opts[:from]
end
if opts.has_key?(:to)
return false unless val[1] == opts[:to]
end
true
end
# The previous value of the column, which is the initial value of
# the column before the object was previously saved.
#
# initial_value(:name) # => 'Initial'
# update(name: 'Current')
# column_previously_was(:name) # => 'Initial'
def column_previously_was(column)
(pc = @previous_changes) && (val = pc[column]) && val[0]
end
# Freeze internal data structures
def freeze
initial_values.freeze
missing_initial_values.freeze
@previous_changes.freeze if @previous_changes
super
end
# The initial value of the given column. If the column value has
# not changed, this will be the same as the current value of the
# column.
#
# initial_value(:name) # => 'Initial'
def initial_value(column)
initial_values.fetch(column){get_column_value(column)}
end
# A hash with column symbol keys and initial values.
#
# initial_values # {:name => 'Initial'}
def initial_values
@initial_values ||= {}
end
# Reset the column to its initial value. If the column was not set
# initial, removes it from the values.
#
# reset_column(:name)
# name # => 'Initial'
def reset_column(column)
if initial_values.has_key?(column)
set_column_value(:"#{column}=", initial_values[column])
end
if missing_initial_values.include?(column)
values.delete(column)
end
end
# Manually specify that a column will change. This should only be used
# if you plan to modify a column value in place, which is not recommended.
#
# will_change_column(:name)
# name.gsub(/i/i, 'o')
# column_change(:name) # => ['Initial', 'onotoal']
def will_change_column(column)
_add_changed_column(column)
check_missing_initial_value(column)
value = if initial_values.has_key?(column)
initial_values[column]
else
get_column_value(column)
end
initial_values[column] = if value && value != true && value.respond_to?(:clone)
begin
value.clone
rescue TypeError
value
end
else
value
end
end
private
# Reset initial values when clearing changed columns
def _clear_changed_columns(reason)
reset_initial_values if reason == :initialize || reason == :refresh
super
end
# When changing the column value, save the initial column value. If the column
# value is changed back to the initial value, update changed columns to remove
# the column.
def change_column_value(column, value)
if (iv = initial_values).has_key?(column)
initial = iv[column]
super
if value == initial
_changed_columns.delete(column) unless missing_initial_values.include?(column)
iv.delete(column)
end
else
check_missing_initial_value(column)
iv[column] = get_column_value(column)
super
end
end
# If the values hash does not contain the column, make sure missing_initial_values
# does so that it doesn't get deleted from changed_columns if changed back,
# and so that resetting the column value can be handled correctly.
def check_missing_initial_value(column)
unless values.has_key?(column) || (miv = missing_initial_values).include?(column)
miv << column
end
end
# Duplicate internal data structures
def initialize_copy(other)
super
@initial_values = Hash[other.initial_values]
@missing_initial_values = other.send(:missing_initial_values).dup
@previous_changes = Hash[other.previous_changes] if other.previous_changes
self
end
# Array holding column symbols that were not present initially. This is necessary
# to differentiate between values that were not present and values that were
# present but equal to nil.
def missing_initial_values
@missing_initial_values ||= []
end
# Clear the data structures that store the initial values.
def reset_initial_values
@initial_values.clear if @initial_values
@missing_initial_values.clear if @missing_initial_values
end
end
end
end
end
|