extract list as a node type
[scpubgit/Q-Branch.git] / lib / SQL / Abstract.pm
CommitLineData
96449e8e 1package SQL::Abstract; # see doc at end of file
2
96449e8e 3use strict;
4use warnings;
9d9d5bd6 5use Carp ();
312d830b 6use List::Util ();
7use Scalar::Util ();
96449e8e 8
0da0fe34 9use Exporter 'import';
10our @EXPORT_OK = qw(is_plain_value is_literal_value);
11
12BEGIN {
13 if ($] < 5.009_005) {
14 require MRO::Compat;
15 }
16 else {
17 require mro;
18 }
843a94b5 19
20 *SQL::Abstract::_ENV_::DETECT_AUTOGENERATED_STRINGIFICATION = $ENV{SQLA_ISVALUE_IGNORE_AUTOGENERATED_STRINGIFICATION}
21 ? sub () { 0 }
22 : sub () { 1 }
23 ;
0da0fe34 24}
25
96449e8e 26#======================================================================
27# GLOBALS
28#======================================================================
29
dc6afcf8 30our $VERSION = '1.86';
7479e27e 31
22f1a437 32# This would confuse some packagers
c520207b 33$VERSION = eval $VERSION if $VERSION =~ /_/; # numify for warning-free dev releases
96449e8e 34
35our $AUTOLOAD;
36
37# special operators (-in, -between). May be extended/overridden by user.
38# See section WHERE: BUILTIN SPECIAL OPERATORS below for implementation
39my @BUILTIN_SPECIAL_OPS = (
f663e672 40 {regex => qr/^ (?: not \s )? between $/ix, handler => sub { die "NOPE" }},
41 {regex => qr/^ (?: not \s )? in $/ix, handler => sub { die "NOPE" }},
87c8e45b 42 {regex => qr/^ is (?: \s+ not )? $/ix, handler => sub { die "NOPE" }},
96449e8e 43);
44
45#======================================================================
46# DEBUGGING AND ERROR REPORTING
47#======================================================================
48
49sub _debug {
50 return unless $_[0]->{debug}; shift; # a little faster
51 my $func = (caller(1))[3];
52 warn "[$func] ", @_, "\n";
53}
54
55sub belch (@) {
56 my($func) = (caller(1))[3];
9d9d5bd6 57 Carp::carp "[$func] Warning: ", @_;
96449e8e 58}
59
60sub puke (@) {
61 my($func) = (caller(1))[3];
9d9d5bd6 62 Carp::croak "[$func] Fatal: ", @_;
96449e8e 63}
64
0da0fe34 65sub is_literal_value ($) {
66 ref $_[0] eq 'SCALAR' ? [ ${$_[0]} ]
67 : ( ref $_[0] eq 'REF' and ref ${$_[0]} eq 'ARRAY' ) ? [ @${ $_[0] } ]
0da0fe34 68 : undef;
69}
70
71# FIXME XSify - this can be done so much more efficiently
72sub is_plain_value ($) {
73 no strict 'refs';
966200cc 74 ! length ref $_[0] ? \($_[0])
0da0fe34 75 : (
76 ref $_[0] eq 'HASH' and keys %{$_[0]} == 1
77 and
78 exists $_[0]->{-value}
966200cc 79 ) ? \($_[0]->{-value})
0da0fe34 80 : (
a1c9e0ff 81 # reuse @_ for even moar speedz
82 defined ( $_[1] = Scalar::Util::blessed $_[0] )
0da0fe34 83 and
84 # deliberately not using Devel::OverloadInfo - the checks we are
85 # intersted in are much more limited than the fullblown thing, and
86 # this is a very hot piece of code
87 (
e8d729d4 88 # simply using ->can('(""') can leave behind stub methods that
89 # break actually using the overload later (see L<perldiag/Stub
90 # found while resolving method "%s" overloading "%s" in package
91 # "%s"> and the source of overload::mycan())
44e54b41 92 #
0da0fe34 93 # either has stringification which DBI SHOULD prefer out of the box
a1c9e0ff 94 grep { *{ (qq[${_}::(""]) }{CODE} } @{ $_[2] = mro::get_linear_isa( $_[1] ) }
0da0fe34 95 or
20e178a8 96 # has nummification or boolification, AND fallback is *not* disabled
0da0fe34 97 (
843a94b5 98 SQL::Abstract::_ENV_::DETECT_AUTOGENERATED_STRINGIFICATION
99 and
20e178a8 100 (
101 grep { *{"${_}::(0+"}{CODE} } @{$_[2]}
102 or
103 grep { *{"${_}::(bool"}{CODE} } @{$_[2]}
104 )
0da0fe34 105 and
106 (
107 # no fallback specified at all
a1c9e0ff 108 ! ( ($_[3]) = grep { *{"${_}::()"}{CODE} } @{$_[2]} )
0da0fe34 109 or
110 # fallback explicitly undef
a1c9e0ff 111 ! defined ${"$_[3]::()"}
0da0fe34 112 or
113 # explicitly true
a1c9e0ff 114 !! ${"$_[3]::()"}
0da0fe34 115 )
116 )
117 )
966200cc 118 ) ? \($_[0])
0da0fe34 119 : undef;
120}
121
122
96449e8e 123
124#======================================================================
125# NEW
126#======================================================================
127
128sub new {
129 my $self = shift;
130 my $class = ref($self) || $self;
131 my %opt = (ref $_[0] eq 'HASH') ? %{$_[0]} : @_;
132
133 # choose our case by keeping an option around
134 delete $opt{case} if $opt{case} && $opt{case} ne 'lower';
135
136 # default logic for interpreting arrayrefs
ef559da3 137 $opt{logic} = $opt{logic} ? uc $opt{logic} : 'OR';
96449e8e 138
139 # how to return bind vars
96449e8e 140 $opt{bindtype} ||= 'normal';
141
142 # default comparison is "=", but can be overridden
143 $opt{cmp} ||= '=';
144
3af02ccb 145 # try to recognize which are the 'equality' and 'inequality' ops
3cdadcbe 146 # (temporary quickfix (in 2007), should go through a more seasoned API)
147 $opt{equality_op} = qr/^( \Q$opt{cmp}\E | \= )$/ix;
148 $opt{inequality_op} = qr/^( != | <> )$/ix;
149
150 $opt{like_op} = qr/^ (is\s+)? r?like $/xi;
151 $opt{not_like_op} = qr/^ (is\s+)? not \s+ r?like $/xi;
96449e8e 152
153 # SQL booleans
154 $opt{sqltrue} ||= '1=1';
155 $opt{sqlfalse} ||= '0=1';
156
9d48860e 157 # special operators
30af97c5 158 $opt{special_ops} ||= [];
159
b6251592 160 # regexes are applied in order, thus push after user-defines
96449e8e 161 push @{$opt{special_ops}}, @BUILTIN_SPECIAL_OPS;
162
cf06e9dc 163 if ($class->isa('DBIx::Class::SQLMaker')) {
dd1d0dbf 164 push @{$opt{special_ops}}, our $DBIC_Compat_Op ||= {
165 regex => qr/^(?:ident|value)$/i, handler => sub { die "NOPE" }
166 };
cf06e9dc 167 $opt{is_dbic_sqlmaker} = 1;
dd1d0dbf 168 }
169
9d48860e 170 # unary operators
59f23b3d 171 $opt{unary_ops} ||= [];
59f23b3d 172
3af02ccb 173 # rudimentary sanity-check for user supplied bits treated as functions/operators
b6251592 174 # If a purported function matches this regular expression, an exception is thrown.
175 # Literal SQL is *NOT* subject to this check, only functions (and column names
176 # when quoting is not in effect)
96449e8e 177
b6251592 178 # FIXME
179 # need to guard against ()'s in column names too, but this will break tons of
180 # hacks... ideas anyone?
181 $opt{injection_guard} ||= qr/
182 \;
183 |
184 ^ \s* go \s
185 /xmi;
96449e8e 186
b07681b1 187 $opt{node_types} = +{
188 map +("-$_" => '_render_'.$_),
352d74bc 189 qw(op func value bind ident literal list)
b07681b1 190 };
191
ec19b759 192 $opt{expand_unary} = {};
193
b6251592 194 return bless \%opt, $class;
195}
96449e8e 196
e175845b 197sub sqltrue { +{ -literal => [ $_[0]->{sqltrue} ] } }
198sub sqlfalse { +{ -literal => [ $_[0]->{sqlfalse} ] } }
170e6c33 199
200sub _assert_pass_injection_guard {
201 if ($_[1] =~ $_[0]->{injection_guard}) {
202 my $class = ref $_[0];
203 puke "Possible SQL injection attempt '$_[1]'. If this is indeed a part of the "
204 . "desired SQL use literal SQL ( \'...' or \[ '...' ] ) or supply your own "
205 . "{injection_guard} attribute to ${class}->new()"
206 }
207}
208
209
96449e8e 210#======================================================================
211# INSERT methods
212#======================================================================
213
214sub insert {
02288357 215 my $self = shift;
216 my $table = $self->_table(shift);
217 my $data = shift || return;
218 my $options = shift;
96449e8e 219
220 my $method = $self->_METHOD_FOR_refkind("_insert", $data);
02288357 221 my ($sql, @bind) = $self->$method($data);
96449e8e 222 $sql = join " ", $self->_sqlcase('insert into'), $table, $sql;
02288357 223
e82e648a 224 if ($options->{returning}) {
ca4f826a 225 my ($s, @b) = $self->_insert_returning($options);
e82e648a 226 $sql .= $s;
227 push @bind, @b;
02288357 228 }
229
96449e8e 230 return wantarray ? ($sql, @bind) : $sql;
231}
232
60f3fd3f 233# So that subclasses can override INSERT ... RETURNING separately from
234# UPDATE and DELETE (e.g. DBIx::Class::SQLMaker::Oracle does this)
b17a3ece 235sub _insert_returning { shift->_returning(@_) }
236
95904db5 237sub _returning {
e82e648a 238 my ($self, $options) = @_;
6b1fe79d 239
e82e648a 240 my $f = $options->{returning};
241
ff96fdd4 242 my ($sql, @bind) = $self->_render_expr(
243 $self->_expand_maybe_list_expr($f, undef, -ident)
244 );
245 return wantarray
246 ? $self->_sqlcase(' returning ') . $sql
247 : ($self->_sqlcase(' returning ').$sql, @bind);
6b1fe79d 248}
249
96449e8e 250sub _insert_HASHREF { # explicit list of fields and then values
251 my ($self, $data) = @_;
252
253 my @fields = sort keys %$data;
254
fe3ae272 255 my ($sql, @bind) = $self->_insert_values($data);
96449e8e 256
257 # assemble SQL
258 $_ = $self->_quote($_) foreach @fields;
259 $sql = "( ".join(", ", @fields).") ".$sql;
260
261 return ($sql, @bind);
262}
263
264sub _insert_ARRAYREF { # just generate values(?,?) part (no list of fields)
265 my ($self, $data) = @_;
266
267 # no names (arrayref) so can't generate bindtype
268 $self->{bindtype} ne 'columns'
269 or belch "can't do 'columns' bindtype when called with arrayref";
270
19b6ccce 271 my (@values, @all_bind);
272 foreach my $value (@$data) {
273 my ($values, @bind) = $self->_insert_value(undef, $value);
274 push @values, $values;
275 push @all_bind, @bind;
276 }
277 my $sql = $self->_sqlcase('values')." ( ".join(", ", @values)." )";
278 return ($sql, @all_bind);
fe3ae272 279}
280
281sub _insert_ARRAYREFREF { # literal SQL with bind
282 my ($self, $data) = @_;
283
284 my ($sql, @bind) = @${$data};
285 $self->_assert_bindval_matches_bindtype(@bind);
286
287 return ($sql, @bind);
288}
289
290
291sub _insert_SCALARREF { # literal SQL without bind
292 my ($self, $data) = @_;
293
294 return ($$data);
295}
296
297sub _insert_values {
298 my ($self, $data) = @_;
299
96449e8e 300 my (@values, @all_bind);
fe3ae272 301 foreach my $column (sort keys %$data) {
19b6ccce 302 my ($values, @bind) = $self->_insert_value($column, $data->{$column});
303 push @values, $values;
304 push @all_bind, @bind;
305 }
306 my $sql = $self->_sqlcase('values')." ( ".join(", ", @values)." )";
307 return ($sql, @all_bind);
308}
96449e8e 309
19b6ccce 310sub _insert_value {
311 my ($self, $column, $v) = @_;
96449e8e 312
720ca4f7 313 return $self->_render_expr(
314 $self->_expand_insert_value($column, $v)
315 );
316}
96449e8e 317
720ca4f7 318sub _expand_insert_value {
319 my ($self, $column, $v) = @_;
96449e8e 320
720ca4f7 321 if (ref($v) eq 'ARRAY') {
322 if ($self->{array_datatypes}) {
323 return +{ -bind => [ $column, $v ] };
324 }
325 my ($sql, @bind) = @$v;
326 $self->_assert_bindval_matches_bindtype(@bind);
327 return +{ -literal => $v };
328 }
329 if (ref($v) eq 'HASH') {
330 if (grep !/^-/, keys %$v) {
331 belch "HASH ref as bind value in insert is not supported";
332 return +{ -bind => [ $column, $v ] };
333 }
334 }
335 if (!defined($v)) {
336 return +{ -bind => [ $column, undef ] };
337 }
338 local our $Cur_Col_Meta = $column;
339 return $self->_expand_expr($v);
96449e8e 340}
341
342
96449e8e 343
344#======================================================================
345# UPDATE methods
346#======================================================================
347
348
349sub update {
95904db5 350 my $self = shift;
351 my $table = $self->_table(shift);
352 my $data = shift || return;
353 my $where = shift;
354 my $options = shift;
96449e8e 355
356 # first build the 'SET' part of the sql statement
96449e8e 357 puke "Unsupported data type specified to \$sql->update"
358 unless ref $data eq 'HASH';
359
9ade906e 360 my ($sql, @all_bind) = $self->_update_set_values($data);
a9e94508 361 $sql = $self->_sqlcase('update ') . $table . $self->_sqlcase(' set ')
9ade906e 362 . $sql;
363
364 if ($where) {
365 my($where_sql, @where_bind) = $self->where($where);
366 $sql .= $where_sql;
367 push @all_bind, @where_bind;
368 }
369
370 if ($options->{returning}) {
371 my ($returning_sql, @returning_bind) = $self->_update_returning($options);
372 $sql .= $returning_sql;
373 push @all_bind, @returning_bind;
374 }
375
376 return wantarray ? ($sql, @all_bind) : $sql;
377}
378
379sub _update_set_values {
380 my ($self, $data) = @_;
381
89690da2 382 return $self->_render_expr(
383 $self->_expand_update_set_values($data),
384 );
385}
96449e8e 386
89690da2 387sub _expand_update_set_values {
388 my ($self, $data) = @_;
389 $self->_expand_maybe_list_expr( [
390 map {
391 my ($k, $set) = @$_;
c4ed66f4 392 $set = { -bind => $_ } unless defined $set;
89690da2 393 +{ -op => [ '=', { -ident => $k }, $set ] };
394 }
395 map {
396 my $k = $_;
397 my $v = $data->{$k};
398 (ref($v) eq 'ARRAY'
399 ? ($self->{array_datatypes}
400 ? [ $k, +{ -bind => [ $k, $v ] } ]
401 : [ $k, +{ -literal => $v } ])
402 : do {
403 local our $Cur_Col_Meta = $k;
404 [ $k, $self->_expand_expr($v) ]
405 }
406 );
407 } sort keys %$data
408 ] );
96449e8e 409}
410
60f3fd3f 411# So that subclasses can override UPDATE ... RETURNING separately from
412# INSERT and DELETE
20bb2ad5 413sub _update_returning { shift->_returning(@_) }
96449e8e 414
415
416
417#======================================================================
418# SELECT
419#======================================================================
420
421
422sub select {
423 my $self = shift;
424 my $table = $self->_table(shift);
425 my $fields = shift || '*';
426 my $where = shift;
427 my $order = shift;
428
daa4ccdd 429 my ($fields_sql, @bind) = $self->_select_fields($fields);
96449e8e 430
daa4ccdd 431 my ($where_sql, @where_bind) = $self->where($where, $order);
432 push @bind, @where_bind;
433
434 my $sql = join(' ', $self->_sqlcase('select'), $fields_sql,
96449e8e 435 $self->_sqlcase('from'), $table)
436 . $where_sql;
437
9d48860e 438 return wantarray ? ($sql, @bind) : $sql;
96449e8e 439}
440
daa4ccdd 441sub _select_fields {
442 my ($self, $fields) = @_;
de63ce57 443 return $fields unless ref($fields);
27592e2b 444 return $self->_render_expr(
445 $self->_expand_maybe_list_expr($fields, undef, '-ident')
446 );
daa4ccdd 447}
448
96449e8e 449#======================================================================
450# DELETE
451#======================================================================
452
453
454sub delete {
85327cd5 455 my $self = shift;
456 my $table = $self->_table(shift);
457 my $where = shift;
458 my $options = shift;
96449e8e 459
460 my($where_sql, @bind) = $self->where($where);
a9e94508 461 my $sql = $self->_sqlcase('delete from ') . $table . $where_sql;
96449e8e 462
85327cd5 463 if ($options->{returning}) {
ca4f826a 464 my ($returning_sql, @returning_bind) = $self->_delete_returning($options);
85327cd5 465 $sql .= $returning_sql;
466 push @bind, @returning_bind;
467 }
468
9d48860e 469 return wantarray ? ($sql, @bind) : $sql;
96449e8e 470}
471
60f3fd3f 472# So that subclasses can override DELETE ... RETURNING separately from
473# INSERT and UPDATE
85327cd5 474sub _delete_returning { shift->_returning(@_) }
475
476
96449e8e 477
478#======================================================================
479# WHERE: entry point
480#======================================================================
481
482
483
484# Finally, a separate routine just to handle WHERE clauses
485sub where {
486 my ($self, $where, $order) = @_;
487
7ad12721 488 local $self->{convert_where} = $self->{convert};
489
96449e8e 490 # where ?
e175845b 491 my ($sql, @bind) = defined($where)
492 ? $self->_recurse_where($where)
493 : (undef);
417dd15e 494 $sql = (defined $sql and length $sql) ? $self->_sqlcase(' where ') . "( $sql )" : '';
96449e8e 495
496 # order by?
497 if ($order) {
26fe4d30 498 my ($order_sql, @order_bind) = $self->_order_by($order);
499 $sql .= $order_sql;
500 push @bind, @order_bind;
96449e8e 501 }
502
9d48860e 503 return wantarray ? ($sql, @bind) : $sql;
96449e8e 504}
505
a2cd381d 506sub _expand_expr {
2558b622 507 my ($self, $expr, $logic, $default_scalar_to) = @_;
508 local our $Default_Scalar_To = $default_scalar_to if $default_scalar_to;
3ae10d16 509 our $Expand_Depth ||= 0; local $Expand_Depth = $Expand_Depth + 1;
252518da 510 return undef unless defined($expr);
59588695 511 if (ref($expr) eq 'HASH') {
512 if (keys %$expr > 1) {
513 $logic ||= 'and';
77617257 514 return +{ -op => [
515 $logic,
59588695 516 map $self->_expand_expr_hashpair($_ => $expr->{$_}, $logic),
517 sort keys %$expr
518 ] };
519 }
1c0c0f41 520 return { -literal => [ '' ] } unless keys %$expr;
59588695 521 return $self->_expand_expr_hashpair(%$expr, $logic);
a2cd381d 522 }
08264f40 523 if (ref($expr) eq 'ARRAY') {
99a65fa8 524 my $logic = lc($logic || $self->{logic});
08264f40 525 $logic eq 'and' or $logic eq 'or' or puke "unknown logic: $logic";
526
1c0c0f41 527 #my @expr = @$expr;
528 my @expr = grep {
529 (ref($_) eq 'ARRAY' and @$_)
530 or (ref($_) eq 'HASH' and %$_)
531 or 1
532 } @$expr;
08264f40 533
534 my @res;
535
536 while (my ($el) = splice @expr, 0, 1) {
537 puke "Supplying an empty left hand side argument is not supported in array-pairs"
538 unless defined($el) and length($el);
539 my $elref = ref($el);
540 if (!$elref) {
dd1d0dbf 541 local $Expand_Depth = 0;
08264f40 542 push(@res, $self->_expand_expr({ $el, shift(@expr) }));
543 } elsif ($elref eq 'ARRAY') {
544 push(@res, $self->_expand_expr($el)) if @$el;
ec857800 545 } elsif (my $l = is_literal_value($el)) {
546 push @res, { -literal => $l };
08264f40 547 } elsif ($elref eq 'HASH') {
dd1d0dbf 548 local $Expand_Depth = 0;
1b630cfe 549 push @res, $self->_expand_expr($el) if %$el;
08264f40 550 } else {
da4a0964 551 die "notreached";
08264f40 552 }
553 }
2143604f 554 return { -op => [ $logic, @res ] };
08264f40 555 }
ca3da680 556 if (my $literal = is_literal_value($expr)) {
557 return +{ -literal => $literal };
558 }
99a65fa8 559 if (!ref($expr) or Scalar::Util::blessed($expr)) {
2558b622 560 if (my $d = $Default_Scalar_To) {
561 return +{ $d => $expr };
562 }
99a65fa8 563 if (my $m = our $Cur_Col_Meta) {
564 return +{ -bind => [ $m, $expr ] };
565 }
252518da 566 return +{ -value => $expr };
567 }
252518da 568 die "notreached";
a2cd381d 569}
96449e8e 570
59588695 571sub _expand_expr_hashpair {
572 my ($self, $k, $v, $logic) = @_;
d13725da 573 unless (defined($k) and length($k)) {
2d64004f 574 if (defined($k) and my $literal = is_literal_value($v)) {
d13725da 575 belch 'Hash-pairs consisting of an empty string with a literal are deprecated, and will be removed in 2.0: use -and => [ $literal ] instead';
2d64004f 576 return { -literal => $literal };
d13725da 577 }
578 puke "Supplying an empty left hand side argument is not supported";
579 }
ef071fad 580 if ($k =~ /^-/) {
99a65fa8 581 $self->_assert_pass_injection_guard($k =~ /^-(.*)$/s);
582 if ($k =~ s/ [_\s]? \d+ $//x ) {
583 belch 'Use of [and|or|nest]_N modifiers is deprecated and will be removed in SQLA v2.0. '
584 . "You probably wanted ...-and => [ $k => COND1, $k => COND2 ... ]";
585 }
ef071fad 586 if ($k eq '-nest') {
0fc68377 587 # DBIx::Class requires a nest warning to be emitted once but the private
588 # method it overrode to do so no longer exists
cf06e9dc 589 if ($self->{is_dbic_sqlmaker}) {
590 unless (our $Nest_Warned) {
0fc68377 591 belch(
592 "-nest in search conditions is deprecated, you most probably wanted:\n"
593 .q|{..., -and => [ \%cond0, \@cond1, \'cond2', \[ 'cond3', [ col => bind ] ], etc. ], ... }|
594 );
595 $Nest_Warned = 1;
596 }
597 }
ef071fad 598 return $self->_expand_expr($v);
599 }
6ab1562a 600 if ($k eq '-bool') {
601 if (ref($v)) {
602 return $self->_expand_expr($v);
603 }
604 puke "-bool => undef not supported" unless defined($v);
605 return { -ident => $v };
606 }
99a65fa8 607 if ($k eq '-not') {
0c7e3af0 608 return { -op => [ 'not', $self->_expand_expr($v) ] };
99a65fa8 609 }
ce3bc4b0 610 if (my ($rest) = $k =~/^-not[_ ](.*)$/) {
0c7e3af0 611 return +{ -op => [
612 'not',
99a65fa8 613 $self->_expand_expr_hashpair("-${rest}", $v, $logic)
0c7e3af0 614 ] };
ce3bc4b0 615 }
99a65fa8 616 if (my ($logic) = $k =~ /^-(and|or)$/i) {
dd2d5bf7 617 if (ref($v) eq 'HASH') {
618 return $self->_expand_expr($v, $logic);
619 }
99a65fa8 620 if (ref($v) eq 'ARRAY') {
621 return $self->_expand_expr($v, $logic);
622 }
dd2d5bf7 623 }
99a65fa8 624 {
625 my $op = $k;
626 $op =~ s/^-// if length($op) > 1;
627
628 # top level special ops are illegal in general
3ae10d16 629 # note that, arguably, if it makes no sense at top level, it also
630 # makes no sense on the other side of an = sign or similar but DBIC
631 # gets disappointingly upset if I disallow it
632 if (
633 (our $Expand_Depth) == 1
634 and List::Util::first { $op =~ $_->{regex} } @{$self->{special_ops}}
635 ) {
636 puke "Illegal use of top-level '-$op'"
637 }
96a8d74a 638 if (my $us = List::Util::first { $op =~ $_->{regex} } @{$self->{unary_ops}}) {
639 return { -op => [ $op, $v ] };
640 }
99a65fa8 641 }
642 if ($k eq '-value' and my $m = our $Cur_Col_Meta) {
643 return +{ -bind => [ $m, $v ] };
644 }
ec19b759 645 if (my $custom = $self->{expand_unary}{$k}) {
646 return $self->$custom($v);
647 }
b07681b1 648 if ($self->{node_types}{$k}) {
99a65fa8 649 return { $k => $v };
d13725da 650 }
711892b1 651 if (
652 ref($v) eq 'HASH'
653 and keys %$v == 1
654 and (keys %$v)[0] =~ /^-/
655 ) {
656 my ($func) = $k =~ /^-(.*)$/;
3ae10d16 657 if (List::Util::first { $func =~ $_->{regex} } @{$self->{special_ops}}) {
658 return +{ -op => [ $func, $self->_expand_expr($v) ] };
659 }
711892b1 660 return +{ -func => [ $func, $self->_expand_expr($v) ] };
661 }
662 if (!ref($v) or is_literal_value($v)) {
99a65fa8 663 return +{ -op => [ $k =~ /^-(.*)$/, $self->_expand_expr($v) ] };
59588695 664 }
99a65fa8 665 }
666 if (
667 !defined($v)
668 or (
669 ref($v) eq 'HASH'
670 and exists $v->{-value}
671 and not defined $v->{-value}
672 )
673 ) {
674 return $self->_expand_expr_hashpair($k => { $self->{cmp} => undef });
675 }
676 if (!ref($v) or Scalar::Util::blessed($v)) {
ec19b759 677 my $d = our $Default_Scalar_To;
99a65fa8 678 return +{
679 -op => [
680 $self->{cmp},
681 { -ident => $k },
ec19b759 682 ($d ? { $d => $v } : { -bind => [ $k, $v ] })
99a65fa8 683 ]
684 };
685 }
686 if (ref($v) eq 'HASH') {
687 if (keys %$v > 1) {
e175845b 688 return { -op => [
689 'and',
99a65fa8 690 map $self->_expand_expr_hashpair($k => { $_ => $v->{$_} }),
691 sort keys %$v
692 ] };
693 }
dd1d0dbf 694 return { -literal => [ '' ] } unless keys %$v;
99a65fa8 695 my ($vk, $vv) = %$v;
696 $vk =~ s/^-//;
697 $vk = lc($vk);
698 $self->_assert_pass_injection_guard($vk);
699 if ($vk =~ s/ [_\s]? \d+ $//x ) {
700 belch 'Use of [and|or|nest]_N modifiers is deprecated and will be removed in SQLA v2.0. '
701 . "You probably wanted ...-and => [ -$vk => COND1, -$vk => COND2 ... ]";
702 }
703 if ($vk =~ /^(?:not[ _])?between$/) {
704 local our $Cur_Col_Meta = $k;
705 my @rhs = map $self->_expand_expr($_),
706 ref($vv) eq 'ARRAY' ? @$vv : $vv;
707 unless (
708 (@rhs == 1 and ref($rhs[0]) eq 'HASH' and $rhs[0]->{-literal})
709 or
710 (@rhs == 2 and defined($rhs[0]) and defined($rhs[1]))
711 ) {
712 puke "Operator '${\uc($vk)}' requires either an arrayref with two defined values or expressions, or a single literal scalarref/arrayref-ref";
b5b18861 713 }
99a65fa8 714 return +{ -op => [
715 join(' ', split '_', $vk),
716 { -ident => $k },
717 @rhs
718 ] }
719 }
720 if ($vk =~ /^(?:not[ _])?in$/) {
721 if (my $literal = is_literal_value($vv)) {
722 my ($sql, @bind) = @$literal;
723 my $opened_sql = $self->_open_outer_paren($sql);
10d07c4e 724 return +{ -op => [
99a65fa8 725 $vk, { -ident => $k },
726 [ { -literal => [ $opened_sql, @bind ] } ]
10d07c4e 727 ] };
728 }
99a65fa8 729 my $undef_err =
730 'SQL::Abstract before v1.75 used to generate incorrect SQL when the '
731 . "-${\uc($vk)} operator was given an undef-containing list: !!!AUDIT YOUR CODE "
732 . 'AND DATA!!! (the upcoming Data::Query-based version of SQL::Abstract '
733 . 'will emit the logically correct SQL instead of raising this exception)'
734 ;
735 puke("Argument passed to the '${\uc($vk)}' operator can not be undefined")
736 if !defined($vv);
737 my @rhs = map $self->_expand_expr($_),
738 map { ref($_) ? $_ : { -bind => [ $k, $_ ] } }
739 map { defined($_) ? $_: puke($undef_err) }
740 (ref($vv) eq 'ARRAY' ? @$vv : $vv);
e175845b 741 return $self->${\($vk =~ /^not/ ? 'sqltrue' : 'sqlfalse')} unless @rhs;
99a65fa8 742
743 return +{ -op => [
744 join(' ', split '_', $vk),
745 { -ident => $k },
746 \@rhs
747 ] };
748 }
749 if ($vk eq 'ident') {
02b8fe35 750 if (! defined $vv or (ref($vv) and ref($vv) eq 'ARRAY')) {
751 puke "-$vk requires a single plain scalar argument (a quotable identifier) or an arrayref of identifier parts";
f7778474 752 }
99a65fa8 753 return +{ -op => [
754 $self->{cmp},
755 { -ident => $k },
756 { -ident => $vv }
757 ] };
758 }
759 if ($vk eq 'value') {
760 return $self->_expand_expr_hashpair($k, undef) unless defined($vv);
761 return +{ -op => [
762 $self->{cmp},
763 { -ident => $k },
764 { -bind => [ $k, $vv ] }
765 ] };
766 }
767 if ($vk =~ /^is(?:[ _]not)?$/) {
768 puke "$vk can only take undef as argument"
769 if defined($vv)
770 and not (
771 ref($vv) eq 'HASH'
772 and exists($vv->{-value})
773 and !defined($vv->{-value})
774 );
775 $vk =~ s/_/ /g;
776 return +{ -op => [ $vk.' null', { -ident => $k } ] };
777 }
778 if ($vk =~ /^(and|or)$/) {
779 if (ref($vv) eq 'HASH') {
e62fe58a 780 return +{ -op => [
781 $vk,
99a65fa8 782 map $self->_expand_expr_hashpair($k, { $_ => $vv->{$_} }),
783 sort keys %$vv
7d7868d1 784 ] };
785 }
e28d9b13 786 }
30af97c5 787 if (my $us = List::Util::first { $vk =~ $_->{regex} } @{$self->{special_ops}}) {
99a65fa8 788 return { -op => [ $vk, { -ident => $k }, $vv ] };
7dbe1183 789 }
96a8d74a 790 if (my $us = List::Util::first { $vk =~ $_->{regex} } @{$self->{unary_ops}}) {
791 return { -op => [
792 $self->{cmp},
793 { -ident => $k },
794 { -op => [ $vk, $vv ] }
795 ] };
796 }
99a65fa8 797 if (ref($vv) eq 'ARRAY') {
798 my ($logic, @values) = (
799 (defined($vv->[0]) and $vv->[0] =~ /^-(and|or)$/i)
800 ? @$vv
801 : (-or => @$vv)
802 );
803 if (
804 $vk =~ $self->{inequality_op}
805 or join(' ', split '_', $vk) =~ $self->{not_like_op}
806 ) {
807 if (lc($logic) eq '-or' and @values > 1) {
808 my $op = uc join ' ', split '_', $vk;
809 belch "A multi-element arrayref as an argument to the inequality op '$op' "
810 . 'is technically equivalent to an always-true 1=1 (you probably wanted '
811 . "to say ...{ \$inequality_op => [ -and => \@values ] }... instead)"
812 ;
813 }
ef071fad 814 }
b3cb13e8 815 unless (@values) {
816 # try to DWIM on equality operators
817 my $op = join ' ', split '_', $vk;
818 return
e175845b 819 $op =~ $self->{equality_op} ? $self->sqlfalse
820 : $op =~ $self->{like_op} ? belch("Supplying an empty arrayref to '@{[ uc $op]}' is deprecated") && $self->sqlfalse
821 : $op =~ $self->{inequality_op} ? $self->sqltrue
822 : $op =~ $self->{not_like_op} ? belch("Supplying an empty arrayref to '@{[ uc $op]}' is deprecated") && $self->sqltrue
b3cb13e8 823 : puke "operator '$op' applied on an empty array (field '$k')";
824 }
63c97a0b 825 return +{ -op => [
826 $logic =~ /^-(.*)$/,
99a65fa8 827 map $self->_expand_expr_hashpair($k => { $vk => $_ }),
828 @values
829 ] };
830 }
831 if (
832 !defined($vv)
833 or (
834 ref($vv) eq 'HASH'
835 and exists $vv->{-value}
836 and not defined $vv->{-value}
837 )
838 ) {
839 my $op = join ' ', split '_', $vk;
840 my $is =
841 $op =~ /^not$/i ? 'is not' # legacy
842 : $op =~ $self->{equality_op} ? 'is'
843 : $op =~ $self->{like_op} ? belch("Supplying an undefined argument to '@{[ uc $op]}' is deprecated") && 'is'
844 : $op =~ $self->{inequality_op} ? 'is not'
845 : $op =~ $self->{not_like_op} ? belch("Supplying an undefined argument to '@{[ uc $op]}' is deprecated") && 'is not'
846 : puke "unexpected operator '$op' with undef operand";
847 return +{ -op => [ $is.' null', { -ident => $k } ] };
848 }
849 local our $Cur_Col_Meta = $k;
850 return +{ -op => [
851 $vk,
852 { -ident => $k },
853 $self->_expand_expr($vv)
854 ] };
855 }
856 if (ref($v) eq 'ARRAY') {
e175845b 857 return $self->sqlfalse unless @$v;
99a65fa8 858 $self->_debug("ARRAY($k) means distribute over elements");
859 my $this_logic = (
860 $v->[0] =~ /^-((?:and|or))$/i
861 ? ($v = [ @{$v}[1..$#$v] ], $1)
862 : ($self->{logic} || 'or')
863 );
cba28f66 864 return +{ -op => [
865 $this_logic,
866 map $self->_expand_expr({ $k => $_ }, $this_logic), @$v
867 ] };
99a65fa8 868 }
869 if (my $literal = is_literal_value($v)) {
870 unless (length $k) {
871 belch 'Hash-pairs consisting of an empty string with a literal are deprecated, and will be removed in 2.0: use -and => [ $literal ] instead';
872 return \$literal;
873 }
874 my ($sql, @bind) = @$literal;
875 if ($self->{bindtype} eq 'columns') {
876 for (@bind) {
6fb2bd90 877 $self->_assert_bindval_matches_bindtype($_);
aa8d7bdb 878 }
331e2209 879 }
99a65fa8 880 return +{ -literal => [ $self->_quote($k).' '.$sql, @bind ] };
331e2209 881 }
99a65fa8 882 die "notreached";
59588695 883}
884
e175845b 885sub _render_expr {
886 my ($self, $expr) = @_;
887 my ($k, $v, @rest) = %$expr;
888 die "No" if @rest;
b07681b1 889 if (my $meth = $self->{node_types}{$k}) {
181dcebf 890 return $self->$meth($v);
e175845b 891 }
892 die "notreached: $k";
893}
894
96449e8e 895sub _recurse_where {
896 my ($self, $where, $logic) = @_;
897
99a65fa8 898#print STDERR Data::Dumper::Concise::Dumper([ $where, $logic ]);
899
5492d4c2 900 # Special case: top level simple string treated as literal
901
902 my $where_exp = (ref($where)
903 ? $self->_expand_expr($where, $logic)
904 : { -literal => [ $where ] });
1c0c0f41 905#::Dwarn([ EXPANDED => $where_exp ]);
a2cd381d 906
99a65fa8 907#print STDERR Data::Dumper::Concise::Dumper([ EXP => $where_exp ]);
908
96449e8e 909 # dispatch on appropriate method according to refkind of $where
e175845b 910# my $method = $self->_METHOD_FOR_refkind("_where", $where_exp);
911
912# my ($sql, @bind) = $self->$method($where_exp, $logic);
311b2151 913
e175845b 914 my ($sql, @bind) = defined($where_exp) ? $self->_render_expr($where_exp) : (undef);
abe1a491 915 # DBIx::Class used to call _recurse_where in scalar context
916 # something else might too...
917 if (wantarray) {
918 return ($sql, @bind);
919 }
920 else {
921 belch "Calling _recurse_where in scalar context is deprecated and will go away before 2.0";
922 return $sql;
923 }
96449e8e 924}
925
181dcebf 926sub _render_ident {
927 my ($self, $ident) = @_;
cc422895 928
9cf28dfb 929 return $self->_convert($self->_quote($ident));
cc422895 930}
931
181dcebf 932sub _render_value {
933 my ($self, $value) = @_;
cc422895 934
52511ae3 935 return ($self->_convert('?'), $self->_bindtype(undef, $value));
cc422895 936}
937
c452734e 938my %unop_postfix = map +($_ => 1),
939 'is null', 'is not null',
940 'asc', 'desc',
941;
d13725da 942
b5b18861 943my %special = (
944 (map +($_ => do {
945 my $op = $_;
946 sub {
947 my ($self, $args) = @_;
948 my ($left, $low, $high) = @$args;
949 my ($rhsql, @rhbind) = do {
950 if (@$args == 2) {
951 puke "Single arg to between must be a literal"
952 unless $low->{-literal};
953 @{$low->{-literal}}
954 } else {
e56dd780 955 my ($l, $h) = map [ $self->_render_expr($_) ], $low, $high;
b5b18861 956 (join(' ', $l->[0], $self->_sqlcase('and'), $h->[0]),
957 @{$l}[1..$#$l], @{$h}[1..$#$h])
958 }
959 };
e56dd780 960 my ($lhsql, @lhbind) = $self->_render_expr($left);
b5b18861 961 return (
962 join(' ', '(', $lhsql, $self->_sqlcase($op), $rhsql, ')'),
963 @lhbind, @rhbind
964 );
965 }
966 }), 'between', 'not between'),
10d07c4e 967 (map +($_ => do {
968 my $op = $_;
969 sub {
970 my ($self, $args) = @_;
971 my ($lhs, $rhs) = @$args;
972 my @in_bind;
973 my @in_sql = map {
0ce981f8 974 my ($sql, @bind) = $self->_render_expr($_);
10d07c4e 975 push @in_bind, @bind;
976 $sql;
977 } @$rhs;
0ce981f8 978 my ($lhsql, @lbind) = $self->_render_expr($lhs);
10d07c4e 979 return (
980 $lhsql.' '.$self->_sqlcase($op).' ( '
981 .join(', ', @in_sql)
982 .' )',
983 @lbind, @in_bind
984 );
985 }
986 }), 'in', 'not in'),
b5b18861 987);
988
181dcebf 989sub _render_op {
990 my ($self, $v) = @_;
d13725da 991 my ($op, @args) = @$v;
992 $op =~ s/^-// if length($op) > 1;
cba28f66 993 $op = lc($op);
b5b18861 994 if (my $h = $special{$op}) {
995 return $self->$h(\@args);
996 }
3ae10d16 997 my $us = List::Util::first { $op =~ $_->{regex} } @{$self->{special_ops}};
998 if ($us and @args > 1) {
99a65fa8 999 puke "Special op '${op}' requires first value to be identifier"
1000 unless my ($k) = map $_->{-ident}, grep ref($_) eq 'HASH', $args[0];
dd1d0dbf 1001 local our $Expand_Depth = 1;
99a65fa8 1002 return $self->${\($us->{handler})}($k, $op, $args[1]);
1003 }
96a8d74a 1004 if (my $us = List::Util::first { $op =~ $_->{regex} } @{$self->{unary_ops}}) {
1005 return $self->${\($us->{handler})}($op, $args[0]);
1006 }
99a65fa8 1007 my $final_op = $op =~ /^(?:is|not)_/ ? join(' ', split '_', $op) : $op;
2143604f 1008 if (@args == 1 and $op !~ /^(and|or)$/) {
ec857800 1009 my ($expr_sql, @bind) = $self->_render_expr($args[0]);
d13725da 1010 my $op_sql = $self->_sqlcase($final_op);
1011 my $final_sql = (
1012 $unop_postfix{lc($final_op)}
1013 ? "${expr_sql} ${op_sql}"
1014 : "${op_sql} ${expr_sql}"
1015 );
3ae10d16 1016 return (($op eq 'not' || $us ? '('.$final_sql.')' : $final_sql), @bind);
1c0c0f41 1017 #} elsif (@args == 0) {
1018 # return '';
16d9289c 1019 } else {
1c0c0f41 1020 my @parts = grep length($_->[0]), map [ $self->_render_expr($_) ], @args;
1021 return '' unless @parts;
230812fc 1022 my $is_andor = !!($op =~ /^(and|or)$/);
1023 return @{$parts[0]} if $is_andor and @parts == 1;
1024 my ($final_sql) = map +($is_andor ? "( ${_} )" : $_), join(
352d74bc 1025 ' '.$self->_sqlcase($final_op).' ',
77617257 1026 map $_->[0], @parts
1027 );
99a65fa8 1028 return (
77617257 1029 $final_sql,
16d9289c 1030 map @{$_}[1..$#$_], @parts
99a65fa8 1031 );
d13725da 1032 }
1033 die "unhandled";
1034}
1035
352d74bc 1036sub _render_list {
1037 my ($self, $list) = @_;
1038 my @parts = grep length($_->[0]), map [ $self->_render_expr($_) ], @$list;
1039 return join(', ', map $_->[0], @parts), map @{$_}[1..$#$_], @parts;
1040}
1041
181dcebf 1042sub _render_func {
1043 my ($self, $rest) = @_;
711892b1 1044 my ($func, @args) = @$rest;
1045 my @arg_sql;
1046 my @bind = map {
1047 my @x = @$_;
1048 push @arg_sql, shift @x;
1049 @x
0f199fce 1050 } map [ $self->_render_expr($_) ], @args;
711892b1 1051 return ($self->_sqlcase($func).'('.join(', ', @arg_sql).')', @bind);
1052}
1053
181dcebf 1054sub _render_bind {
1055 my ($self, $bind) = @_;
d13725da 1056 return ($self->_convert('?'), $self->_bindtype(@$bind));
1057}
1058
181dcebf 1059sub _render_literal {
1060 my ($self, $literal) = @_;
465d43fd 1061 $self->_assert_bindval_matches_bindtype(@{$literal}[1..$#$literal]);
aa8d7bdb 1062 return @$literal;
1063}
1064
4a1f01a3 1065# Some databases (SQLite) treat col IN (1, 2) different from
1066# col IN ( (1, 2) ). Use this to strip all outer parens while
1067# adding them back in the corresponding method
1068sub _open_outer_paren {
1069 my ($self, $sql) = @_;
a5f91feb 1070
ca4f826a 1071 while (my ($inner) = $sql =~ /^ \s* \( (.*) \) \s* $/xs) {
a5f91feb 1072
1073 # there are closing parens inside, need the heavy duty machinery
1074 # to reevaluate the extraction starting from $sql (full reevaluation)
ca4f826a 1075 if ($inner =~ /\)/) {
a5f91feb 1076 require Text::Balanced;
1077
1078 my (undef, $remainder) = do {
1079 # idiotic design - writes to $@ but *DOES NOT* throw exceptions
1080 local $@;
ca4f826a 1081 Text::Balanced::extract_bracketed($sql, '()', qr/\s*/);
a5f91feb 1082 };
1083
1084 # the entire expression needs to be a balanced bracketed thing
1085 # (after an extract no remainder sans trailing space)
1086 last if defined $remainder and $remainder =~ /\S/;
1087 }
1088
1089 $sql = $inner;
1090 }
1091
1092 $sql;
4a1f01a3 1093}
1094
96449e8e 1095
96449e8e 1096#======================================================================
1097# ORDER BY
1098#======================================================================
1099
33177570 1100sub _expand_order_by {
96449e8e 1101 my ($self, $arg) = @_;
1102
33177570 1103 return unless defined($arg) and not (ref($arg) eq 'ARRAY' and !@$arg);
2b6158af 1104
4325df6a 1105 my $expander = sub {
1106 my ($self, $dir, $expr) = @_;
52ca537e 1107 my @to_expand = ref($expr) eq 'ARRAY' ? @$expr : $expr;
1108 foreach my $arg (@to_expand) {
1109 if (
1110 ref($arg) eq 'HASH'
1111 and keys %$arg > 1
1112 and grep /^-(asc|desc)$/, keys %$arg
1113 ) {
1114 puke "ordering direction hash passed to order by must have exactly one key (-asc or -desc)";
1115 }
1116 }
4325df6a 1117 my @exp = map +(defined($dir) ? { -op => [ $dir => $_ ] } : $_),
74156ee9 1118 map $self->_expand_expr($_, undef, -ident),
1119 map ref($_) eq 'ARRAY' ? @$_ : $_, @to_expand;
352d74bc 1120 return (@exp > 1 ? { -list => \@exp } : $exp[0]);
4325df6a 1121 };
18c743c8 1122
ec19b759 1123 local @{$self->{expand_unary}}{qw(-asc -desc)} = (
1124 sub { shift->$expander(asc => @_) },
1125 sub { shift->$expander(desc => @_) },
1126 );
f267b646 1127
33177570 1128 return $self->$expander(undef, $arg);
1129}
1130
1131sub _order_by {
1132 my ($self, $arg) = @_;
1133
1134 return '' unless defined(my $expanded = $self->_expand_order_by($arg));
4325df6a 1135
1136 my ($sql, @bind) = $self->_render_expr($expanded);
1137
13cd9220 1138 return '' unless length($sql);
1139
4325df6a 1140 my $final_sql = $self->_sqlcase(' order by ').$sql;
1141
1142 return wantarray ? ($final_sql, @bind) : $final_sql;
f267b646 1143}
1144
2e3cc357 1145# _order_by no longer needs to call this so doesn't but DBIC uses it.
1146
33177570 1147sub _order_by_chunks {
1148 my ($self, $arg) = @_;
1149
1150 return () unless defined(my $expanded = $self->_expand_order_by($arg));
1151
2e3cc357 1152 return $self->_chunkify_order_by($expanded);
1153}
1154
1155sub _chunkify_order_by {
1156 my ($self, $expanded) = @_;
1b630cfe 1157
dd1d0dbf 1158 return grep length, $self->_render_expr($expanded)
1b630cfe 1159 if $expanded->{-ident} or @{$expanded->{-literal}||[]} == 1;
1160
33177570 1161 for ($expanded) {
352d74bc 1162 if (ref() eq 'HASH' and my $l = $_->{-list}) {
1163 return map $self->_chunkify_order_by($_), @$l;
33177570 1164 }
1165 return [ $self->_render_expr($_) ];
1166 }
1167}
1168
96449e8e 1169#======================================================================
1170# DATASOURCE (FOR NOW, JUST PLAIN TABLE OR LIST OF TABLES)
1171#======================================================================
1172
1173sub _table {
1174 my $self = shift;
1175 my $from = shift;
7ad12721 1176 ($self->_render_expr(
8476c6a3 1177 $self->_expand_maybe_list_expr($from, undef, -ident)
7ad12721 1178 ))[0];
96449e8e 1179}
1180
1181
1182#======================================================================
1183# UTILITY FUNCTIONS
1184#======================================================================
1185
8476c6a3 1186sub _expand_maybe_list_expr {
1187 my ($self, $expr, $logic, $default) = @_;
bba04f52 1188 my $e = do {
1189 if (ref($expr) eq 'ARRAY') {
352d74bc 1190 return { -list => [
1191 map $self->_expand_expr($_, $logic, $default), @$expr
bba04f52 1192 ] } if @$expr > 1;
1193 $expr->[0]
1194 } else {
1195 $expr
1196 }
1197 };
1198 return $self->_expand_expr($e, $logic, $default);
8476c6a3 1199}
1200
955e77ca 1201# highly optimized, as it's called way too often
96449e8e 1202sub _quote {
955e77ca 1203 # my ($self, $label) = @_;
96449e8e 1204
955e77ca 1205 return '' unless defined $_[1];
955e77ca 1206 return ${$_[1]} if ref($_[1]) eq 'SCALAR';
d3162b5c 1207 puke 'Identifier cannot be hashref' if ref($_[1]) eq 'HASH';
96449e8e 1208
d3162b5c 1209 unless ($_[0]->{quote_char}) {
1210 if (ref($_[1]) eq 'ARRAY') {
1211 return join($_[0]->{name_sep}||'.', @{$_[1]});
1212 } else {
1213 $_[0]->_assert_pass_injection_guard($_[1]);
1214 return $_[1];
1215 }
1216 }
96449e8e 1217
07d7c35c 1218 my $qref = ref $_[0]->{quote_char};
439834d3 1219 my ($l, $r) =
1220 !$qref ? ($_[0]->{quote_char}, $_[0]->{quote_char})
1221 : ($qref eq 'ARRAY') ? @{$_[0]->{quote_char}}
1222 : puke "Unsupported quote_char format: $_[0]->{quote_char}";
1223
46be4313 1224 my $esc = $_[0]->{escape_char} || $r;
96449e8e 1225
07d7c35c 1226 # parts containing * are naturally unquoted
d3162b5c 1227 return join(
1228 $_[0]->{name_sep}||'',
1229 map +(
1230 $_ eq '*'
1231 ? $_
1232 : do { (my $n = $_) =~ s/(\Q$esc\E|\Q$r\E)/$esc$1/g; $l . $n . $r }
1233 ),
1234 (ref($_[1]) eq 'ARRAY'
1235 ? @{$_[1]}
1236 : (
1237 $_[0]->{name_sep}
1238 ? split (/\Q$_[0]->{name_sep}\E/, $_[1] )
1239 : $_[1]
1240 )
1241 )
955e77ca 1242 );
96449e8e 1243}
1244
1245
1246# Conversion, if applicable
d7c862e0 1247sub _convert {
07d7c35c 1248 #my ($self, $arg) = @_;
7ad12721 1249 if ($_[0]->{convert_where}) {
1250 return $_[0]->_sqlcase($_[0]->{convert_where}) .'(' . $_[1] . ')';
96449e8e 1251 }
07d7c35c 1252 return $_[1];
96449e8e 1253}
1254
1255# And bindtype
d7c862e0 1256sub _bindtype {
07d7c35c 1257 #my ($self, $col, @vals) = @_;
07d7c35c 1258 # called often - tighten code
1259 return $_[0]->{bindtype} eq 'columns'
1260 ? map {[$_[1], $_]} @_[2 .. $#_]
1261 : @_[2 .. $#_]
1262 ;
96449e8e 1263}
1264
fe3ae272 1265# Dies if any element of @bind is not in [colname => value] format
1266# if bindtype is 'columns'.
1267sub _assert_bindval_matches_bindtype {
c94a6c93 1268# my ($self, @bind) = @_;
1269 my $self = shift;
fe3ae272 1270 if ($self->{bindtype} eq 'columns') {
c94a6c93 1271 for (@_) {
1272 if (!defined $_ || ref($_) ne 'ARRAY' || @$_ != 2) {
3a06278c 1273 puke "bindtype 'columns' selected, you need to pass: [column_name => bind_value]"
fe3ae272 1274 }
1275 }
1276 }
1277}
1278
96449e8e 1279sub _join_sql_clauses {
1280 my ($self, $logic, $clauses_aref, $bind_aref) = @_;
1281
1282 if (@$clauses_aref > 1) {
1283 my $join = " " . $self->_sqlcase($logic) . " ";
1284 my $sql = '( ' . join($join, @$clauses_aref) . ' )';
1285 return ($sql, @$bind_aref);
1286 }
1287 elsif (@$clauses_aref) {
1288 return ($clauses_aref->[0], @$bind_aref); # no parentheses
1289 }
1290 else {
1291 return (); # if no SQL, ignore @$bind_aref
1292 }
1293}
1294
1295
1296# Fix SQL case, if so requested
1297sub _sqlcase {
96449e8e 1298 # LDNOTE: if $self->{case} is true, then it contains 'lower', so we
1299 # don't touch the argument ... crooked logic, but let's not change it!
07d7c35c 1300 return $_[0]->{case} ? $_[1] : uc($_[1]);
96449e8e 1301}
1302
1303
1304#======================================================================
1305# DISPATCHING FROM REFKIND
1306#======================================================================
1307
1308sub _refkind {
1309 my ($self, $data) = @_;
96449e8e 1310
955e77ca 1311 return 'UNDEF' unless defined $data;
1312
1313 # blessed objects are treated like scalars
1314 my $ref = (Scalar::Util::blessed $data) ? '' : ref $data;
1315
1316 return 'SCALAR' unless $ref;
1317
1318 my $n_steps = 1;
1319 while ($ref eq 'REF') {
96449e8e 1320 $data = $$data;
955e77ca 1321 $ref = (Scalar::Util::blessed $data) ? '' : ref $data;
1322 $n_steps++ if $ref;
96449e8e 1323 }
1324
848556bc 1325 return ($ref||'SCALAR') . ('REF' x $n_steps);
96449e8e 1326}
1327
1328sub _try_refkind {
1329 my ($self, $data) = @_;
1330 my @try = ($self->_refkind($data));
1331 push @try, 'SCALAR_or_UNDEF' if $try[0] eq 'SCALAR' || $try[0] eq 'UNDEF';
1332 push @try, 'FALLBACK';
955e77ca 1333 return \@try;
96449e8e 1334}
1335
1336sub _METHOD_FOR_refkind {
1337 my ($self, $meth_prefix, $data) = @_;
f39eaa60 1338
1339 my $method;
955e77ca 1340 for (@{$self->_try_refkind($data)}) {
f39eaa60 1341 $method = $self->can($meth_prefix."_".$_)
1342 and last;
1343 }
1344
1345 return $method || puke "cannot dispatch on '$meth_prefix' for ".$self->_refkind($data);
96449e8e 1346}
1347
1348
1349sub _SWITCH_refkind {
1350 my ($self, $data, $dispatch_table) = @_;
1351
f39eaa60 1352 my $coderef;
955e77ca 1353 for (@{$self->_try_refkind($data)}) {
f39eaa60 1354 $coderef = $dispatch_table->{$_}
1355 and last;
1356 }
1357
1358 puke "no dispatch entry for ".$self->_refkind($data)
1359 unless $coderef;
1360
96449e8e 1361 $coderef->();
1362}
1363
1364
1365
1366
1367#======================================================================
1368# VALUES, GENERATE, AUTOLOAD
1369#======================================================================
1370
1371# LDNOTE: original code from nwiger, didn't touch code in that section
1372# I feel the AUTOLOAD stuff should not be the default, it should
1373# only be activated on explicit demand by user.
1374
1375sub values {
1376 my $self = shift;
1377 my $data = shift || return;
1378 puke "Argument to ", __PACKAGE__, "->values must be a \\%hash"
1379 unless ref $data eq 'HASH';
bab725ce 1380
1381 my @all_bind;
ca4f826a 1382 foreach my $k (sort keys %$data) {
bab725ce 1383 my $v = $data->{$k};
1384 $self->_SWITCH_refkind($v, {
9d48860e 1385 ARRAYREF => sub {
bab725ce 1386 if ($self->{array_datatypes}) { # array datatype
1387 push @all_bind, $self->_bindtype($k, $v);
1388 }
1389 else { # literal SQL with bind
1390 my ($sql, @bind) = @$v;
1391 $self->_assert_bindval_matches_bindtype(@bind);
1392 push @all_bind, @bind;
1393 }
1394 },
1395 ARRAYREFREF => sub { # literal SQL with bind
1396 my ($sql, @bind) = @${$v};
1397 $self->_assert_bindval_matches_bindtype(@bind);
1398 push @all_bind, @bind;
1399 },
1400 SCALARREF => sub { # literal SQL without bind
1401 },
1402 SCALAR_or_UNDEF => sub {
1403 push @all_bind, $self->_bindtype($k, $v);
1404 },
1405 });
1406 }
1407
1408 return @all_bind;
96449e8e 1409}
1410
1411sub generate {
1412 my $self = shift;
1413
1414 my(@sql, @sqlq, @sqlv);
1415
1416 for (@_) {
1417 my $ref = ref $_;
1418 if ($ref eq 'HASH') {
1419 for my $k (sort keys %$_) {
1420 my $v = $_->{$k};
1421 my $r = ref $v;
1422 my $label = $self->_quote($k);
1423 if ($r eq 'ARRAY') {
fe3ae272 1424 # literal SQL with bind
1425 my ($sql, @bind) = @$v;
1426 $self->_assert_bindval_matches_bindtype(@bind);
96449e8e 1427 push @sqlq, "$label = $sql";
fe3ae272 1428 push @sqlv, @bind;
96449e8e 1429 } elsif ($r eq 'SCALAR') {
fe3ae272 1430 # literal SQL without bind
96449e8e 1431 push @sqlq, "$label = $$v";
9d48860e 1432 } else {
96449e8e 1433 push @sqlq, "$label = ?";
1434 push @sqlv, $self->_bindtype($k, $v);
1435 }
1436 }
1437 push @sql, $self->_sqlcase('set'), join ', ', @sqlq;
1438 } elsif ($ref eq 'ARRAY') {
1439 # unlike insert(), assume these are ONLY the column names, i.e. for SQL
1440 for my $v (@$_) {
1441 my $r = ref $v;
fe3ae272 1442 if ($r eq 'ARRAY') { # literal SQL with bind
1443 my ($sql, @bind) = @$v;
1444 $self->_assert_bindval_matches_bindtype(@bind);
1445 push @sqlq, $sql;
1446 push @sqlv, @bind;
1447 } elsif ($r eq 'SCALAR') { # literal SQL without bind
96449e8e 1448 # embedded literal SQL
1449 push @sqlq, $$v;
9d48860e 1450 } else {
96449e8e 1451 push @sqlq, '?';
1452 push @sqlv, $v;
1453 }
1454 }
1455 push @sql, '(' . join(', ', @sqlq) . ')';
1456 } elsif ($ref eq 'SCALAR') {
1457 # literal SQL
1458 push @sql, $$_;
1459 } else {
1460 # strings get case twiddled
1461 push @sql, $self->_sqlcase($_);
1462 }
1463 }
1464
1465 my $sql = join ' ', @sql;
1466
1467 # this is pretty tricky
1468 # if ask for an array, return ($stmt, @bind)
1469 # otherwise, s/?/shift @sqlv/ to put it inline
1470 if (wantarray) {
1471 return ($sql, @sqlv);
1472 } else {
1473 1 while $sql =~ s/\?/my $d = shift(@sqlv);
1474 ref $d ? $d->[1] : $d/e;
1475 return $sql;
1476 }
1477}
1478
1479
1480sub DESTROY { 1 }
1481
1482sub AUTOLOAD {
1483 # This allows us to check for a local, then _form, attr
1484 my $self = shift;
1485 my($name) = $AUTOLOAD =~ /.*::(.+)/;
1486 return $self->generate($name, @_);
1487}
1488
14891;
1490
1491
1492
1493__END__
32eab2da 1494
1495=head1 NAME
1496
1497SQL::Abstract - Generate SQL from Perl data structures
1498
1499=head1 SYNOPSIS
1500
1501 use SQL::Abstract;
1502
1503 my $sql = SQL::Abstract->new;
1504
85783f3c 1505 my($stmt, @bind) = $sql->select($source, \@fields, \%where, $order);
32eab2da 1506
1507 my($stmt, @bind) = $sql->insert($table, \%fieldvals || \@values);
1508
1509 my($stmt, @bind) = $sql->update($table, \%fieldvals, \%where);
1510
1511 my($stmt, @bind) = $sql->delete($table, \%where);
1512
1513 # Then, use these in your DBI statements
1514 my $sth = $dbh->prepare($stmt);
1515 $sth->execute(@bind);
1516
1517 # Just generate the WHERE clause
85783f3c 1518 my($stmt, @bind) = $sql->where(\%where, $order);
32eab2da 1519
1520 # Return values in the same order, for hashed queries
1521 # See PERFORMANCE section for more details
1522 my @bind = $sql->values(\%fieldvals);
1523
1524=head1 DESCRIPTION
1525
1526This module was inspired by the excellent L<DBIx::Abstract>.
1527However, in using that module I found that what I really wanted
1528to do was generate SQL, but still retain complete control over my
1529statement handles and use the DBI interface. So, I set out to
1530create an abstract SQL generation module.
1531
1532While based on the concepts used by L<DBIx::Abstract>, there are
1533several important differences, especially when it comes to WHERE
1534clauses. I have modified the concepts used to make the SQL easier
1535to generate from Perl data structures and, IMO, more intuitive.
1536The underlying idea is for this module to do what you mean, based
1537on the data structures you provide it. The big advantage is that
1538you don't have to modify your code every time your data changes,
1539as this module figures it out.
1540
1541To begin with, an SQL INSERT is as easy as just specifying a hash
1542of C<key=value> pairs:
1543
1544 my %data = (
1545 name => 'Jimbo Bobson',
1546 phone => '123-456-7890',
1547 address => '42 Sister Lane',
1548 city => 'St. Louis',
1549 state => 'Louisiana',
1550 );
1551
1552The SQL can then be generated with this:
1553
1554 my($stmt, @bind) = $sql->insert('people', \%data);
1555
1556Which would give you something like this:
1557
1558 $stmt = "INSERT INTO people
1559 (address, city, name, phone, state)
1560 VALUES (?, ?, ?, ?, ?)";
1561 @bind = ('42 Sister Lane', 'St. Louis', 'Jimbo Bobson',
1562 '123-456-7890', 'Louisiana');
1563
1564These are then used directly in your DBI code:
1565
1566 my $sth = $dbh->prepare($stmt);
1567 $sth->execute(@bind);
1568
96449e8e 1569=head2 Inserting and Updating Arrays
1570
1571If your database has array types (like for example Postgres),
1572activate the special option C<< array_datatypes => 1 >>
9d48860e 1573when creating the C<SQL::Abstract> object.
96449e8e 1574Then you may use an arrayref to insert and update database array types:
1575
1576 my $sql = SQL::Abstract->new(array_datatypes => 1);
1577 my %data = (
1578 planets => [qw/Mercury Venus Earth Mars/]
1579 );
9d48860e 1580
96449e8e 1581 my($stmt, @bind) = $sql->insert('solar_system', \%data);
1582
1583This results in:
1584
1585 $stmt = "INSERT INTO solar_system (planets) VALUES (?)"
1586
1587 @bind = (['Mercury', 'Venus', 'Earth', 'Mars']);
1588
1589
1590=head2 Inserting and Updating SQL
1591
1592In order to apply SQL functions to elements of your C<%data> you may
1593specify a reference to an arrayref for the given hash value. For example,
1594if you need to execute the Oracle C<to_date> function on a value, you can
1595say something like this:
32eab2da 1596
1597 my %data = (
1598 name => 'Bill',
3ae1c5e2 1599 date_entered => \[ "to_date(?,'MM/DD/YYYY')", "03/02/2003" ],
9d48860e 1600 );
32eab2da 1601
1602The first value in the array is the actual SQL. Any other values are
1603optional and would be included in the bind values array. This gives
1604you:
1605
1606 my($stmt, @bind) = $sql->insert('people', \%data);
1607
9d48860e 1608 $stmt = "INSERT INTO people (name, date_entered)
32eab2da 1609 VALUES (?, to_date(?,'MM/DD/YYYY'))";
1610 @bind = ('Bill', '03/02/2003');
1611
1612An UPDATE is just as easy, all you change is the name of the function:
1613
1614 my($stmt, @bind) = $sql->update('people', \%data);
1615
1616Notice that your C<%data> isn't touched; the module will generate
1617the appropriately quirky SQL for you automatically. Usually you'll
1618want to specify a WHERE clause for your UPDATE, though, which is
1619where handling C<%where> hashes comes in handy...
1620
96449e8e 1621=head2 Complex where statements
1622
32eab2da 1623This module can generate pretty complicated WHERE statements
1624easily. For example, simple C<key=value> pairs are taken to mean
1625equality, and if you want to see if a field is within a set
1626of values, you can use an arrayref. Let's say we wanted to
1627SELECT some data based on this criteria:
1628
1629 my %where = (
1630 requestor => 'inna',
1631 worker => ['nwiger', 'rcwe', 'sfz'],
1632 status => { '!=', 'completed' }
1633 );
1634
1635 my($stmt, @bind) = $sql->select('tickets', '*', \%where);
1636
1637The above would give you something like this:
1638
1639 $stmt = "SELECT * FROM tickets WHERE
1640 ( requestor = ? ) AND ( status != ? )
1641 AND ( worker = ? OR worker = ? OR worker = ? )";
1642 @bind = ('inna', 'completed', 'nwiger', 'rcwe', 'sfz');
1643
1644Which you could then use in DBI code like so:
1645
1646 my $sth = $dbh->prepare($stmt);
1647 $sth->execute(@bind);
1648
1649Easy, eh?
1650
0da0fe34 1651=head1 METHODS
32eab2da 1652
13cc86af 1653The methods are simple. There's one for every major SQL operation,
32eab2da 1654and a constructor you use first. The arguments are specified in a
13cc86af 1655similar order for each method (table, then fields, then a where
32eab2da 1656clause) to try and simplify things.
1657
32eab2da 1658=head2 new(option => 'value')
1659
1660The C<new()> function takes a list of options and values, and returns
1661a new B<SQL::Abstract> object which can then be used to generate SQL
1662through the methods below. The options accepted are:
1663
1664=over
1665
1666=item case
1667
1668If set to 'lower', then SQL will be generated in all lowercase. By
1669default SQL is generated in "textbook" case meaning something like:
1670
1671 SELECT a_field FROM a_table WHERE some_field LIKE '%someval%'
1672
96449e8e 1673Any setting other than 'lower' is ignored.
1674
32eab2da 1675=item cmp
1676
1677This determines what the default comparison operator is. By default
1678it is C<=>, meaning that a hash like this:
1679
1680 %where = (name => 'nwiger', email => 'nate@wiger.org');
1681
1682Will generate SQL like this:
1683
1684 WHERE name = 'nwiger' AND email = 'nate@wiger.org'
1685
1686However, you may want loose comparisons by default, so if you set
1687C<cmp> to C<like> you would get SQL such as:
1688
1689 WHERE name like 'nwiger' AND email like 'nate@wiger.org'
1690
3af02ccb 1691You can also override the comparison on an individual basis - see
32eab2da 1692the huge section on L</"WHERE CLAUSES"> at the bottom.
1693
96449e8e 1694=item sqltrue, sqlfalse
1695
1696Expressions for inserting boolean values within SQL statements.
6e0c6552 1697By default these are C<1=1> and C<1=0>. They are used
1698by the special operators C<-in> and C<-not_in> for generating
1699correct SQL even when the argument is an empty array (see below).
96449e8e 1700
32eab2da 1701=item logic
1702
1703This determines the default logical operator for multiple WHERE
7cac25e6 1704statements in arrays or hashes. If absent, the default logic is "or"
1705for arrays, and "and" for hashes. This means that a WHERE
32eab2da 1706array of the form:
1707
1708 @where = (
9d48860e 1709 event_date => {'>=', '2/13/99'},
1710 event_date => {'<=', '4/24/03'},
32eab2da 1711 );
1712
7cac25e6 1713will generate SQL like this:
32eab2da 1714
1715 WHERE event_date >= '2/13/99' OR event_date <= '4/24/03'
1716
1717This is probably not what you want given this query, though (look
1718at the dates). To change the "OR" to an "AND", simply specify:
1719
1720 my $sql = SQL::Abstract->new(logic => 'and');
1721
1722Which will change the above C<WHERE> to:
1723
1724 WHERE event_date >= '2/13/99' AND event_date <= '4/24/03'
1725
96449e8e 1726The logic can also be changed locally by inserting
be21dde3 1727a modifier in front of an arrayref:
96449e8e 1728
9d48860e 1729 @where = (-and => [event_date => {'>=', '2/13/99'},
7cac25e6 1730 event_date => {'<=', '4/24/03'} ]);
96449e8e 1731
1732See the L</"WHERE CLAUSES"> section for explanations.
1733
32eab2da 1734=item convert
1735
1736This will automatically convert comparisons using the specified SQL
1737function for both column and value. This is mostly used with an argument
1738of C<upper> or C<lower>, so that the SQL will have the effect of
1739case-insensitive "searches". For example, this:
1740
1741 $sql = SQL::Abstract->new(convert => 'upper');
1742 %where = (keywords => 'MaKe iT CAse inSeNSItive');
1743
1744Will turn out the following SQL:
1745
1746 WHERE upper(keywords) like upper('MaKe iT CAse inSeNSItive')
1747
1748The conversion can be C<upper()>, C<lower()>, or any other SQL function
1749that can be applied symmetrically to fields (actually B<SQL::Abstract> does
1750not validate this option; it will just pass through what you specify verbatim).
1751
1752=item bindtype
1753
1754This is a kludge because many databases suck. For example, you can't
1755just bind values using DBI's C<execute()> for Oracle C<CLOB> or C<BLOB> fields.
1756Instead, you have to use C<bind_param()>:
1757
1758 $sth->bind_param(1, 'reg data');
1759 $sth->bind_param(2, $lots, {ora_type => ORA_CLOB});
1760
1761The problem is, B<SQL::Abstract> will normally just return a C<@bind> array,
1762which loses track of which field each slot refers to. Fear not.
1763
1764If you specify C<bindtype> in new, you can determine how C<@bind> is returned.
1765Currently, you can specify either C<normal> (default) or C<columns>. If you
1766specify C<columns>, you will get an array that looks like this:
1767
1768 my $sql = SQL::Abstract->new(bindtype => 'columns');
1769 my($stmt, @bind) = $sql->insert(...);
1770
1771 @bind = (
1772 [ 'column1', 'value1' ],
1773 [ 'column2', 'value2' ],
1774 [ 'column3', 'value3' ],
1775 );
1776
1777You can then iterate through this manually, using DBI's C<bind_param()>.
e3f9dff4 1778
32eab2da 1779 $sth->prepare($stmt);
1780 my $i = 1;
1781 for (@bind) {
1782 my($col, $data) = @$_;
1783 if ($col eq 'details' || $col eq 'comments') {
1784 $sth->bind_param($i, $data, {ora_type => ORA_CLOB});
1785 } elsif ($col eq 'image') {
1786 $sth->bind_param($i, $data, {ora_type => ORA_BLOB});
1787 } else {
1788 $sth->bind_param($i, $data);
1789 }
1790 $i++;
1791 }
1792 $sth->execute; # execute without @bind now
1793
1794Now, why would you still use B<SQL::Abstract> if you have to do this crap?
1795Basically, the advantage is still that you don't have to care which fields
1796are or are not included. You could wrap that above C<for> loop in a simple
1797sub called C<bind_fields()> or something and reuse it repeatedly. You still
1798get a layer of abstraction over manual SQL specification.
1799
3ae1c5e2 1800Note that if you set L</bindtype> to C<columns>, the C<\[ $sql, @bind ]>
deb148a2 1801construct (see L</Literal SQL with placeholders and bind values (subqueries)>)
1802will expect the bind values in this format.
1803
32eab2da 1804=item quote_char
1805
1806This is the character that a table or column name will be quoted
9d48860e 1807with. By default this is an empty string, but you could set it to
32eab2da 1808the character C<`>, to generate SQL like this:
1809
1810 SELECT `a_field` FROM `a_table` WHERE `some_field` LIKE '%someval%'
1811
96449e8e 1812Alternatively, you can supply an array ref of two items, the first being the left
1813hand quote character, and the second the right hand quote character. For
1814example, you could supply C<['[',']']> for SQL Server 2000 compliant quotes
1815that generates SQL like this:
1816
1817 SELECT [a_field] FROM [a_table] WHERE [some_field] LIKE '%someval%'
1818
9d48860e 1819Quoting is useful if you have tables or columns names that are reserved
96449e8e 1820words in your database's SQL dialect.
32eab2da 1821
46be4313 1822=item escape_char
1823
1824This is the character that will be used to escape L</quote_char>s appearing
1825in an identifier before it has been quoted.
1826
80790166 1827The parameter default in case of a single L</quote_char> character is the quote
46be4313 1828character itself.
1829
1830When opening-closing-style quoting is used (L</quote_char> is an arrayref)
9de2bd86 1831this parameter defaults to the B<closing (right)> L</quote_char>. Occurrences
46be4313 1832of the B<opening (left)> L</quote_char> within the identifier are currently left
1833untouched. The default for opening-closing-style quotes may change in future
1834versions, thus you are B<strongly encouraged> to specify the escape character
1835explicitly.
1836
32eab2da 1837=item name_sep
1838
1839This is the character that separates a table and column name. It is
1840necessary to specify this when the C<quote_char> option is selected,
1841so that tables and column names can be individually quoted like this:
1842
1843 SELECT `table`.`one_field` FROM `table` WHERE `table`.`other_field` = 1
1844
b6251592 1845=item injection_guard
1846
1847A regular expression C<qr/.../> that is applied to any C<-function> and unquoted
1848column name specified in a query structure. This is a safety mechanism to avoid
1849injection attacks when mishandling user input e.g.:
1850
1851 my %condition_as_column_value_pairs = get_values_from_user();
1852 $sqla->select( ... , \%condition_as_column_value_pairs );
1853
1854If the expression matches an exception is thrown. Note that literal SQL
1855supplied via C<\'...'> or C<\['...']> is B<not> checked in any way.
1856
1857Defaults to checking for C<;> and the C<GO> keyword (TransactSQL)
1858
96449e8e 1859=item array_datatypes
32eab2da 1860
9d48860e 1861When this option is true, arrayrefs in INSERT or UPDATE are
1862interpreted as array datatypes and are passed directly
96449e8e 1863to the DBI layer.
1864When this option is false, arrayrefs are interpreted
1865as literal SQL, just like refs to arrayrefs
1866(but this behavior is for backwards compatibility; when writing
1867new queries, use the "reference to arrayref" syntax
1868for literal SQL).
32eab2da 1869
32eab2da 1870
96449e8e 1871=item special_ops
32eab2da 1872
9d48860e 1873Takes a reference to a list of "special operators"
96449e8e 1874to extend the syntax understood by L<SQL::Abstract>.
1875See section L</"SPECIAL OPERATORS"> for details.
32eab2da 1876
59f23b3d 1877=item unary_ops
1878
9d48860e 1879Takes a reference to a list of "unary operators"
59f23b3d 1880to extend the syntax understood by L<SQL::Abstract>.
1881See section L</"UNARY OPERATORS"> for details.
1882
32eab2da 1883
32eab2da 1884
96449e8e 1885=back
32eab2da 1886
02288357 1887=head2 insert($table, \@values || \%fieldvals, \%options)
32eab2da 1888
1889This is the simplest function. You simply give it a table name
1890and either an arrayref of values or hashref of field/value pairs.
1891It returns an SQL INSERT statement and a list of bind values.
96449e8e 1892See the sections on L</"Inserting and Updating Arrays"> and
1893L</"Inserting and Updating SQL"> for information on how to insert
1894with those data types.
32eab2da 1895
02288357 1896The optional C<\%options> hash reference may contain additional
1897options to generate the insert SQL. Currently supported options
1898are:
1899
1900=over 4
1901
1902=item returning
1903
1904Takes either a scalar of raw SQL fields, or an array reference of
1905field names, and adds on an SQL C<RETURNING> statement at the end.
1906This allows you to return data generated by the insert statement
1907(such as row IDs) without performing another C<SELECT> statement.
1908Note, however, this is not part of the SQL standard and may not
1909be supported by all database engines.
1910
1911=back
1912
95904db5 1913=head2 update($table, \%fieldvals, \%where, \%options)
32eab2da 1914
1915This takes a table, hashref of field/value pairs, and an optional
86298391 1916hashref L<WHERE clause|/WHERE CLAUSES>. It returns an SQL UPDATE function and a list
32eab2da 1917of bind values.
96449e8e 1918See the sections on L</"Inserting and Updating Arrays"> and
1919L</"Inserting and Updating SQL"> for information on how to insert
1920with those data types.
32eab2da 1921
95904db5 1922The optional C<\%options> hash reference may contain additional
1923options to generate the update SQL. Currently supported options
1924are:
1925
1926=over 4
1927
1928=item returning
1929
1930See the C<returning> option to
1931L<insert|/insert($table, \@values || \%fieldvals, \%options)>.
1932
1933=back
1934
96449e8e 1935=head2 select($source, $fields, $where, $order)
32eab2da 1936
9d48860e 1937This returns a SQL SELECT statement and associated list of bind values, as
be21dde3 1938specified by the arguments:
32eab2da 1939
96449e8e 1940=over
32eab2da 1941
96449e8e 1942=item $source
32eab2da 1943
9d48860e 1944Specification of the 'FROM' part of the statement.
96449e8e 1945The argument can be either a plain scalar (interpreted as a table
1946name, will be quoted), or an arrayref (interpreted as a list
1947of table names, joined by commas, quoted), or a scalarref
063097a3 1948(literal SQL, not quoted).
32eab2da 1949
96449e8e 1950=item $fields
32eab2da 1951
9d48860e 1952Specification of the list of fields to retrieve from
96449e8e 1953the source.
1954The argument can be either an arrayref (interpreted as a list
9d48860e 1955of field names, will be joined by commas and quoted), or a
96449e8e 1956plain scalar (literal SQL, not quoted).
521647e7 1957Please observe that this API is not as flexible as that of
1958the first argument C<$source>, for backwards compatibility reasons.
32eab2da 1959
96449e8e 1960=item $where
32eab2da 1961
96449e8e 1962Optional argument to specify the WHERE part of the query.
1963The argument is most often a hashref, but can also be
9d48860e 1964an arrayref or plain scalar --
96449e8e 1965see section L<WHERE clause|/"WHERE CLAUSES"> for details.
32eab2da 1966
96449e8e 1967=item $order
32eab2da 1968
96449e8e 1969Optional argument to specify the ORDER BY part of the query.
9d48860e 1970The argument can be a scalar, a hashref or an arrayref
96449e8e 1971-- see section L<ORDER BY clause|/"ORDER BY CLAUSES">
1972for details.
32eab2da 1973
96449e8e 1974=back
32eab2da 1975
32eab2da 1976
85327cd5 1977=head2 delete($table, \%where, \%options)
32eab2da 1978
86298391 1979This takes a table name and optional hashref L<WHERE clause|/WHERE CLAUSES>.
32eab2da 1980It returns an SQL DELETE statement and list of bind values.
1981
85327cd5 1982The optional C<\%options> hash reference may contain additional
1983options to generate the delete SQL. Currently supported options
1984are:
1985
1986=over 4
1987
1988=item returning
1989
1990See the C<returning> option to
1991L<insert|/insert($table, \@values || \%fieldvals, \%options)>.
1992
1993=back
1994
85783f3c 1995=head2 where(\%where, $order)
32eab2da 1996
1997This is used to generate just the WHERE clause. For example,
1998if you have an arbitrary data structure and know what the
1999rest of your SQL is going to look like, but want an easy way
2000to produce a WHERE clause, use this. It returns an SQL WHERE
2001clause and list of bind values.
2002
32eab2da 2003
2004=head2 values(\%data)
2005
2006This just returns the values from the hash C<%data>, in the same
2007order that would be returned from any of the other above queries.
2008Using this allows you to markedly speed up your queries if you
2009are affecting lots of rows. See below under the L</"PERFORMANCE"> section.
2010
32eab2da 2011=head2 generate($any, 'number', $of, \@data, $struct, \%types)
2012
2013Warning: This is an experimental method and subject to change.
2014
2015This returns arbitrarily generated SQL. It's a really basic shortcut.
2016It will return two different things, depending on return context:
2017
2018 my($stmt, @bind) = $sql->generate('create table', \$table, \@fields);
2019 my $stmt_and_val = $sql->generate('create table', \$table, \@fields);
2020
2021These would return the following:
2022
2023 # First calling form
2024 $stmt = "CREATE TABLE test (?, ?)";
2025 @bind = (field1, field2);
2026
2027 # Second calling form
2028 $stmt_and_val = "CREATE TABLE test (field1, field2)";
2029
2030Depending on what you're trying to do, it's up to you to choose the correct
2031format. In this example, the second form is what you would want.
2032
2033By the same token:
2034
2035 $sql->generate('alter session', { nls_date_format => 'MM/YY' });
2036
2037Might give you:
2038
2039 ALTER SESSION SET nls_date_format = 'MM/YY'
2040
2041You get the idea. Strings get their case twiddled, but everything
2042else remains verbatim.
2043
0da0fe34 2044=head1 EXPORTABLE FUNCTIONS
2045
2046=head2 is_plain_value
2047
2048Determines if the supplied argument is a plain value as understood by this
2049module:
2050
2051=over
2052
2053=item * The value is C<undef>
2054
2055=item * The value is a non-reference
2056
2057=item * The value is an object with stringification overloading
2058
2059=item * The value is of the form C<< { -value => $anything } >>
2060
2061=back
2062
9de2bd86 2063On failure returns C<undef>, on success returns a B<scalar> reference
966200cc 2064to the original supplied argument.
0da0fe34 2065
843a94b5 2066=over
2067
2068=item * Note
2069
2070The stringification overloading detection is rather advanced: it takes
2071into consideration not only the presence of a C<""> overload, but if that
2072fails also checks for enabled
2073L<autogenerated versions of C<"">|overload/Magic Autogeneration>, based
2074on either C<0+> or C<bool>.
2075
2076Unfortunately testing in the field indicates that this
2077detection B<< may tickle a latent bug in perl versions before 5.018 >>,
2078but only when very large numbers of stringifying objects are involved.
2079At the time of writing ( Sep 2014 ) there is no clear explanation of
2080the direct cause, nor is there a manageably small test case that reliably
2081reproduces the problem.
2082
2083If you encounter any of the following exceptions in B<random places within
2084your application stack> - this module may be to blame:
2085
2086 Operation "ne": no method found,
2087 left argument in overloaded package <something>,
2088 right argument in overloaded package <something>
2089
2090or perhaps even
2091
2092 Stub found while resolving method "???" overloading """" in package <something>
2093
2094If you fall victim to the above - please attempt to reduce the problem
2095to something that could be sent to the L<SQL::Abstract developers
1f490ae4 2096|DBIx::Class/GETTING HELP/SUPPORT>
843a94b5 2097(either publicly or privately). As a workaround in the meantime you can
2098set C<$ENV{SQLA_ISVALUE_IGNORE_AUTOGENERATED_STRINGIFICATION}> to a true
2099value, which will most likely eliminate your problem (at the expense of
2100not being able to properly detect exotic forms of stringification).
2101
2102This notice and environment variable will be removed in a future version,
2103as soon as the underlying problem is found and a reliable workaround is
2104devised.
2105
2106=back
2107
0da0fe34 2108=head2 is_literal_value
2109
2110Determines if the supplied argument is a literal value as understood by this
2111module:
2112
2113=over
2114
2115=item * C<\$sql_string>
2116
2117=item * C<\[ $sql_string, @bind_values ]>
2118
0da0fe34 2119=back
2120
9de2bd86 2121On failure returns C<undef>, on success returns an B<array> reference
966200cc 2122containing the unpacked version of the supplied literal SQL and bind values.
0da0fe34 2123
32eab2da 2124=head1 WHERE CLAUSES
2125
96449e8e 2126=head2 Introduction
2127
32eab2da 2128This module uses a variation on the idea from L<DBIx::Abstract>. It
2129is B<NOT>, repeat I<not> 100% compatible. B<The main logic of this
2130module is that things in arrays are OR'ed, and things in hashes
2131are AND'ed.>
2132
2133The easiest way to explain is to show lots of examples. After
2134each C<%where> hash shown, it is assumed you used:
2135
2136 my($stmt, @bind) = $sql->where(\%where);
2137
2138However, note that the C<%where> hash can be used directly in any
2139of the other functions as well, as described above.
2140
96449e8e 2141=head2 Key-value pairs
2142
32eab2da 2143So, let's get started. To begin, a simple hash:
2144
2145 my %where = (
2146 user => 'nwiger',
2147 status => 'completed'
2148 );
2149
2150Is converted to SQL C<key = val> statements:
2151
2152 $stmt = "WHERE user = ? AND status = ?";
2153 @bind = ('nwiger', 'completed');
2154
2155One common thing I end up doing is having a list of values that
2156a field can be in. To do this, simply specify a list inside of
2157an arrayref:
2158
2159 my %where = (
2160 user => 'nwiger',
2161 status => ['assigned', 'in-progress', 'pending'];
2162 );
2163
2164This simple code will create the following:
9d48860e 2165
32eab2da 2166 $stmt = "WHERE user = ? AND ( status = ? OR status = ? OR status = ? )";
2167 @bind = ('nwiger', 'assigned', 'in-progress', 'pending');
2168
9d48860e 2169A field associated to an empty arrayref will be considered a
7cac25e6 2170logical false and will generate 0=1.
8a68b5be 2171
b864ba9b 2172=head2 Tests for NULL values
2173
2174If the value part is C<undef> then this is converted to SQL <IS NULL>
2175
2176 my %where = (
2177 user => 'nwiger',
2178 status => undef,
2179 );
2180
2181becomes:
2182
2183 $stmt = "WHERE user = ? AND status IS NULL";
2184 @bind = ('nwiger');
2185
e9614080 2186To test if a column IS NOT NULL:
2187
2188 my %where = (
2189 user => 'nwiger',
2190 status => { '!=', undef },
2191 );
cc422895 2192
6e0c6552 2193=head2 Specific comparison operators
96449e8e 2194
32eab2da 2195If you want to specify a different type of operator for your comparison,
2196you can use a hashref for a given column:
2197
2198 my %where = (
2199 user => 'nwiger',
2200 status => { '!=', 'completed' }
2201 );
2202
2203Which would generate:
2204
2205 $stmt = "WHERE user = ? AND status != ?";
2206 @bind = ('nwiger', 'completed');
2207
2208To test against multiple values, just enclose the values in an arrayref:
2209
96449e8e 2210 status => { '=', ['assigned', 'in-progress', 'pending'] };
2211
f2d5020d 2212Which would give you:
96449e8e 2213
2214 "WHERE status = ? OR status = ? OR status = ?"
2215
2216
2217The hashref can also contain multiple pairs, in which case it is expanded
32eab2da 2218into an C<AND> of its elements:
2219
2220 my %where = (
2221 user => 'nwiger',
2222 status => { '!=', 'completed', -not_like => 'pending%' }
2223 );
2224
2225 # Or more dynamically, like from a form
2226 $where{user} = 'nwiger';
2227 $where{status}{'!='} = 'completed';
2228 $where{status}{'-not_like'} = 'pending%';
2229
2230 # Both generate this
2231 $stmt = "WHERE user = ? AND status != ? AND status NOT LIKE ?";
2232 @bind = ('nwiger', 'completed', 'pending%');
2233
96449e8e 2234
32eab2da 2235To get an OR instead, you can combine it with the arrayref idea:
2236
2237 my %where => (
2238 user => 'nwiger',
1a6f2a03 2239 priority => [ { '=', 2 }, { '>', 5 } ]
32eab2da 2240 );
2241
2242Which would generate:
2243
1a6f2a03 2244 $stmt = "WHERE ( priority = ? OR priority > ? ) AND user = ?";
2245 @bind = ('2', '5', 'nwiger');
32eab2da 2246
44b9e502 2247If you want to include literal SQL (with or without bind values), just use a
13cc86af 2248scalar reference or reference to an arrayref as the value:
44b9e502 2249
2250 my %where = (
2251 date_entered => { '>' => \["to_date(?, 'MM/DD/YYYY')", "11/26/2008"] },
2252 date_expires => { '<' => \"now()" }
2253 );
2254
2255Which would generate:
2256
13cc86af 2257 $stmt = "WHERE date_entered > to_date(?, 'MM/DD/YYYY') AND date_expires < now()";
44b9e502 2258 @bind = ('11/26/2008');
2259
96449e8e 2260
2261=head2 Logic and nesting operators
2262
2263In the example above,
2264there is a subtle trap if you want to say something like
32eab2da 2265this (notice the C<AND>):
2266
2267 WHERE priority != ? AND priority != ?
2268
2269Because, in Perl you I<can't> do this:
2270
13cc86af 2271 priority => { '!=' => 2, '!=' => 1 }
32eab2da 2272
2273As the second C<!=> key will obliterate the first. The solution
2274is to use the special C<-modifier> form inside an arrayref:
2275
9d48860e 2276 priority => [ -and => {'!=', 2},
96449e8e 2277 {'!=', 1} ]
2278
32eab2da 2279
2280Normally, these would be joined by C<OR>, but the modifier tells it
2281to use C<AND> instead. (Hint: You can use this in conjunction with the
2282C<logic> option to C<new()> in order to change the way your queries
2283work by default.) B<Important:> Note that the C<-modifier> goes
2284B<INSIDE> the arrayref, as an extra first element. This will
2285B<NOT> do what you think it might:
2286
2287 priority => -and => [{'!=', 2}, {'!=', 1}] # WRONG!
2288
2289Here is a quick list of equivalencies, since there is some overlap:
2290
2291 # Same
2292 status => {'!=', 'completed', 'not like', 'pending%' }
2293 status => [ -and => {'!=', 'completed'}, {'not like', 'pending%'}]
2294
2295 # Same
2296 status => {'=', ['assigned', 'in-progress']}
2297 status => [ -or => {'=', 'assigned'}, {'=', 'in-progress'}]
2298 status => [ {'=', 'assigned'}, {'=', 'in-progress'} ]
2299
e3f9dff4 2300
2301
be21dde3 2302=head2 Special operators: IN, BETWEEN, etc.
96449e8e 2303
32eab2da 2304You can also use the hashref format to compare a list of fields using the
2305C<IN> comparison operator, by specifying the list as an arrayref:
2306
2307 my %where = (
2308 status => 'completed',
2309 reportid => { -in => [567, 2335, 2] }
2310 );
2311
2312Which would generate:
2313
2314 $stmt = "WHERE status = ? AND reportid IN (?,?,?)";
2315 @bind = ('completed', '567', '2335', '2');
2316
9d48860e 2317The reverse operator C<-not_in> generates SQL C<NOT IN> and is used in
96449e8e 2318the same way.
2319
6e0c6552 2320If the argument to C<-in> is an empty array, 'sqlfalse' is generated
be21dde3 2321(by default: C<1=0>). Similarly, C<< -not_in => [] >> generates
2322'sqltrue' (by default: C<1=1>).
6e0c6552 2323
e41c3bdd 2324In addition to the array you can supply a chunk of literal sql or
2325literal sql with bind:
6e0c6552 2326
e41c3bdd 2327 my %where = {
2328 customer => { -in => \[
2329 'SELECT cust_id FROM cust WHERE balance > ?',
2330 2000,
2331 ],
2332 status => { -in => \'SELECT status_codes FROM states' },
2333 };
6e0c6552 2334
e41c3bdd 2335would generate:
2336
2337 $stmt = "WHERE (
2338 customer IN ( SELECT cust_id FROM cust WHERE balance > ? )
2339 AND status IN ( SELECT status_codes FROM states )
2340 )";
2341 @bind = ('2000');
2342
0dfd2442 2343Finally, if the argument to C<-in> is not a reference, it will be
2344treated as a single-element array.
e41c3bdd 2345
2346Another pair of operators is C<-between> and C<-not_between>,
96449e8e 2347used with an arrayref of two values:
32eab2da 2348
2349 my %where = (
2350 user => 'nwiger',
2351 completion_date => {
2352 -not_between => ['2002-10-01', '2003-02-06']
2353 }
2354 );
2355
2356Would give you:
2357
2358 WHERE user = ? AND completion_date NOT BETWEEN ( ? AND ? )
2359
e41c3bdd 2360Just like with C<-in> all plausible combinations of literal SQL
2361are possible:
2362
2363 my %where = {
2364 start0 => { -between => [ 1, 2 ] },
2365 start1 => { -between => \["? AND ?", 1, 2] },
2366 start2 => { -between => \"lower(x) AND upper(y)" },
9d48860e 2367 start3 => { -between => [
e41c3bdd 2368 \"lower(x)",
2369 \["upper(?)", 'stuff' ],
2370 ] },
2371 };
2372
2373Would give you:
2374
2375 $stmt = "WHERE (
2376 ( start0 BETWEEN ? AND ? )
2377 AND ( start1 BETWEEN ? AND ? )
2378 AND ( start2 BETWEEN lower(x) AND upper(y) )
2379 AND ( start3 BETWEEN lower(x) AND upper(?) )
2380 )";
2381 @bind = (1, 2, 1, 2, 'stuff');
2382
2383
9d48860e 2384These are the two builtin "special operators"; but the
be21dde3 2385list can be expanded: see section L</"SPECIAL OPERATORS"> below.
96449e8e 2386
59f23b3d 2387=head2 Unary operators: bool
97a920ef 2388
2389If you wish to test against boolean columns or functions within your
2390database you can use the C<-bool> and C<-not_bool> operators. For
2391example to test the column C<is_user> being true and the column
827bb0eb 2392C<is_enabled> being false you would use:-
97a920ef 2393
2394 my %where = (
2395 -bool => 'is_user',
2396 -not_bool => 'is_enabled',
2397 );
2398
2399Would give you:
2400
277b5d3f 2401 WHERE is_user AND NOT is_enabled
97a920ef 2402
0b604e9d 2403If a more complex combination is required, testing more conditions,
2404then you should use the and/or operators:-
2405
2406 my %where = (
2407 -and => [
2408 -bool => 'one',
23401b81 2409 -not_bool => { two=> { -rlike => 'bar' } },
2410 -not_bool => { three => [ { '=', 2 }, { '>', 5 } ] },
0b604e9d 2411 ],
2412 );
2413
2414Would give you:
2415
23401b81 2416 WHERE
2417 one
2418 AND
2419 (NOT two RLIKE ?)
2420 AND
2421 (NOT ( three = ? OR three > ? ))
97a920ef 2422
2423
107b72f1 2424=head2 Nested conditions, -and/-or prefixes
96449e8e 2425
32eab2da 2426So far, we've seen how multiple conditions are joined with a top-level
2427C<AND>. We can change this by putting the different conditions we want in
2428hashes and then putting those hashes in an array. For example:
2429
2430 my @where = (
2431 {
2432 user => 'nwiger',
2433 status => { -like => ['pending%', 'dispatched'] },
2434 },
2435 {
2436 user => 'robot',
2437 status => 'unassigned',
2438 }
2439 );
2440
2441This data structure would create the following:
2442
2443 $stmt = "WHERE ( user = ? AND ( status LIKE ? OR status LIKE ? ) )
2444 OR ( user = ? AND status = ? ) )";
2445 @bind = ('nwiger', 'pending', 'dispatched', 'robot', 'unassigned');
2446
107b72f1 2447
48d9f5f8 2448Clauses in hashrefs or arrayrefs can be prefixed with an C<-and> or C<-or>
be21dde3 2449to change the logic inside:
32eab2da 2450
2451 my @where = (
2452 -and => [
2453 user => 'nwiger',
48d9f5f8 2454 [
2455 -and => [ workhrs => {'>', 20}, geo => 'ASIA' ],
2456 -or => { workhrs => {'<', 50}, geo => 'EURO' },
32eab2da 2457 ],
2458 ],
2459 );
2460
2461That would yield:
2462
13cc86af 2463 $stmt = "WHERE ( user = ?
2464 AND ( ( workhrs > ? AND geo = ? )
2465 OR ( workhrs < ? OR geo = ? ) ) )";
2466 @bind = ('nwiger', '20', 'ASIA', '50', 'EURO');
107b72f1 2467
cc422895 2468=head3 Algebraic inconsistency, for historical reasons
107b72f1 2469
7cac25e6 2470C<Important note>: when connecting several conditions, the C<-and->|C<-or>
2471operator goes C<outside> of the nested structure; whereas when connecting
2472several constraints on one column, the C<-and> operator goes
be21dde3 2473C<inside> the arrayref. Here is an example combining both features:
7cac25e6 2474
2475 my @where = (
2476 -and => [a => 1, b => 2],
2477 -or => [c => 3, d => 4],
2478 e => [-and => {-like => 'foo%'}, {-like => '%bar'} ]
2479 )
2480
2481yielding
2482
9d48860e 2483 WHERE ( ( ( a = ? AND b = ? )
2484 OR ( c = ? OR d = ? )
7cac25e6 2485 OR ( e LIKE ? AND e LIKE ? ) ) )
2486
107b72f1 2487This difference in syntax is unfortunate but must be preserved for
be21dde3 2488historical reasons. So be careful: the two examples below would
107b72f1 2489seem algebraically equivalent, but they are not
2490
a948b1fe 2491 { col => [ -and =>
2492 { -like => 'foo%' },
2493 { -like => '%bar' },
2494 ] }
be21dde3 2495 # yields: WHERE ( ( col LIKE ? AND col LIKE ? ) )
107b72f1 2496
a948b1fe 2497 [ -and =>
2498 { col => { -like => 'foo%' } },
2499 { col => { -like => '%bar' } },
2500 ]
be21dde3 2501 # yields: WHERE ( ( col LIKE ? OR col LIKE ? ) )
107b72f1 2502
7cac25e6 2503
cc422895 2504=head2 Literal SQL and value type operators
96449e8e 2505
cc422895 2506The basic premise of SQL::Abstract is that in WHERE specifications the "left
2507side" is a column name and the "right side" is a value (normally rendered as
2508a placeholder). This holds true for both hashrefs and arrayref pairs as you
2509see in the L</WHERE CLAUSES> examples above. Sometimes it is necessary to
2510alter this behavior. There are several ways of doing so.
e9614080 2511
cc422895 2512=head3 -ident
2513
2514This is a virtual operator that signals the string to its right side is an
2515identifier (a column name) and not a value. For example to compare two
2516columns you would write:
32eab2da 2517
e9614080 2518 my %where = (
2519 priority => { '<', 2 },
cc422895 2520 requestor => { -ident => 'submitter' },
e9614080 2521 );
2522
2523which creates:
2524
2525 $stmt = "WHERE priority < ? AND requestor = submitter";
2526 @bind = ('2');
2527
cc422895 2528If you are maintaining legacy code you may see a different construct as
2529described in L</Deprecated usage of Literal SQL>, please use C<-ident> in new
2530code.
2531
2532=head3 -value
e9614080 2533
cc422895 2534This is a virtual operator that signals that the construct to its right side
2535is a value to be passed to DBI. This is for example necessary when you want
2536to write a where clause against an array (for RDBMS that support such
2537datatypes). For example:
e9614080 2538
32eab2da 2539 my %where = (
cc422895 2540 array => { -value => [1, 2, 3] }
32eab2da 2541 );
2542
cc422895 2543will result in:
32eab2da 2544
cc422895 2545 $stmt = 'WHERE array = ?';
2546 @bind = ([1, 2, 3]);
32eab2da 2547
cc422895 2548Note that if you were to simply say:
32eab2da 2549
2550 my %where = (
cc422895 2551 array => [1, 2, 3]
32eab2da 2552 );
2553
3af02ccb 2554the result would probably not be what you wanted:
cc422895 2555
2556 $stmt = 'WHERE array = ? OR array = ? OR array = ?';
2557 @bind = (1, 2, 3);
2558
2559=head3 Literal SQL
96449e8e 2560
cc422895 2561Finally, sometimes only literal SQL will do. To include a random snippet
2562of SQL verbatim, you specify it as a scalar reference. Consider this only
2563as a last resort. Usually there is a better way. For example:
96449e8e 2564
2565 my %where = (
cc422895 2566 priority => { '<', 2 },
2567 requestor => { -in => \'(SELECT name FROM hitmen)' },
96449e8e 2568 );
2569
cc422895 2570Would create:
96449e8e 2571
cc422895 2572 $stmt = "WHERE priority < ? AND requestor IN (SELECT name FROM hitmen)"
2573 @bind = (2);
2574
2575Note that in this example, you only get one bind parameter back, since
2576the verbatim SQL is passed as part of the statement.
2577
2578=head4 CAVEAT
2579
2580 Never use untrusted input as a literal SQL argument - this is a massive
2581 security risk (there is no way to check literal snippets for SQL
2582 injections and other nastyness). If you need to deal with untrusted input
2583 use literal SQL with placeholders as described next.
96449e8e 2584
cc422895 2585=head3 Literal SQL with placeholders and bind values (subqueries)
96449e8e 2586
2587If the literal SQL to be inserted has placeholders and bind values,
2588use a reference to an arrayref (yes this is a double reference --
2589not so common, but perfectly legal Perl). For example, to find a date
2590in Postgres you can use something like this:
2591
2592 my %where = (
3ae1c5e2 2593 date_column => \[ "= date '2008-09-30' - ?::integer", 10 ]
96449e8e 2594 )
2595
2596This would create:
2597
d2a8fe1a 2598 $stmt = "WHERE ( date_column = date '2008-09-30' - ?::integer )"
96449e8e 2599 @bind = ('10');
2600
deb148a2 2601Note that you must pass the bind values in the same format as they are returned
85783f3c 2602by L<where|/where(\%where, $order)>. This means that if you set L</bindtype>
1f490ae4 2603to C<columns>, you must provide the bind values in the
2604C<< [ column_meta => value ] >> format, where C<column_meta> is an opaque
2605scalar value; most commonly the column name, but you can use any scalar value
2606(including references and blessed references), L<SQL::Abstract> will simply
2607pass it through intact. So if C<bindtype> is set to C<columns> the above
2608example will look like:
deb148a2 2609
2610 my %where = (
3ae1c5e2 2611 date_column => \[ "= date '2008-09-30' - ?::integer", [ {} => 10 ] ]
deb148a2 2612 )
96449e8e 2613
2614Literal SQL is especially useful for nesting parenthesized clauses in the
be21dde3 2615main SQL query. Here is a first example:
96449e8e 2616
2617 my ($sub_stmt, @sub_bind) = ("SELECT c1 FROM t1 WHERE c2 < ? AND c3 LIKE ?",
2618 100, "foo%");
2619 my %where = (
2620 foo => 1234,
2621 bar => \["IN ($sub_stmt)" => @sub_bind],
2622 );
2623
be21dde3 2624This yields:
96449e8e 2625
9d48860e 2626 $stmt = "WHERE (foo = ? AND bar IN (SELECT c1 FROM t1
96449e8e 2627 WHERE c2 < ? AND c3 LIKE ?))";
2628 @bind = (1234, 100, "foo%");
2629
9d48860e 2630Other subquery operators, like for example C<"E<gt> ALL"> or C<"NOT IN">,
96449e8e 2631are expressed in the same way. Of course the C<$sub_stmt> and
9d48860e 2632its associated bind values can be generated through a former call
96449e8e 2633to C<select()> :
2634
2635 my ($sub_stmt, @sub_bind)
9d48860e 2636 = $sql->select("t1", "c1", {c2 => {"<" => 100},
96449e8e 2637 c3 => {-like => "foo%"}});
2638 my %where = (
2639 foo => 1234,
2640 bar => \["> ALL ($sub_stmt)" => @sub_bind],
2641 );
2642
2643In the examples above, the subquery was used as an operator on a column;
9d48860e 2644but the same principle also applies for a clause within the main C<%where>
be21dde3 2645hash, like an EXISTS subquery:
96449e8e 2646
9d48860e 2647 my ($sub_stmt, @sub_bind)
96449e8e 2648 = $sql->select("t1", "*", {c1 => 1, c2 => \"> t0.c0"});
48d9f5f8 2649 my %where = ( -and => [
96449e8e 2650 foo => 1234,
48d9f5f8 2651 \["EXISTS ($sub_stmt)" => @sub_bind],
2652 ]);
96449e8e 2653
2654which yields
2655
9d48860e 2656 $stmt = "WHERE (foo = ? AND EXISTS (SELECT * FROM t1
96449e8e 2657 WHERE c1 = ? AND c2 > t0.c0))";
2658 @bind = (1234, 1);
2659
2660
9d48860e 2661Observe that the condition on C<c2> in the subquery refers to
be21dde3 2662column C<t0.c0> of the main query: this is I<not> a bind
9d48860e 2663value, so we have to express it through a scalar ref.
96449e8e 2664Writing C<< c2 => {">" => "t0.c0"} >> would have generated
2665C<< c2 > ? >> with bind value C<"t0.c0"> ... not exactly
2666what we wanted here.
2667
96449e8e 2668Finally, here is an example where a subquery is used
2669for expressing unary negation:
2670
9d48860e 2671 my ($sub_stmt, @sub_bind)
96449e8e 2672 = $sql->where({age => [{"<" => 10}, {">" => 20}]});
2673 $sub_stmt =~ s/^ where //i; # don't want "WHERE" in the subclause
2674 my %where = (
2675 lname => {like => '%son%'},
48d9f5f8 2676 \["NOT ($sub_stmt)" => @sub_bind],
96449e8e 2677 );
2678
2679This yields
2680
2681 $stmt = "lname LIKE ? AND NOT ( age < ? OR age > ? )"
2682 @bind = ('%son%', 10, 20)
2683
cc422895 2684=head3 Deprecated usage of Literal SQL
2685
2686Below are some examples of archaic use of literal SQL. It is shown only as
2687reference for those who deal with legacy code. Each example has a much
2688better, cleaner and safer alternative that users should opt for in new code.
2689
2690=over
2691
2692=item *
2693
2694 my %where = ( requestor => \'IS NOT NULL' )
2695
2696 $stmt = "WHERE requestor IS NOT NULL"
2697
2698This used to be the way of generating NULL comparisons, before the handling
2699of C<undef> got formalized. For new code please use the superior syntax as
2700described in L</Tests for NULL values>.
96449e8e 2701
cc422895 2702=item *
2703
2704 my %where = ( requestor => \'= submitter' )
2705
2706 $stmt = "WHERE requestor = submitter"
2707
2708This used to be the only way to compare columns. Use the superior L</-ident>
2709method for all new code. For example an identifier declared in such a way
2710will be properly quoted if L</quote_char> is properly set, while the legacy
2711form will remain as supplied.
2712
2713=item *
2714
2715 my %where = ( is_ready => \"", completed => { '>', '2012-12-21' } )
2716
2717 $stmt = "WHERE completed > ? AND is_ready"
2718 @bind = ('2012-12-21')
2719
2720Using an empty string literal used to be the only way to express a boolean.
2721For all new code please use the much more readable
2722L<-bool|/Unary operators: bool> operator.
2723
2724=back
96449e8e 2725
2726=head2 Conclusion
2727
32eab2da 2728These pages could go on for a while, since the nesting of the data
2729structures this module can handle are pretty much unlimited (the
2730module implements the C<WHERE> expansion as a recursive function
2731internally). Your best bet is to "play around" with the module a
2732little to see how the data structures behave, and choose the best
2733format for your data based on that.
2734
2735And of course, all the values above will probably be replaced with
2736variables gotten from forms or the command line. After all, if you
2737knew everything ahead of time, you wouldn't have to worry about
2738dynamically-generating SQL and could just hardwire it into your
2739script.
2740
86298391 2741=head1 ORDER BY CLAUSES
2742
9d48860e 2743Some functions take an order by clause. This can either be a scalar (just a
18710f60 2744column name), a hashref of C<< { -desc => 'col' } >> or C<< { -asc => 'col' }
2745>>, a scalarref, an arrayref-ref, or an arrayref of any of the previous
2746forms. Examples:
1cfa1db3 2747
8c15b421 2748 Given | Will Generate
18710f60 2749 ---------------------------------------------------------------
8c15b421 2750 |
2751 'colA' | ORDER BY colA
2752 |
2753 [qw/colA colB/] | ORDER BY colA, colB
2754 |
2755 {-asc => 'colA'} | ORDER BY colA ASC
2756 |
2757 {-desc => 'colB'} | ORDER BY colB DESC
2758 |
2759 ['colA', {-asc => 'colB'}] | ORDER BY colA, colB ASC
2760 |
2761 { -asc => [qw/colA colB/] } | ORDER BY colA ASC, colB ASC
2762 |
2763 \'colA DESC' | ORDER BY colA DESC
2764 |
2765 \[ 'FUNC(colA, ?)', $x ] | ORDER BY FUNC(colA, ?)
2766 | /* ...with $x bound to ? */
2767 |
bd805d85 2768 [ | ORDER BY
2769 { -asc => 'colA' }, | colA ASC,
2770 { -desc => [qw/colB/] }, | colB DESC,
2771 { -asc => [qw/colC colD/] },| colC ASC, colD ASC,
2772 \'colE DESC', | colE DESC,
2773 \[ 'FUNC(colF, ?)', $x ], | FUNC(colF, ?)
2774 ] | /* ...with $x bound to ? */
18710f60 2775 ===============================================================
86298391 2776
96449e8e 2777
2778
2779=head1 SPECIAL OPERATORS
2780
e3f9dff4 2781 my $sqlmaker = SQL::Abstract->new(special_ops => [
3a2e1a5e 2782 {
2783 regex => qr/.../,
e3f9dff4 2784 handler => sub {
2785 my ($self, $field, $op, $arg) = @_;
2786 ...
3a2e1a5e 2787 },
2788 },
2789 {
2790 regex => qr/.../,
2791 handler => 'method_name',
e3f9dff4 2792 },
2793 ]);
2794
9d48860e 2795A "special operator" is a SQL syntactic clause that can be
e3f9dff4 2796applied to a field, instead of a usual binary operator.
be21dde3 2797For example:
e3f9dff4 2798
2799 WHERE field IN (?, ?, ?)
2800 WHERE field BETWEEN ? AND ?
2801 WHERE MATCH(field) AGAINST (?, ?)
96449e8e 2802
e3f9dff4 2803Special operators IN and BETWEEN are fairly standard and therefore
3a2e1a5e 2804are builtin within C<SQL::Abstract> (as the overridable methods
2805C<_where_field_IN> and C<_where_field_BETWEEN>). For other operators,
2806like the MATCH .. AGAINST example above which is specific to MySQL,
2807you can write your own operator handlers - supply a C<special_ops>
2808argument to the C<new> method. That argument takes an arrayref of
2809operator definitions; each operator definition is a hashref with two
2810entries:
96449e8e 2811
e3f9dff4 2812=over
2813
2814=item regex
2815
2816the regular expression to match the operator
96449e8e 2817
e3f9dff4 2818=item handler
2819
3a2e1a5e 2820Either a coderef or a plain scalar method name. In both cases
2821the expected return is C<< ($sql, @bind) >>.
2822
2823When supplied with a method name, it is simply called on the
13cc86af 2824L<SQL::Abstract> object as:
3a2e1a5e 2825
ca4f826a 2826 $self->$method_name($field, $op, $arg)
3a2e1a5e 2827
2828 Where:
2829
3a2e1a5e 2830 $field is the LHS of the operator
13cc86af 2831 $op is the part that matched the handler regex
3a2e1a5e 2832 $arg is the RHS
2833
2834When supplied with a coderef, it is called as:
2835
2836 $coderef->($self, $field, $op, $arg)
2837
e3f9dff4 2838
2839=back
2840
9d48860e 2841For example, here is an implementation
e3f9dff4 2842of the MATCH .. AGAINST syntax for MySQL
2843
2844 my $sqlmaker = SQL::Abstract->new(special_ops => [
9d48860e 2845
e3f9dff4 2846 # special op for MySql MATCH (field) AGAINST(word1, word2, ...)
9d48860e 2847 {regex => qr/^match$/i,
e3f9dff4 2848 handler => sub {
2849 my ($self, $field, $op, $arg) = @_;
2850 $arg = [$arg] if not ref $arg;
2851 my $label = $self->_quote($field);
2852 my ($placeholder) = $self->_convert('?');
2853 my $placeholders = join ", ", (($placeholder) x @$arg);
2854 my $sql = $self->_sqlcase('match') . " ($label) "
2855 . $self->_sqlcase('against') . " ($placeholders) ";
2856 my @bind = $self->_bindtype($field, @$arg);
2857 return ($sql, @bind);
2858 }
2859 },
9d48860e 2860
e3f9dff4 2861 ]);
96449e8e 2862
2863
59f23b3d 2864=head1 UNARY OPERATORS
2865
112b5232 2866 my $sqlmaker = SQL::Abstract->new(unary_ops => [
59f23b3d 2867 {
2868 regex => qr/.../,
2869 handler => sub {
2870 my ($self, $op, $arg) = @_;
2871 ...
2872 },
2873 },
2874 {
2875 regex => qr/.../,
2876 handler => 'method_name',
2877 },
2878 ]);
2879
9d48860e 2880A "unary operator" is a SQL syntactic clause that can be
59f23b3d 2881applied to a field - the operator goes before the field
2882
2883You can write your own operator handlers - supply a C<unary_ops>
2884argument to the C<new> method. That argument takes an arrayref of
2885operator definitions; each operator definition is a hashref with two
2886entries:
2887
2888=over
2889
2890=item regex
2891
2892the regular expression to match the operator
2893
2894=item handler
2895
2896Either a coderef or a plain scalar method name. In both cases
2897the expected return is C<< $sql >>.
2898
2899When supplied with a method name, it is simply called on the
13cc86af 2900L<SQL::Abstract> object as:
59f23b3d 2901
ca4f826a 2902 $self->$method_name($op, $arg)
59f23b3d 2903
2904 Where:
2905
2906 $op is the part that matched the handler regex
2907 $arg is the RHS or argument of the operator
2908
2909When supplied with a coderef, it is called as:
2910
2911 $coderef->($self, $op, $arg)
2912
2913
2914=back
2915
2916
32eab2da 2917=head1 PERFORMANCE
2918
2919Thanks to some benchmarking by Mark Stosberg, it turns out that
2920this module is many orders of magnitude faster than using C<DBIx::Abstract>.
2921I must admit this wasn't an intentional design issue, but it's a
2922byproduct of the fact that you get to control your C<DBI> handles
2923yourself.
2924
2925To maximize performance, use a code snippet like the following:
2926
2927 # prepare a statement handle using the first row
2928 # and then reuse it for the rest of the rows
2929 my($sth, $stmt);
2930 for my $href (@array_of_hashrefs) {
2931 $stmt ||= $sql->insert('table', $href);
2932 $sth ||= $dbh->prepare($stmt);
2933 $sth->execute($sql->values($href));
2934 }
2935
2936The reason this works is because the keys in your C<$href> are sorted
2937internally by B<SQL::Abstract>. Thus, as long as your data retains
2938the same structure, you only have to generate the SQL the first time
2939around. On subsequent queries, simply use the C<values> function provided
2940by this module to return your values in the correct order.
2941
b864ba9b 2942However this depends on the values having the same type - if, for
2943example, the values of a where clause may either have values
2944(resulting in sql of the form C<column = ?> with a single bind
2945value), or alternatively the values might be C<undef> (resulting in
2946sql of the form C<column IS NULL> with no bind value) then the
2947caching technique suggested will not work.
96449e8e 2948
32eab2da 2949=head1 FORMBUILDER
2950
2951If you use my C<CGI::FormBuilder> module at all, you'll hopefully
2952really like this part (I do, at least). Building up a complex query
2953can be as simple as the following:
2954
2955 #!/usr/bin/perl
2956
46dc2f3e 2957 use warnings;
2958 use strict;
2959
32eab2da 2960 use CGI::FormBuilder;
2961 use SQL::Abstract;
2962
2963 my $form = CGI::FormBuilder->new(...);
2964 my $sql = SQL::Abstract->new;
2965
2966 if ($form->submitted) {
2967 my $field = $form->field;
2968 my $id = delete $field->{id};
2969 my($stmt, @bind) = $sql->update('table', $field, {id => $id});
2970 }
2971
2972Of course, you would still have to connect using C<DBI> to run the
2973query, but the point is that if you make your form look like your
2974table, the actual query script can be extremely simplistic.
2975
2976If you're B<REALLY> lazy (I am), check out C<HTML::QuickTable> for
9d48860e 2977a fast interface to returning and formatting data. I frequently
32eab2da 2978use these three modules together to write complex database query
2979apps in under 50 lines.
2980
af733667 2981=head1 HOW TO CONTRIBUTE
2982
2983Contributions are always welcome, in all usable forms (we especially
2984welcome documentation improvements). The delivery methods include git-
2985or unified-diff formatted patches, GitHub pull requests, or plain bug
2986reports either via RT or the Mailing list. Contributors are generally
2987granted full access to the official repository after their first several
2988patches pass successful review.
2989
2990This project is maintained in a git repository. The code and related tools are
2991accessible at the following locations:
d8cc1792 2992
2993=over
2994
af733667 2995=item * Official repo: L<git://git.shadowcat.co.uk/dbsrgits/SQL-Abstract.git>
2996
2997=item * Official gitweb: L<http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=dbsrgits/SQL-Abstract.git>
2998
2999=item * GitHub mirror: L<https://github.com/dbsrgits/sql-abstract>
d8cc1792 3000
af733667 3001=item * Authorized committers: L<ssh://dbsrgits@git.shadowcat.co.uk/SQL-Abstract.git>
d8cc1792 3002
3003=back
32eab2da 3004
96449e8e 3005=head1 CHANGES
3006
3007Version 1.50 was a major internal refactoring of C<SQL::Abstract>.
3008Great care has been taken to preserve the I<published> behavior
3009documented in previous versions in the 1.* family; however,
9d48860e 3010some features that were previously undocumented, or behaved
96449e8e 3011differently from the documentation, had to be changed in order
3012to clarify the semantics. Hence, client code that was relying
9d48860e 3013on some dark areas of C<SQL::Abstract> v1.*
96449e8e 3014B<might behave differently> in v1.50.
32eab2da 3015
be21dde3 3016The main changes are:
d2a8fe1a 3017
96449e8e 3018=over
32eab2da 3019
9d48860e 3020=item *
32eab2da 3021
3ae1c5e2 3022support for literal SQL through the C<< \ [ $sql, @bind ] >> syntax.
96449e8e 3023
3024=item *
3025
145fbfc8 3026support for the { operator => \"..." } construct (to embed literal SQL)
3027
3028=item *
3029
9c37b9c0 3030support for the { operator => \["...", @bind] } construct (to embed literal SQL with bind values)
3031
3032=item *
3033
96449e8e 3034optional support for L<array datatypes|/"Inserting and Updating Arrays">
3035
9d48860e 3036=item *
96449e8e 3037
be21dde3 3038defensive programming: check arguments
96449e8e 3039
3040=item *
3041
3042fixed bug with global logic, which was previously implemented
7cac25e6 3043through global variables yielding side-effects. Prior versions would
96449e8e 3044interpret C<< [ {cond1, cond2}, [cond3, cond4] ] >>
3045as C<< "(cond1 AND cond2) OR (cond3 AND cond4)" >>.
3046Now this is interpreted
3047as C<< "(cond1 AND cond2) OR (cond3 OR cond4)" >>.
3048
96449e8e 3049
3050=item *
3051
3052fixed semantics of _bindtype on array args
3053
9d48860e 3054=item *
96449e8e 3055
3056dropped the C<_anoncopy> of the %where tree. No longer necessary,
3057we just avoid shifting arrays within that tree.
3058
3059=item *
3060
3061dropped the C<_modlogic> function
3062
3063=back
32eab2da 3064
32eab2da 3065=head1 ACKNOWLEDGEMENTS
3066
3067There are a number of individuals that have really helped out with
3068this module. Unfortunately, most of them submitted bugs via CPAN
3069so I have no idea who they are! But the people I do know are:
3070
9d48860e 3071 Ash Berlin (order_by hash term support)
b643abe1 3072 Matt Trout (DBIx::Class support)
32eab2da 3073 Mark Stosberg (benchmarking)
3074 Chas Owens (initial "IN" operator support)
3075 Philip Collins (per-field SQL functions)
3076 Eric Kolve (hashref "AND" support)
3077 Mike Fragassi (enhancements to "BETWEEN" and "LIKE")
3078 Dan Kubb (support for "quote_char" and "name_sep")
f5aab26e 3079 Guillermo Roditi (patch to cleanup "IN" and "BETWEEN", fix and tests for _order_by)
48d9f5f8 3080 Laurent Dami (internal refactoring, extensible list of special operators, literal SQL)
dbdf7648 3081 Norbert Buchmuller (support for literal SQL in hashpair, misc. fixes & tests)
e96c510a 3082 Peter Rabbitson (rewrite of SQLA::Test, misc. fixes & tests)
02288357 3083 Oliver Charles (support for "RETURNING" after "INSERT")
32eab2da 3084
3085Thanks!
3086
32eab2da 3087=head1 SEE ALSO
3088
86298391 3089L<DBIx::Class>, L<DBIx::Abstract>, L<CGI::FormBuilder>, L<HTML::QuickTable>.
32eab2da 3090
32eab2da 3091=head1 AUTHOR
3092
b643abe1 3093Copyright (c) 2001-2007 Nathan Wiger <nwiger@cpan.org>. All Rights Reserved.
3094
3095This module is actively maintained by Matt Trout <mst@shadowcatsystems.co.uk>
32eab2da 3096
abe72f94 3097For support, your best bet is to try the C<DBIx::Class> users mailing list.
3098While not an official support venue, C<DBIx::Class> makes heavy use of
3099C<SQL::Abstract>, and as such list members there are very familiar with
3100how to create queries.
3101
0d067ded 3102=head1 LICENSE
3103
d988ab87 3104This module is free software; you may copy this under the same
3105terms as perl itself (either the GNU General Public License or
3106the Artistic License)
32eab2da 3107
3108=cut