require 'bigdecimal'
module Arel
module Visitors
class ToSql
def initialize engine
@engine = engine
@connection = nil
end
def accept object
@connection = @engine.connection
visit object
end
private
def visit_Arel_Nodes_DeleteStatement o
[
"DELETE FROM #{visit o.relation}",
("WHERE #{o.wheres.map { |x| visit x }.join ' AND '}" unless o.wheres.empty?)
].compact.join ' '
end
def visit_Arel_Nodes_UpdateStatement o
[
"UPDATE #{visit o.relation}",
("SET #{o.values.map { |value| visit value }.join ', '}" unless o.values.empty?),
("WHERE #{o.wheres.map { |x| visit x }.join ' AND '}" unless o.wheres.empty?)
].compact.join ' '
end
def visit_Arel_Nodes_InsertStatement o
[
"INSERT INTO #{visit o.relation}",
("(#{o.columns.map { |x|
quote_column_name x.name
}.join ', '})" unless o.columns.empty?),
(visit o.values if o.values),
].compact.join ' '
end
def visit_Arel_Nodes_Exists o
"EXISTS (#{visit o.select_stmt})"
end
def visit_Arel_Nodes_Values o
"VALUES (#{o.expressions.zip(o.columns).map { |value, column|
quote(value, column && column.column)
}.join ', '})"
end
def visit_Arel_Nodes_SelectStatement o
[
o.cores.map { |x| visit x }.join,
("ORDER BY #{o.orders.map { |x| visit x }.join(', ')}" unless o.orders.empty?),
("LIMIT #{o.limit}" if o.limit),
(visit(o.offset) if o.offset),
(visit(o.lock) if o.lock),
].compact.join ' '
end
def visit_Arel_Nodes_SelectCore o
[
"SELECT #{o.projections.map { |x| visit x }.join ', '}",
("FROM #{visit o.froms}" if o.froms),
("WHERE #{o.wheres.map { |x| visit x }.join ' AND ' }" unless o.wheres.empty?),
("GROUP BY #{o.groups.map { |x| visit x }.join ', ' }" unless o.groups.empty?),
(visit(o.having) if o.having),
].compact.join ' '
end
def visit_Arel_Nodes_Having o
"HAVING #{visit o.expr}"
end
def visit_Arel_Nodes_Offset o
"OFFSET #{visit o.value}"
end
# FIXME: this does nothing on SQLLite3, but should do things on other
# databases.
def visit_Arel_Nodes_Lock o
end
def visit_Arel_Nodes_Grouping o
"(#{visit o.expr})"
end
def visit_Arel_Nodes_Group o
visit o.expr
end
def visit_Arel_Nodes_Count o
"COUNT(#{o.distinct ? 'DISTINCT ' : ''}#{o.expressions.map { |x|
visit x
}.join(', ')})#{o.alias ? " AS #{visit o.alias}" : ''}"
end
def visit_Arel_Nodes_Sum o
"SUM(#{o.expressions.map { |x|
visit x }.join(', ')})#{o.alias ? " AS #{visit o.alias}" : ''}"
end
def visit_Arel_Nodes_Max o
"MAX(#{o.expressions.map { |x|
visit x }.join(', ')})#{o.alias ? " AS #{visit o.alias}" : ''}"
end
def visit_Arel_Nodes_Min o
"MIN(#{o.expressions.map { |x|
visit x }.join(', ')})#{o.alias ? " AS #{visit o.alias}" : ''}"
end
def visit_Arel_Nodes_Avg o
"AVG(#{o.expressions.map { |x|
visit x }.join(', ')})#{o.alias ? " AS #{visit o.alias}" : ''}"
end
def visit_Arel_Nodes_TableAlias o
"#{visit o.relation} #{quote_table_name o.name}"
end
def visit_Arel_Nodes_GreaterThanOrEqual o
"#{visit o.left} >= #{visit o.right}"
end
def visit_Arel_Nodes_GreaterThan o
"#{visit o.left} > #{visit o.right}"
end
def visit_Arel_Nodes_StringJoin o
"#{visit o.left} #{visit o.right}"
end
def visit_Arel_Nodes_OuterJoin o
"#{visit o.left} LEFT OUTER JOIN #{visit o.right} #{visit o.constraint}"
end
def visit_Arel_Nodes_InnerJoin o
"#{visit o.left} INNER JOIN #{visit o.right} #{visit o.constraint if o.constraint}"
end
def visit_Arel_Nodes_On o
"ON #{visit o.expr}"
end
def visit_Arel_Table o
if o.table_alias
"#{quote_table_name o.name} #{quote_table_name o.table_alias}"
else
quote_table_name o.name
end
end
def visit_Arel_Nodes_In o
"#{visit o.left} IN (#{o.right.map { |x| visit x }.join ', '})"
end
def visit_Arel_Nodes_And o
"#{visit o.left} AND #{visit o.right}"
end
def visit_Arel_Nodes_Or o
"#{visit o.left} OR #{visit o.right}"
end
def visit_Arel_Nodes_Assignment o
right = o.right
right = right.nil? ? 'NULL' : visit(right)
"#{visit o.left} = #{right}"
end
def visit_Arel_Nodes_Equality o
right = o.right
if right.nil?
"#{visit o.left} IS NULL"
else
"#{visit o.left} = #{visit right}"
end
end
def visit_Arel_Nodes_NotEqual o
right = o.right
if right.nil?
"#{visit o.left} IS NOT NULL"
else
"#{visit o.left} != #{visit right}"
end
end
def visit_Arel_Nodes_UnqualifiedColumn o
"#{quote_column_name o.name}"
end
def visit_Arel_Attributes_Attribute o
join_name = o.relation.table_alias || o.relation.name
"#{quote_table_name join_name}.#{quote_column_name o.name}"
end
alias :visit_Arel_Attributes_Integer :visit_Arel_Attributes_Attribute
alias :visit_Arel_Attributes_String :visit_Arel_Attributes_Attribute
alias :visit_Arel_Attributes_Time :visit_Arel_Attributes_Attribute
alias :visit_Arel_Attributes_Boolean :visit_Arel_Attributes_Attribute
def visit_Fixnum o; o end
alias :visit_Arel_Nodes_SqlLiteral :visit_Fixnum
alias :visit_Arel_SqlLiteral :visit_Fixnum # This is deprecated
def visit_TrueClass o; quote(o) end
def visit_String o; quote(o) end
def visit_Hash o; quote(o) end
def visit_ActiveSupport_Multibyte_Chars o; quote(o) end
def visit_Symbol o; quote(o) end
def visit_Time o; quote(o) end
def visit_Date o; quote(o) end
def visit_DateTime o; quote(o) end
def visit_Float o; quote(o) end
def visit_BigDecimal o; quote(o) end
def visit_FalseClass o; quote(o) end
DISPATCH = Hash.new do |hash, klass|
hash[klass] = "visit_#{klass.name.gsub('::', '_')}"
end
def visit object
send DISPATCH[object.class], object
end
def quote value, column = nil
@connection.quote value, column
end
def quote_table_name name
@connection.quote_table_name name
end
def quote_column_name name
@connection.quote_column_name name
end
end
end
end