/
hstore.rb
109 lines (88 loc) · 2.99 KB
/
hstore.rb
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
# frozen_string_literal: true
require "strscan"
module ActiveRecord
module ConnectionAdapters
module PostgreSQL
module OID # :nodoc:
class Hstore < Type::Value # :nodoc:
ERROR = "Invalid Hstore document: %s"
include ActiveModel::Type::Helpers::Mutable
def type
:hstore
end
def deserialize(value)
return value unless value.is_a?(::String)
scanner = StringScanner.new(value)
hash = {}
until scanner.eos?
unless scanner.skip(/"/)
raise(ArgumentError, ERROR % scanner.string.inspect)
end
unless key = scanner.scan(/^(\\[\\"]|[^\\"])*?(?=")/)
raise(ArgumentError, ERROR % scanner.string.inspect)
end
unless scanner.skip(/"=>?/)
raise(ArgumentError, ERROR % scanner.string.inspect)
end
if scanner.scan(/NULL/)
value = nil
else
unless scanner.skip(/"/)
raise(ArgumentError, ERROR % scanner.string.inspect)
end
unless value = scanner.scan(/^(\\[\\"]|[^\\"])*?(?=")/)
raise(ArgumentError, ERROR % scanner.string.inspect)
end
unless scanner.skip(/"/)
raise(ArgumentError, ERROR % scanner.string.inspect)
end
end
key.gsub!('\"', '"')
key.gsub!("\\\\", "\\")
if value
value.gsub!('\"', '"')
value.gsub!("\\\\", "\\")
end
hash[key] = value
unless scanner.skip(/, /) || scanner.eos?
raise(ArgumentError, ERROR % scanner.string.inspect)
end
end
hash
end
def serialize(value)
if value.is_a?(::Hash)
value.map { |k, v| "#{escape_hstore(k)}=>#{escape_hstore(v)}" }.join(", ")
elsif value.respond_to?(:to_unsafe_h)
serialize(value.to_unsafe_h)
else
value
end
end
def accessor
ActiveRecord::Store::StringKeyedHashAccessor
end
# Will compare the Hash equivalents of +raw_old_value+ and +new_value+.
# By comparing hashes, this avoids an edge case where the order of
# the keys change between the two hashes, and they would not be marked
# as equal.
def changed_in_place?(raw_old_value, new_value)
deserialize(raw_old_value) != new_value
end
private
def escape_hstore(value)
if value.nil?
"NULL"
else
if value == ""
'""'
else
'"%s"' % value.to_s.gsub(/(["\\])/, '\\\\\1')
end
end
end
end
end
end
end
end