X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FSQL%2FAbstract.pm;h=0e41ffda162ba52f251159145ae59dd56f2ae866;hb=58ebc7fa5f9ccaabc1ce23d57ab642c6825bdebc;hp=143588393f19385f1666923098efbb15c26a5107;hpb=33ac0d7bd78b3b5cbe6e52520d80fd88e208215b;p=scpubgit%2FQ-Branch.git diff --git a/lib/SQL/Abstract.pm b/lib/SQL/Abstract.pm index 1435883..0e41ffd 100644 --- a/lib/SQL/Abstract.pm +++ b/lib/SQL/Abstract.pm @@ -208,6 +208,7 @@ sub new { (map +($_ => '_expand_op_is'), ('is', 'is_not')), ident => '_expand_ident', value => '_expand_value', + func => '_expand_func', }; $opt{expand_op} = { @@ -270,8 +271,7 @@ 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) ]; @@ -589,7 +589,10 @@ sub _expand_hashpair { if ($k =~ /^-/) { return $self->_expand_hashpair_op($k, $v); } elsif ($k =~ /^[^\w]/i) { - return $self->_expand_op(-op, [ $k, @$v ]); + my ($lhs, @rhs) = @$v; + return $self->_expand_op( + -op, [ $k, $self->expand_expr($lhs, -ident), @rhs ] + ); } return $self->_expand_hashpair_ident($k, $v); } @@ -721,29 +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, $self->_expand_expr($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 { @@ -847,6 +850,12 @@ sub _dwim_op_to_is { puke(sprintf $fail, $op); } +sub _expand_func { + my ($self, undef, $args) = @_; + my ($func, @args) = @$args; + return { -func => [ $func, map $self->expand_expr($_), @args ] }; +} + sub _expand_ident { my ($self, undef, $body, $k) = @_; return $self->_expand_hashpair_cmp( @@ -1073,6 +1082,9 @@ sub _render_row { sub _render_func { my ($self, $rest) = @_; my ($func, @args) = @$rest; + if (ref($func) eq 'HASH') { + $func = $self->render_aqt($func); + } my @arg_sql; my @bind = map { my @x = @$_;