X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FSQL%2FAbstract%2FClauses.pm;h=eea7cc1251c2876b03afe794e2ee2684398e12d2;hb=46158aa8ac5c03e77083a3b541ae30b019b6b6f8;hp=95334142837c44745df27b49f0e7a57a468844d0;hpb=ccb7f3d64b727ea610654d7eeaf3d8758446ec1a;p=scpubgit%2FQ-Branch.git diff --git a/lib/SQL/Abstract/Clauses.pm b/lib/SQL/Abstract/Clauses.pm index 9533414..eea7cc1 100644 --- a/lib/SQL/Abstract/Clauses.pm +++ b/lib/SQL/Abstract/Clauses.pm @@ -19,24 +19,35 @@ sub register_defaults { $self->{render}{select} = sub { shift->_render_statement(select => @_) }; $self->{expand_clause}{"select.$_"} = "_expand_select_clause_$_" for @{$self->{clauses_of}{select}}; - $self->{clauses_of}{update} = [ qw(update set where returning) ]; + $self->{clauses_of}{update} = [ qw(target set where returning) ]; $self->{expand}{update} = sub { shift->_expand_statement(@_) }; $self->{render}{update} = sub { shift->_render_statement(update => @_) }; $self->{expand_clause}{"update.$_"} = "_expand_update_clause_$_" for @{$self->{clauses_of}{update}}; - $self->{clauses_of}{delete} = [ qw(delete_from where returning) ]; + $self->{expand_clause}{'update.update'} = '_expand_update_clause_target'; + $self->{render_clause}{'update.target'} = sub { + my ($self, $target) = @_; + my ($sql, @bind) = $self->render_aqt($target); + ($self->_sqlcase('update ').$sql, @bind); + }; + $self->{clauses_of}{delete} = [ qw(target where returning) ]; $self->{expand}{delete} = sub { shift->_expand_statement(@_) }; $self->{render}{delete} = sub { shift->_render_statement(delete => @_) }; $self->{expand_clause}{"delete.$_"} = "_expand_delete_clause_$_" for @{$self->{clauses_of}{delete}}; + $self->{expand_clause}{"delete.from"} = '_expand_delete_clause_target'; + $self->{render_clause}{'delete.target'} = sub { + my ($self, $from) = @_; + my ($sql, @bind) = $self->render_aqt($from); + ($self->_sqlcase('delete from ').$sql, @bind); + }; $self->{clauses_of}{insert} = [ - 'insert_into', 'fields', 'values', 'returning' + 'target', 'fields', 'values', 'returning' ]; $self->{expand}{insert} = sub { shift->_expand_statement(@_) }; $self->{render}{insert} = sub { shift->_render_statement(insert => @_) }; - $self->{expand_clause}{'insert.insert_into'} = sub { - shift->expand_expr(@_, -ident); - }; + $self->{expand_clause}{'insert.into'} = '_expand_insert_clause_target'; + $self->{expand_clause}{'insert.target'} = '_expand_insert_clause_target'; $self->{expand_clause}{'insert.values'} = '_expand_insert_clause_values'; $self->{expand_clause}{'insert.returning'} = sub { shift->_expand_maybe_list_expr(@_, -ident); @@ -44,6 +55,11 @@ sub register_defaults { $self->{render_clause}{'insert.fields'} = sub { return $_[0]->render_aqt($_[1]); }; + $self->{render_clause}{'insert.target'} = sub { + my ($self, $from) = @_; + my ($sql, @bind) = $self->render_aqt($from); + ($self->_sqlcase('insert into ').$sql, @bind); + }; return $self; } @@ -67,9 +83,9 @@ sub _expand_select_clause_order_by { +(order_by => $self->_expand_order_by($order_by)); } -sub _expand_update_clause_update { +sub _expand_update_clause_target { my ($self, $target) = @_; - +(update => $self->expand_expr($target, -ident)); + +(target => $self->expand_expr($target, -ident)); } sub _expand_update_clause_set { @@ -85,8 +101,8 @@ sub _expand_update_clause_returning { +(returning => shift->_expand_maybe_list_expr(@_, -ident)); } -sub _expand_delete_clause_delete_from { - +(delete_from => shift->_expand_maybe_list_expr(@_, -ident)); +sub _expand_delete_clause_target { + +(target => shift->_expand_maybe_list_expr(@_, -ident)); } sub _expand_delete_clause_where { +(where => shift->expand_expr(@_)); } @@ -155,7 +171,7 @@ sub select { sub update { my ($self, $table, $set, $where, $options) = @_; my %clauses; - @clauses{qw(update set where)} = ($table, $set, $where); + @clauses{qw(target set where)} = ($table, $set, $where); puke "Unsupported data type specified to \$sql->update" unless ref($clauses{set}) eq 'HASH'; @clauses{keys %$options} = values %$options; @@ -165,18 +181,22 @@ sub update { sub delete { my ($self, $table, $where, $options) = @_; - my %clauses = (delete_from => $table, where => $where, %{$options||{}}); + my %clauses = (target => $table, where => $where, %{$options||{}}); my ($sql, @bind) = $self->render_expr({ -delete => \%clauses }); return wantarray ? ($sql, @bind) : $sql; } sub insert { my ($self, $table, $data, $options) = @_; - my %clauses = (insert_into => $table, values => $data, %{$options||{}}); + my %clauses = (target => $table, values => $data, %{$options||{}}); my ($sql, @bind) = $self->render_expr({ -insert => \%clauses }); return wantarray ? ($sql, @bind) : $sql; } +sub _expand_insert_clause_target { + +(target => shift->_expand_maybe_list_expr(@_, -ident)); +} + sub _expand_insert_clause_values { my ($self, $data) = @_; return $data if ref($data) eq 'HASH' and $data->{-row};