Module: ActiveRecord::ConnectionAdapters::PostgreSQL::Quoting

Included in:
ActiveRecord::ConnectionAdapters::PostgreSQLAdapter
Defined in:
lib/active_record/connection_adapters/postgresql/quoting.rb

Defined Under Namespace

Classes: IntegerOutOf64BitRange

Instance Method Summary collapse

Instance Method Details

#column_name_matcher ⇒ Object 



87
88
89
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 87

def column_name_matcher
  COLUMN_NAME
end

#column_name_with_order_matcher ⇒ Object 



91
92
93
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 91

def column_name_with_order_matcher
  COLUMN_NAME_WITH_ORDER
end

#escape_bytea(value) ⇒ Object

Escapes binary strings for bytea input to the database.



14
15
16
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 14

def escape_bytea(value)
  @connection.escape_bytea(value) if value
end

#lookup_cast_type_from_column(column) ⇒ Object

:nodoc:



83
84
85
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 83

def lookup_cast_type_from_column(column) # :nodoc:
  type_map.lookup(column.oid, column.fmod, column.sql_type)
end

#quote_column_name(name) ⇒ Object

Quotes column names for use in SQL queries.



52
53
54
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 52

def quote_column_name(name) # :nodoc:
  self.class.quoted_column_names[name] ||= PG::Connection.quote_ident(super).freeze
end

#quote_default_expression(value, column) ⇒ Object

:nodoc:



70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 70

def quote_default_expression(value, column) # :nodoc:
  if value.is_a?(Proc)
    value.call
  elsif column.type == :uuid && value.is_a?(String) && /\(\)/.match?(value)
    value # Does not quote function default values for UUID columns
  elsif column.respond_to?(:array?)
    type = lookup_cast_type_from_column(column)
    quote(type.serialize(value))
  else
    super
  end
end

#quote_schema_name(name) ⇒ Object

Quotes schema names for use in SQL queries.



43
44
45
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 43

def quote_schema_name(name)
  PG::Connection.quote_ident(name)
end

#quote_string(s) ⇒ Object

Quotes strings for use in SQL input.



26
27
28
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 26

def quote_string(s) #:nodoc:
  PG::Connection.escape(s)
end

#quote_table_name(name) ⇒ Object

Checks the following cases:

  • table_name

  • “table.name”

  • schema_name.table_name

  • schema_name.“table.name”

  • “schema.name”.table_name

  • “schema.name”.“table.name”



38
39
40
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 38

def quote_table_name(name) # :nodoc:
  self.class.quoted_table_names[name] ||= Utils.extract_schema_qualified_name(name.to_s).quoted.freeze
end

#quote_table_name_for_assignment(table, attr) ⇒ Object 



47
48
49
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 47

def quote_table_name_for_assignment(table, attr)
  quote_column_name(attr)
end

#quoted_binary(value) ⇒ Object

:nodoc:



66
67
68
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 66

def quoted_binary(value) # :nodoc:
  "'#{escape_bytea(value.to_s)}'"
end

#quoted_date(value) ⇒ Object

Quote date/time values for use in SQL input.



57
58
59
60
61
62
63
64
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 57

def quoted_date(value) #:nodoc:
  if value.year <= 0
    bce_year = format("%04d", -value.year + 1)
    super.sub(/^-?\d+/, bce_year) + " BC"
  else
    super
  end
end

#unescape_bytea(value) ⇒ Object

Unescapes bytea output from a database to the binary string it represents. NOTE: This is NOT an inverse of escape_bytea! This is only to be used on escaped binary output from database drive.



21
22
23
 
# File 'lib/active_record/connection_adapters/postgresql/quoting.rb', line 21

def unescape_bytea(value)
  @connection.unescape_bytea(value) if value
end