package SQL::Abstract; # see doc at end of file
-# LDNOTE : this code is heavy refactoring from original SQLA.
-# Several design decisions will need discussion during
-# the test / diffusion / acceptance phase; those are marked with flag
-# 'LDNOTE' (note by laurent.dami AT free.fr)
+use SQL::Abstract::_TempExtlib;
use Carp ();
use List::Util ();
use Scalar::Util ();
-use Data::Query::Constants qw(
- DQ_IDENTIFIER DQ_OPERATOR DQ_VALUE DQ_LITERAL DQ_JOIN DQ_SELECT DQ_ORDER
- DQ_WHERE DQ_DELETE DQ_UPDATE DQ_INSERT
-);
-use Data::Query::ExprHelpers qw(perl_scalar_value);
+use Module::Runtime qw(use_module);
+use Sub::Quote 'quote_sub';
use Moo;
+use namespace::clean;
-#======================================================================
-# GLOBALS
-#======================================================================
-
-our $VERSION = '1.72';
+# DO NOT INCREMENT TO 2.0 WITHOUT COORDINATING WITH mst OR ribasushi
+ our $VERSION = '1.99_01';
+# DO NOT INCREMENT TO 2.0 WITHOUT COORDINATING WITH mst OR ribasushi
# This would confuse some packagers
$VERSION = eval $VERSION if $VERSION =~ /_/; # numify for warning-free dev releases
-our $AUTOLOAD;
-
-#======================================================================
-# DEBUGGING AND ERROR REPORTING
-#======================================================================
-
-sub _debug {
- return unless $_[0]->{debug}; shift; # a little faster
- my $func = (caller(1))[3];
- warn "[$func] ", @_, "\n";
-}
-
sub belch (@) {
my($func) = (caller(1))[3];
Carp::carp "[$func] Warning: ", @_;
Carp::croak "[$func] Fatal: ", @_;
}
-
-#======================================================================
-# NEW
-#======================================================================
+has converter => (is => 'lazy', clearer => 1);
has case => (
- is => 'ro', coerce => sub { $_[0] eq 'lower' ? 'lower' : undef }
+ is => 'ro', coerce => quote_sub( q{ $_[0] eq 'lower' ? 'lower' : undef } ),
);
has logic => (
- is => 'ro', coerce => sub { uc($_[0]) }, default => sub { 'OR' }
+ is => 'ro', coerce => quote_sub( q{ uc($_[0]) } ), default => 'OR',
);
has bindtype => (
- is => 'ro', default => sub { 'normal' }
-);
-
-has cmp => (is => 'ro', default => sub { '=' });
-
-
- # try to recognize which are the 'equality' and 'unequality' ops
- # (temporary quickfix, should go through a more seasoned API)
-
-has equality_op => (
- is => 'ro', lazy => 1,
- default => sub { qr/^(\Q${\$_[0]->cmp}\E|is|(is\s+)?like)$/i }
-);
-
-has inequality_op => (
- is => 'ro',
- default => sub { qr/^(!=|<>|(is\s+)?not(\s+like)?)$/i }
+ is => 'ro', default => 'normal'
);
- # SQL booleans
-has sqltrue => (is => 'ro', default => sub { '1=1' });
-has sqlfalse => (is => 'ro', default => sub { '0=1' });
+has cmp => (is => 'ro', default => '=');
-has special_ops => (is => 'ro', default => sub { [] });
-has unary_ops => (is => 'ro', default => sub { [] });
+has sqltrue => (is => 'ro', default => '1=1' );
+has sqlfalse => (is => 'ro', default => '0=1' );
- # rudimentary saniy-check for user supplied bits treated as functions/operators
- # If a purported function matches this regular expression, an exception is thrown.
- # Literal SQL is *NOT* subject to this check, only functions (and column names
- # when quoting is not in effect)
+has special_ops => (is => 'ro', default => quote_sub( q{ [] } ));
+has unary_ops => (is => 'ro', default => quote_sub( q{ [] } ));
- # FIXME
- # need to guard against ()'s in column names too, but this will break tons of
- # hacks... ideas anyone?
+# FIXME
+# need to guard against ()'s in column names too, but this will break tons of
+# hacks... ideas anyone?
has injection_guard => (
is => 'ro',
- default => sub {
+ default => quote_sub( q{
qr/
\;
|
^ \s* go \s
/xmi;
- }
+ })
);
-has renderer => (is => 'lazy', clearer => 'clear_renderer');
+has renderer => (is => 'lazy', clearer => 1);
has name_sep => (
- is => 'rw', default => sub { '.' },
- trigger => sub { shift->clear_renderer },
+ is => 'rw', default => '.',
+ trigger => quote_sub( q{
+ $_[0]->clear_renderer;
+ $_[0]->clear_converter;
+ }),
);
has quote_char => (
is => 'rw',
- trigger => sub { shift->clear_renderer },
+ trigger => quote_sub( q{
+ $_[0]->clear_renderer;
+ $_[0]->clear_converter;
+ }),
+);
+
+has collapse_aliases => (
+ is => 'ro',
+ default => 0,
);
-has always_quote => (is => 'ro', default => sub { 1 });
+has always_quote => (
+ is => 'rw', default => 1,
+ trigger => quote_sub( q{
+ $_[0]->clear_renderer;
+ $_[0]->clear_converter;
+ }),
+);
has convert => (is => 'ro');
has array_datatypes => (is => 'ro');
-sub _build_renderer {
+has converter_class => (
+ is => 'rw', lazy => 1, builder => 1,
+ trigger => quote_sub( q{ $_[0]->clear_converter } ),
+);
+
+sub _build_converter_class {
+ use_module('SQL::Abstract::Converter')
+}
+
+has renderer_class => (
+ is => 'rw', lazy => 1, clearer => 1, builder => 1,
+ trigger => quote_sub( q{ $_[0]->clear_renderer } ),
+);
+
+after clear_renderer_class => sub { $_[0]->clear_renderer };
+
+sub _build_renderer_class {
+ my ($self) = @_;
+ my ($class, @roles) = (
+ $self->_build_base_renderer_class, $self->_build_renderer_roles
+ );
+ return $class unless @roles;
+ return use_module('Moo::Role')->create_class_with_roles($class, @roles);
+}
+
+sub _build_base_renderer_class {
+ use_module('Data::Query::Renderer::SQL::Naive')
+}
+
+sub _build_renderer_roles { () }
+
+sub _converter_args {
+ my ($self) = @_;
+ Scalar::Util::weaken($self);
+ +{
+ lower_case => $self->case,
+ default_logic => $self->logic,
+ bind_meta => not($self->bindtype eq 'normal'),
+ identifier_sep => $self->name_sep,
+ (map +($_ => $self->$_), qw(
+ cmp sqltrue sqlfalse injection_guard convert array_datatypes
+ )),
+ special_ops => [
+ map {
+ my $sub = $_->{handler};
+ +{
+ %$_,
+ handler => sub { $self->$sub(@_) }
+ }
+ } @{$self->special_ops}
+ ],
+ renderer_will_quote => (
+ defined($self->quote_char) and $self->always_quote
+ ),
+ }
+}
+
+sub _build_converter {
+ my ($self) = @_;
+ $self->converter_class->new($self->_converter_args);
+}
+
+sub _renderer_args {
my ($self) = @_;
- require Data::Query::Renderer::SQL::Naive;
my ($chars);
for ($self->quote_char) {
$chars = defined() ? (ref() ? $_ : [$_]) : ['',''];
}
- Data::Query::Renderer::SQL::Naive->new({
+ +{
quote_chars => $chars, always_quote => $self->always_quote,
identifier_sep => $self->name_sep,
+ collapse_aliases => $self->collapse_aliases,
($self->case ? (lc_keywords => 1) : ()), # always 'lower' if it exists
- });
+ };
+}
+
+sub _build_renderer {
+ my ($self) = @_;
+ $self->renderer_class->new($self->_renderer_args);
}
sub _render_dq {
sub _render_sqla {
my ($self, $type, @args) = @_;
- $self->_render_dq($self->${\"_${type}_to_dq"}(@args));
+ $self->_render_dq($self->converter->${\"_${type}_to_dq"}(@args));
}
-sub _literal_to_dq {
- my ($self, $literal) = @_;
- my @bind;
- ($literal, @bind) = @$literal if ref($literal) eq 'ARRAY';
- +{
- type => DQ_LITERAL,
- subtype => 'SQL',
- literal => $literal,
- (@bind ? (values => [ $self->_bind_to_dq(@bind) ]) : ()),
- };
-}
-
-sub _bind_to_dq {
- my ($self, @bind) = @_;
- return unless @bind;
- $self->{bindtype} eq 'normal'
- ? map perl_scalar_value($_), @bind
- : do {
- $self->_assert_bindval_matches_bindtype(@bind);
- map perl_scalar_value(reverse @$_), @bind
- }
-}
-
-sub _value_to_dq {
- my ($self, $value) = @_;
- $self->_maybe_convert_dq(perl_scalar_value($value, our $Cur_Col_Meta));
-}
-
-sub _ident_to_dq {
- my ($self, $ident) = @_;
- $self->_assert_pass_injection_guard($ident)
- unless $self->renderer->quote_chars->[0] && $self->renderer->always_quote;
- $self->_maybe_convert_dq({
- type => DQ_IDENTIFIER,
- elements => [ split /\Q${\$self->renderer->identifier_sep}/, $ident ],
- });
-}
-
-sub _maybe_convert_dq {
- my ($self, $dq) = @_;
- if (my $c = $self->{where_convert}) {
- +{
- type => DQ_OPERATOR,
- operator => { 'SQL.Naive' => 'apply' },
- args => [
- { type => DQ_IDENTIFIER, elements => [ $self->_sqlcase($c) ] },
- $dq
- ]
- };
- } else {
- $dq;
- }
-}
-
-sub _op_to_dq {
- my ($self, $op, @args) = @_;
- $self->_assert_pass_injection_guard($op);
- +{
- type => DQ_OPERATOR,
- operator => { 'SQL.Naive' => $op },
- args => \@args
- };
-}
-
-sub _assert_pass_injection_guard {
- if ($_[1] =~ $_[0]->{injection_guard}) {
- my $class = ref $_[0];
- puke "Possible SQL injection attempt '$_[1]'. If this is indeed a part of the "
- . "desired SQL use literal SQL ( \'...' or \[ '...' ] ) or supply your own "
- . "{injection_guard} attribute to ${class}->new()"
- }
-}
-
-
-#======================================================================
-# INSERT methods
-#======================================================================
-
sub insert { shift->_render_sqla(insert => @_) }
-sub _insert_to_dq {
- my ($self, $table, $data, $options) = @_;
- my (@names, @values);
- if (ref($data) eq 'HASH') {
- @names = sort keys %$data;
- foreach my $k (@names) {
- local our $Cur_Col_Meta = $k;
- push @values, $self->_mutation_rhs_to_dq($data->{$k});
- }
- } elsif (ref($data) eq 'ARRAY') {
- local our $Cur_Col_Meta;
- @values = map $self->_mutation_rhs_to_dq($_), @$data;
- } else {
- die "Not handled yet";
- }
- my $returning;
- if (my $r_source = $options->{returning}) {
- $returning = [
- map +(ref($_) ? $self->_expr_to_dq($_) : $self->_ident_to_dq($_)),
- (ref($r_source) eq 'ARRAY' ? @$r_source : $r_source),
- ];
- }
- +{
- type => DQ_INSERT,
- target => $self->_table_to_dq($table),
- (@names ? (names => [ map $self->_ident_to_dq($_), @names ]) : ()),
- values => [ \@values ],
- ($returning ? (returning => $returning) : ()),
- };
-}
-
-sub _mutation_rhs_to_dq {
- my ($self, $v) = @_;
- if (ref($v) eq 'ARRAY') {
- if ($self->{array_datatypes}) {
- return $self->_value_to_dq($v);
- }
- $v = \do { my $x = $v };
- }
- if (ref($v) eq 'HASH') {
- my ($op, $arg, @rest) = %$v;
-
- puke 'Operator calls in update/insert must be in the form { -op => $arg }'
- if (@rest or not $op =~ /^\-(.+)/);
- }
- return $self->_expr_to_dq($v);
-}
-
-#======================================================================
-# UPDATE methods
-#======================================================================
-
-
sub update { shift->_render_sqla(update => @_) }
-sub _update_to_dq {
- my ($self, $table, $data, $where) = @_;
-
- puke "Unsupported data type specified to \$sql->update"
- unless ref $data eq 'HASH';
-
- my @set;
-
- foreach my $k (sort keys %$data) {
- my $v = $data->{$k};
- local our $Cur_Col_Meta = $k;
- push @set, [ $self->_ident_to_dq($k), $self->_mutation_rhs_to_dq($v) ];
- }
-
- return +{
- type => DQ_UPDATE,
- target => $self->_table_to_dq($table),
- set => \@set,
- where => $self->_where_to_dq($where),
- };
-}
-
-
-#======================================================================
-# SELECT
-#======================================================================
-
-sub _source_to_dq {
- my ($self, $table, $where) = @_;
-
- my $source_dq = $self->_table_to_dq($table);
-
- if (my $where_dq = $self->_where_to_dq($where)) {
- $source_dq = {
- type => DQ_WHERE,
- from => $source_dq,
- where => $where_dq,
- };
- }
-
- $source_dq;
-}
-
sub select { shift->_render_sqla(select => @_) }
-sub _select_to_dq {
- my ($self, $table, $fields, $where, $order) = @_;
-
- my $final_dq = $self->_select_body_to_dq($table, $fields, $where);
-
- if ($order) {
- $final_dq = $self->_order_by_to_dq($order, undef, $final_dq);
- }
-
- return $final_dq;
-}
-
-sub _select_body_to_dq {
- my ($self, $table, $fields, $where) = @_;
-
- $fields ||= '*';
-
- my $source_dq = $self->_source_to_dq($table, $where);
-
- return +{
- type => DQ_SELECT,
- select => [
- map $self->_select_field_to_dq($_),
- ref($fields) eq 'ARRAY' ? @$fields : $fields
- ],
- from => $source_dq,
- };
-}
-
-sub _select_field_to_dq {
- my ($self, $field) = @_;
- ref($field)
- ? $self->_literal_to_dq($$field)
- : $self->_ident_to_dq($field)
-}
-
-#======================================================================
-# DELETE
-#======================================================================
-
-
sub delete { shift->_render_sqla(delete => @_) }
-sub _delete_to_dq {
- my ($self, $table, $where) = @_;
- +{
- type => DQ_DELETE,
- target => $self->_table_to_dq($table),
- where => $self->_where_to_dq($where),
- }
-}
-
-
-#======================================================================
-# WHERE: entry point
-#======================================================================
-
-
-
-# Finally, a separate routine just to handle WHERE clauses
sub where {
my ($self, $where, $order) = @_;
sub _recurse_where { shift->_render_sqla(where => @_) }
-sub _where_to_dq {
- my ($self, $where, $logic) = @_;
-
- return undef unless defined($where);
-
- # turn the convert misfeature on - only used in WHERE clauses
- local $self->{where_convert} = $self->{convert};
-
- return $self->_expr_to_dq($where, $logic);
-}
-
-sub _expr_to_dq {
- my ($self, $where, $logic) = @_;
-
- if (ref($where) eq 'ARRAY') {
- return $self->_expr_to_dq_ARRAYREF($where, $logic);
- } elsif (ref($where) eq 'HASH') {
- return $self->_expr_to_dq_HASHREF($where, $logic);
- } elsif (
- ref($where) eq 'SCALAR'
- or (ref($where) eq 'REF' and ref($$where) eq 'ARRAY')
- ) {
- return $self->_literal_to_dq($$where);
- } elsif (!ref($where) or Scalar::Util::blessed($where)) {
- return $self->_value_to_dq($where);
- }
- die "Can't handle $where";
-}
-
-sub _expr_to_dq_ARRAYREF {
- my ($self, $where, $logic) = @_;
-
- $logic = uc($logic || $self->{logic} || 'OR');
- $logic eq 'AND' or $logic eq 'OR' or puke "unknown logic: $logic";
-
- return unless @$where;
-
- my ($first, @rest) = @$where;
-
- return $self->_expr_to_dq($first) unless @rest;
-
- my $first_dq = do {
- if (!ref($first)) {
- $self->_where_hashpair_to_dq($first => shift(@rest));
- } else {
- $self->_expr_to_dq($first);
- }
- };
-
- return $self->_expr_to_dq_ARRAYREF(\@rest, $logic) unless $first_dq;
-
- $self->_op_to_dq(
- $logic, $first_dq, $self->_expr_to_dq_ARRAYREF(\@rest, $logic)
- );
-}
-
-sub _expr_to_dq_HASHREF {
- my ($self, $where, $logic) = @_;
-
- $logic = uc($logic) if $logic;
-
- my @dq = map {
- $self->_where_hashpair_to_dq($_ => $where->{$_}, $logic)
- } sort keys %$where;
-
- return $dq[0] unless @dq > 1;
-
- my $final = pop(@dq);
-
- foreach my $dq (reverse @dq) {
- $final = $self->_op_to_dq($logic||'AND', $dq, $final);
- }
-
- return $final;
-}
-
-sub _where_to_dq_SCALAR {
- shift->_value_to_dq(@_);
-}
-
-sub _apply_to_dq {
- my ($self, $op, $v) = @_;
- my @args = map $self->_expr_to_dq($_), (ref($v) eq 'ARRAY' ? @$v : $v);
-
- # Ok. Welcome to stupid compat code land. An SQLA expr that would in the
- # absence of this piece of crazy render to:
- #
- # A( B( C( x ) ) )
- #
- # such as
- #
- # { -a => { -b => { -c => $x } } }
- #
- # actually needs to render to:
- #
- # A( B( C x ) )
- #
- # because SQL sucks, and databases are hateful, and SQLA is Just That DWIM.
- #
- # However, we don't want to catch 'A(x)' and turn it into 'A x'
- #
- # So the way we deal with this is to go through all our arguments, and
- # then if the argument is -also- an apply, i.e. at least 'B', we check
- # its arguments - and if there's only one of them, and that isn't an apply,
- # then we convert to the bareword form. The end result should be:
- #
- # A( x ) -> A( x )
- # A( B( x ) ) -> A( B x )
- # A( B( C( x ) ) ) -> A( B( C x ) )
- # A( B( x + y ) ) -> A( B( x + y ) )
- # A( B( x, y ) ) -> A( B( x, y ) )
- #
- # If this turns out not to be quite right, please add additional tests
- # to either 01generate.t or 02where.t *and* update this comment.
-
- foreach my $arg (@args) {
- if (
- $arg->{type} eq DQ_OPERATOR and $arg->{operator}{'SQL.Naive'} eq 'apply'
- and @{$arg->{args}} == 2 and $arg->{args}[1]{type} ne DQ_OPERATOR
- ) {
- $arg->{operator}{'SQL.Naive'} = (shift @{$arg->{args}})->{elements}->[0];
- }
- }
- $self->_assert_pass_injection_guard($op);
- return $self->_op_to_dq(
- apply => $self->_ident_to_dq($op), @args
- );
-}
-
-sub _where_hashpair_to_dq {
- my ($self, $k, $v, $logic) = @_;
-
- if ($k =~ /^-(.*)/s) {
- my $op = uc($1);
- if ($op eq 'AND' or $op eq 'OR') {
- return $self->_expr_to_dq($v, $op);
- } elsif ($op eq 'NEST') {
- return $self->_expr_to_dq($v);
- } elsif ($op eq 'NOT') {
- return $self->_op_to_dq(NOT => $self->_expr_to_dq($v));
- } elsif ($op eq 'BOOL') {
- return ref($v) ? $self->_expr_to_dq($v) : $self->_ident_to_dq($v);
- } elsif ($op eq 'NOT_BOOL') {
- return $self->_op_to_dq(
- NOT => ref($v) ? $self->_expr_to_dq($v) : $self->_ident_to_dq($v)
- );
- } elsif ($op eq 'IDENT') {
- return $self->_ident_to_dq($v);
- } elsif ($op eq 'VALUE') {
- return $self->_value_to_dq($v);
- } elsif ($op =~ /^(?:AND|OR|NEST)_?\d+/) {
- die "Use of [and|or|nest]_N modifiers is no longer supported";
- } else {
- return $self->_apply_to_dq($op, $v);
- }
- } else {
- local our $Cur_Col_Meta = $k;
- if (ref($v) eq 'ARRAY') {
- if (!@$v) {
- return $self->_literal_to_dq($self->{sqlfalse});
- } elsif (defined($v->[0]) && $v->[0] =~ /-(and|or)/i) {
- return $self->_expr_to_dq_ARRAYREF([
- map +{ $k => $_ }, @{$v}[1..$#$v]
- ], uc($1));
- }
- return $self->_expr_to_dq_ARRAYREF([
- map +{ $k => $_ }, @$v
- ], $logic);
- } elsif (ref($v) eq 'SCALAR' or (ref($v) eq 'REF' and ref($$v) eq 'ARRAY')) {
- return +{
- type => DQ_LITERAL,
- subtype => 'SQL',
- parts => [ $self->_ident_to_dq($k), $self->_literal_to_dq($$v) ]
- };
- }
- my ($op, $rhs) = do {
- if (ref($v) eq 'HASH') {
- if (keys %$v > 1) {
- return $self->_expr_to_dq_ARRAYREF([
- map +{ $k => { $_ => $v->{$_} } }, sort keys %$v
- ], $logic||'AND');
- }
- my ($op, $value) = %$v;
- s/^-//, s/_/ /g for $op;
- if ($op =~ /^(and|or)$/i) {
- return $self->_expr_to_dq({ $k => $value }, $op);
- } elsif (
- my $special_op = List::Util::first {$op =~ $_->{regex}}
- @{$self->{special_ops}}
- ) {
- return $self->_literal_to_dq(
- [ $self->${\$special_op->{handler}}($k, $op, $value) ]
- );;
- } elsif ($op =~ /^(?:AND|OR|NEST)_?\d+$/i) {
- die "Use of [and|or|nest]_N modifiers is no longer supported";
- }
- (uc($op), $value);
- } else {
- ($self->{cmp}, $v);
- }
- };
- if ($op eq 'BETWEEN' or $op eq 'IN' or $op eq 'NOT IN' or $op eq 'NOT BETWEEN') {
- if (ref($rhs) ne 'ARRAY') {
- if ($op =~ /IN$/) {
- # have to add parens if none present because -in => \"SELECT ..."
- # got documented. mst hates everything.
- if (ref($rhs) eq 'SCALAR') {
- my $x = $$rhs;
- 1 while ($x =~ s/\A\s*\((.*)\)\s*\Z/$1/s);
- $rhs = \$x;
- } else {
- my ($x, @rest) = @{$$rhs};
- 1 while ($x =~ s/\A\s*\((.*)\)\s*\Z/$1/s);
- $rhs = \[ $x, @rest ];
- }
- }
- return $self->_op_to_dq(
- $op, $self->_ident_to_dq($k), $self->_literal_to_dq($$rhs)
- );
- }
- return $self->_literal_to_dq($self->{sqlfalse}) unless @$rhs;
- return $self->_op_to_dq(
- $op, $self->_ident_to_dq($k), map $self->_expr_to_dq($_), @$rhs
- )
- } elsif ($op =~ s/^NOT (?!LIKE)//) {
- return $self->_where_hashpair_to_dq(-not => { $k => { $op => $rhs } });
- } elsif ($op eq 'IDENT') {
- return $self->_op_to_dq(
- $self->{cmp}, $self->_ident_to_dq($k), $self->_ident_to_dq($rhs)
- );
- } elsif ($op eq 'VALUE') {
- return $self->_op_to_dq(
- $self->{cmp}, $self->_ident_to_dq($k), $self->_value_to_dq($rhs)
- );
- } elsif (!defined($rhs)) {
- my $null_op = do {
- if ($op eq '=' or $op eq 'LIKE') {
- 'IS NULL'
- } elsif ($op eq '!=') {
- 'IS NOT NULL'
- } else {
- die "Can't do undef -> NULL transform for operator ${op}";
- }
- };
- return $self->_op_to_dq($null_op, $self->_ident_to_dq($k));
- }
- if (ref($rhs) eq 'ARRAY') {
- if (!@$rhs) {
- return $self->_literal_to_dq(
- $op eq '!=' ? $self->{sqltrue} : $self->{sqlfalse}
- );
- } elsif (defined($rhs->[0]) and $rhs->[0] =~ /^-(and|or)$/i) {
- return $self->_expr_to_dq_ARRAYREF([
- map +{ $k => { $op => $_ } }, @{$rhs}[1..$#$rhs]
- ], uc($1));
- } elsif ($op =~ /^-(?:AND|OR|NEST)_?\d+/) {
- die "Use of [and|or|nest]_N modifiers is no longer supported";
- }
- return $self->_expr_to_dq_ARRAYREF([
- map +{ $k => { $op => $_ } }, @$rhs
- ]);
- }
- return $self->_op_to_dq(
- $op, $self->_ident_to_dq($k), $self->_expr_to_dq($rhs)
- );
- }
-}
-
-#======================================================================
-# ORDER BY
-#======================================================================
-
sub _order_by {
my ($self, $arg) = @_;
- if (my $dq = $self->_order_by_to_dq($arg)) {
+ if (my $dq = $self->converter->_order_by_to_dq($arg)) {
# SQLA generates ' ORDER BY foo'. The hilarity.
wantarray
? do { my @r = $self->_render_dq($dq); $r[0] = ' '.$r[0]; @r }
}
}
-sub _order_by_to_dq {
- my ($self, $arg, $dir, $from) = @_;
-
- return unless $arg;
-
- my $dq = {
- type => DQ_ORDER,
- ($dir ? (direction => $dir) : ()),
- ($from ? (from => $from) : ()),
- };
-
- if (!ref($arg)) {
- $dq->{by} = $self->_ident_to_dq($arg);
- } elsif (ref($arg) eq 'ARRAY') {
- return unless @$arg;
- local our $Order_Inner unless our $Order_Recursing;
- local $Order_Recursing = 1;
- my ($outer, $inner);
- foreach my $member (@$arg) {
- local $Order_Inner;
- my $next = $self->_order_by_to_dq($member, $dir, $from);
- $outer ||= $next;
- $inner->{from} = $next if $inner;
- $inner = $Order_Inner || $next;
- }
- $Order_Inner = $inner;
- return $outer;
- } elsif (ref($arg) eq 'REF' and ref($$arg) eq 'ARRAY') {
- $dq->{by} = $self->_literal_to_dq($$arg);
- } elsif (ref($arg) eq 'SCALAR') {
- $dq->{by} = $self->_literal_to_dq($$arg);
- } elsif (ref($arg) eq 'HASH') {
- my ($key, $val, @rest) = %$arg;
-
- return unless $key;
-
- if (@rest or not $key =~ /^-(desc|asc)/i) {
- puke "hash passed to _order_by must have exactly one key (-desc or -asc)";
- }
- my $dir = uc $1;
- return $self->_order_by_to_dq($val, $dir, $from);
- } else {
- die "Can't handle $arg in _order_by_to_dq";
- }
- return $dq;
-}
-
-#======================================================================
-# DATASOURCE (FOR NOW, JUST PLAIN TABLE OR LIST OF TABLES)
-#======================================================================
-
-sub _table { shift->_render_sqla(table => @_) }
-
-sub _table_to_dq {
- my ($self, $from) = @_;
- if (ref($from) eq 'ARRAY') {
- die "Empty FROM list" unless my @f = @$from;
- my $dq = $self->_table_to_dq(shift @f);
- while (my $x = shift @f) {
- $dq = {
- type => DQ_JOIN,
- join => [ $dq, $self->_table_to_dq($x) ]
- };
- }
- $dq;
- } elsif (ref($from) eq 'SCALAR') {
- +{
- type => DQ_LITERAL,
- subtype => 'SQL',
- literal => $$from
- }
- } else {
- $self->_ident_to_dq($from);
- }
-}
-
-
-#======================================================================
-# UTILITY FUNCTIONS
-#======================================================================
-
# highly optimized, as it's called way too often
sub _quote {
# my ($self, $label) = @_;
);
}
+sub _assert_pass_injection_guard {
+ if ($_[1] =~ $_[0]->{injection_guard}) {
+ my $class = ref $_[0];
+ die "Possible SQL injection attempt '$_[1]'. If this is indeed a part of "
+ . "the desired SQL use literal SQL ( \'...' or \[ '...' ] ) or supply "
+ . "your own {injection_guard} attribute to ${class}->new()"
+ }
+}
# Conversion, if applicable
sub _convert ($) {
#my ($self, $arg) = @_;
-
-# LDNOTE : modified the previous implementation below because
-# it was not consistent : the first "return" is always an array,
-# the second "return" is context-dependent. Anyway, _convert
-# seems always used with just a single argument, so make it a
-# scalar function.
-# return @_ unless $self->{convert};
-# my $conv = $self->_sqlcase($self->{convert});
-# my @ret = map { $conv.'('.$_.')' } @_;
-# return wantarray ? @ret : $ret[0];
if ($_[0]->{convert}) {
return $_[0]->_sqlcase($_[0]->{convert}) .'(' . $_[1] . ')';
}
# And bindtype
sub _bindtype (@) {
#my ($self, $col, @vals) = @_;
-
- #LDNOTE : changed original implementation below because it did not make
- # sense when bindtype eq 'columns' and @vals > 1.
-# return $self->{bindtype} eq 'columns' ? [ $col, @vals ] : @vals;
-
# called often - tighten code
return $_[0]->{bindtype} eq 'columns'
? map {[$_[1], $_]} @_[2 .. $#_]
return $_[0]->{case} ? $_[1] : uc($_[1]);
}
-#======================================================================
-# VALUES, GENERATE, AUTOLOAD
-#======================================================================
-
-# LDNOTE: original code from nwiger, didn't touch code in that section
-# I feel the AUTOLOAD stuff should not be the default, it should
-# only be activated on explicit demand by user.
-
sub values {
my $self = shift;
my $data = shift || return;
}
}
-
-sub DESTROY { 1 }
-
-#sub AUTOLOAD {
-# # This allows us to check for a local, then _form, attr
-# my $self = shift;
-# my($name) = $AUTOLOAD =~ /.*::(.+)/;
-# return $self->generate($name, @_);
-#}
-
1;
-
__END__
=head1 NAME
my $sql = SQL::Abstract->new;
- my($stmt, @bind) = $sql->select($table, \@fields, \%where, \@order);
+ my($stmt, @bind) = $sql->select($source, \@fields, \%where, \@order);
my($stmt, @bind) = $sql->insert($table, \%fieldvals || \@values);
WHERE name like 'nwiger' AND email like 'nate@wiger.org'
-You can also override the comparsion on an individual basis - see
+You can also override the comparison on an individual basis - see
the huge section on L</"WHERE CLAUSES"> at the bottom.
=item sqltrue, sqlfalse
The argument can be either an arrayref (interpreted as a list
of field names, will be joined by commas and quoted), or a
plain scalar (literal SQL, not quoted).
-Please observe that this API is not as flexible as for
-the first argument C<$table>, for backwards compatibility reasons.
+Please observe that this API is not as flexible as that of
+the first argument C<$source>, for backwards compatibility reasons.
=item $where
)";
@bind = ('2000');
-
+Finally, if the argument to C<-in> is not a reference, it will be
+treated as a single-element array.
Another pair of operators is C<-between> and C<-not_between>,
used with an arrayref of two values:
my %where = (
-and => [
-bool => 'one',
- -bool => 'two',
- -bool => 'three',
- -not_bool => 'four',
+ -not_bool => { two=> { -rlike => 'bar' } },
+ -not_bool => { three => [ { '=', 2 }, { '>', 5 } ] },
],
);
Would give you:
- WHERE one AND two AND three AND NOT four
+ WHERE
+ one
+ AND
+ (NOT two RLIKE ?)
+ AND
+ (NOT ( three = ? OR three > ? ))
=head2 Nested conditions, -and/-or prefixes
array => [1, 2, 3]
);
-the result would porbably be not what you wanted:
+the result would probably not be what you wanted:
$stmt = 'WHERE array = ? OR array = ? OR array = ?';
@bind = (1, 2, 3);
#!/usr/bin/perl
+ use warnings;
+ use strict;
+
use CGI::FormBuilder;
use SQL::Abstract;