X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FSQL%2FAbstract.pm;h=340a757b1bb78fdbaf0fc02951d0d168ec533a04;hb=a01911a20b326afd1a45f97f14aca68206708eba;hp=b06f0fa718efe55031aed5c4c7000ef63ab988e0;hpb=7741b7ad9d94e2c060763b13ad5ce93764af6163;p=scpubgit%2FQ-Branch.git diff --git a/lib/SQL/Abstract.pm b/lib/SQL/Abstract.pm index b06f0fa..340a757 100644 --- a/lib/SQL/Abstract.pm +++ b/lib/SQL/Abstract.pm @@ -271,14 +271,13 @@ sub insert { my @parts = ([ $self->_sqlcase('insert into').' '.$table ]); push @parts, [ $self->render_aqt($f_aqt) ] if $f_aqt; - push @parts, [ $self->render_aqt($v_aqt) ]; - $parts[-1][0] =~ s/^/VALUES /; + push @parts, [ $self->_sqlcase('values') ], [ $self->render_aqt($v_aqt) ]; if ($options->{returning}) { push @parts, [ $self->_insert_returning($options) ]; } - return $self->_join_parts(' ', @parts); + return $self->join_clauses(' ', @parts); } sub _expand_insert_values { @@ -531,7 +530,7 @@ sub render_aqt { die "No" if @rest; die "Not a node type: $k" unless $k =~ s/^-//; if (my $meth = $self->{render}{$k}) { - return $self->$meth($v); + return $self->$meth($k, $v); } die "notreached: $k"; } @@ -725,33 +724,29 @@ sub _expand_hashpair_op { return { $k => $v }; } - # hashref RHS values get expanded and used as op/func args + my $type = $self->{unknown_unop_always_func} ? -func : -op; - if ( - ref($v) eq 'HASH' - and keys %$v == 1 - and (keys %$v)[0] =~ /^-/ - ) { - my ($func) = $k =~ /^-(.*)$/; - { # Old SQLA compat - if (List::Util::first { $func =~ $_->{regex} } @{$self->{special_ops}}) { - return +{ -op => [ $func, $self->_expand_expr($v) ] }; - } - } - return +{ -func => [ - $func, - map $self->_expand_expr($_), - ref($v) eq 'ARRAY' ? @$v : $v - ] }; - } - - # scalars and literals get simply expanded + { # Old SQLA compat - if (!ref($v) or is_literal_value($v)) { - return +{ -op => [ $op, $self->_expand_expr($v) ] }; + if ( + ref($v) eq 'HASH' + and keys %$v == 1 + and (keys %$v)[0] =~ /^-/ + ) { + $type = ( + (List::Util::first { $op =~ $_->{regex} } @{$self->{special_ops}}) + ? -op + : -func + ) + } } - die "notreached"; + return +{ $type => [ + $op, + ($type eq -func and ref($v) eq 'ARRAY') + ? map $self->_expand_expr($_), @$v + : $self->_expand_expr($v) + ] }; } sub _expand_hashpair_cmp { @@ -1073,20 +1068,23 @@ sub _recurse_where { } sub _render_ident { - my ($self, $ident) = @_; + my ($self, undef, $ident) = @_; return $self->_convert($self->_quote($ident)); } sub _render_row { - my ($self, $values) = @_; - my ($sql, @bind) = $self->_render_op([ ',', @$values ]); + my ($self, undef, $values) = @_; + my ($sql, @bind) = $self->_render_op(undef, [ ',', @$values ]); return "($sql)", @bind; } sub _render_func { - my ($self, $rest) = @_; + my ($self, undef, $rest) = @_; my ($func, @args) = @$rest; + if (ref($func) eq 'HASH') { + $func = $self->render_aqt($func); + } my @arg_sql; my @bind = map { my @x = @$_; @@ -1097,18 +1095,18 @@ sub _render_func { } sub _render_bind { - my ($self, $bind) = @_; + my ($self, undef, $bind) = @_; return ($self->_convert('?'), $self->_bindtype(@$bind)); } sub _render_literal { - my ($self, $literal) = @_; + my ($self, undef, $literal) = @_; $self->_assert_bindval_matches_bindtype(@{$literal}[1..$#$literal]); return @$literal; } sub _render_op { - my ($self, $v) = @_; + my ($self, undef, $v) = @_; my ($op, @args) = @$v; if (my $r = $self->{render_op}{$op}) { return $self->$r($op, \@args); @@ -1190,7 +1188,7 @@ sub _render_op_andor { my @parts = grep length($_->[0]), map [ $self->render_aqt($_) ], @$args; return '' unless @parts; return @{$parts[0]} if @parts == 1; - my ($sql, @bind) = $self->_join_parts(' '.$self->_sqlcase($op).' ', @parts); + my ($sql, @bind) = $self->join_clauses(' '.$self->_sqlcase($op).' ', @parts); return '( '.$sql.' )', @bind; } @@ -1203,10 +1201,10 @@ sub _render_op_multop { ? ', ' : ' '.$self->_sqlcase(join ' ', split '_', $op).' ' ); - return $self->_join_parts($join, @parts); + return $self->join_clauses($join, @parts); } -sub _join_parts { +sub join_clauses { my ($self, $join, @parts) = @_; return ( join($join, map $_->[0], @parts),