use SQL::Abstract::Test import => [ qw(is_same_sql_bind is_same_sql) ];
use SQL::Abstract::ExtraClauses;
-my $sqlac = SQL::Abstract::ExtraClauses->new;
+my $sqlac = SQL::Abstract::ExtraClauses->new(unknown_unop_always_func => 1);
my ($sql, @bind) = $sqlac->select({
- select => [ qw(artist.id artist.name), { -func => [ json_agg => 'cd' ] } ],
+ select => [ qw(artist.id artist.name), { -json_agg => 'cd' } ],
from => [
{ artists => { -as => 'artist' } },
-join => [ cds => as => 'cd' => on => { 'cd.artist_id' => 'artist.id' } ],
where => { 'artist.genres', => { '@>', { -value => [ 'Rock' ] } } },
order_by => 'artist.name',
group_by => 'artist.id',
- having => { '>' => [ { -func => [ count => 'cd.id' ] }, 3 ] }
+ having => { '>' => [ { -count => 'cd.id' }, 3 ] }
});
is_same_sql_bind(
SELECT artist.id, artist.name, JSON_AGG(cd)
FROM artists AS artist JOIN cds AS cd ON cd.artist_id = artist.id
WHERE artist.genres @> ?
- ORDER BY artist.name
GROUP BY artist.id
HAVING COUNT(cd.id) > ?
+ ORDER BY artist.name
},
[ [ 'Rock' ], 3 ]
);
is_same_sql(
$sqlac->insert({
into => 'foo',
- values => { -select => { select => '*', from => 'bar' } }
+ select => { select => '*', from => 'bar' }
}),
q{INSERT INTO foo SELECT * FROM bar}
);
+($sql, @bind) = $sqlac->insert({
+ into => 'eh',
+ rowvalues => [ [ 1, 2 ], [ 3, 4 ], [ 5, 6 ] ]
+});
+
+is_same_sql_bind(
+ $sql, \@bind,
+ q{INSERT INTO eh VALUES (?, ?), (?, ?), (?, ?)},
+ [ 1..6 ],
+);
+
+is_same_sql(
+ $sqlac->select({
+ select => '*',
+ from => 'foo',
+ where => { -not_exists => {
+ -select => {
+ select => \1,
+ from => 'bar',
+ where => { 'foo.id' => { -ident => 'bar.foo_id' } }
+ },
+ } },
+ }),
+ q{SELECT * FROM foo
+ WHERE NOT EXISTS (SELECT 1 FROM bar WHERE foo.id = bar.foo_id)},
+);
+
+is_same_sql(
+ $sqlac->select({
+ select => '*',
+ from => 'foo',
+ where => { id => {
+ '=' => { -select => { select => { -max => 'id' }, from => 'foo' } }
+ } },
+ }),
+ q{SELECT * FROM foo WHERE id = (SELECT MAX(id) FROM foo)},
+);
+
+{
+ my $sqlac = $sqlac->clone
+ ->clauses_of(
+ select => (
+ $sqlac->clauses_of('select'),
+ qw(limit offset),
+ )
+ );
+
+ ($sql, @bind) = $sqlac->select({
+ select => '*',
+ from => 'foo',
+ limit => 10,
+ offset => 20,
+ });
+
+ is_same_sql_bind(
+ $sql, \@bind,
+ q{SELECT * FROM foo LIMIT ? OFFSET ?}, [ 10, 20 ]
+ );
+}
+
+$sql = $sqlac->select({
+ select => { -as => [ \1, 'x' ] },
+ union => { -select => { select => { -as => [ \2, 'x' ] } } },
+ order_by => { -desc => 'x' },
+});
+
+is_same_sql(
+ $sql,
+ q{(SELECT 1 AS x) UNION (SELECT 2 AS x) ORDER BY x DESC},
+);
+
+$sql = $sqlac->select({
+ select => '*',
+ from => 'foo',
+ except => { -select => { select => '*', from => 'foo_exclusions' } }
+});
+
+is_same_sql(
+ $sql,
+ q{(SELECT * FROM foo) EXCEPT (SELECT * FROM foo_exclusions)},
+);
+
+$sql = $sqlac->select({
+ with => [ foo => { -select => { select => \1 } } ],
+ select => '*',
+ from => 'foo'
+});
+
+is_same_sql(
+ $sql,
+ q{WITH (foo AS (SELECT 1)) SELECT * FROM foo},
+);
+
+$sql = $sqlac->update({
+ _ => [ 'tree_table', -join => {
+ to => { -select => {
+ with_recursive => [
+ [ tree_with_path => qw(id parent_id path) ],
+ { -select => {
+ _ => [
+ qw(id parent_id),
+ { -as => [
+ { -cast => { -as => [ id => char => 255 ] } },
+ 'path'
+ ] },
+ ],
+ from => 'tree_table',
+ where => { parent_id => undef },
+ union_all => {
+ -select => {
+ _ => [ qw(t.id t.parent_id),
+ { -as => [
+ { -concat => [ 'r.path', \q{'/'}, 't.id' ] },
+ 'path',
+ ] },
+ ],
+ from => [
+ tree_table => -as => t =>
+ -join => {
+ to => 'tree_with_path',
+ as => 'r',
+ on => { 't.parent_id' => 'r.id' },
+ },
+ ],
+ } },
+ } },
+ ],
+ select => '*',
+ from => 'tree_with_path'
+ } },
+ as => 'tree',
+ on => { 'tree.id' => 'tree_with_path.id' },
+ } ],
+ set => { path => { -ident => [ qw(tree path) ] } },
+});
+
+is_same_sql(
+ $sql,
+ q{
+ UPDATE tree_table JOIN (
+ WITH RECURSIVE (tree_with_path(id, parent_id, path) AS (
+ (
+ SELECT id, parent_id, CAST(id AS char(255)) AS path
+ FROM tree_table
+ WHERE parent_id IS NULL
+ )
+ UNION ALL
+ (
+ SELECT t.id, t.parent_id, CONCAT(r.path, '/', t.id) AS path
+ FROM tree_table AS t
+ JOIN tree_with_path AS r ON t.parent_id = r.id
+ )
+ ))
+ SELECT * FROM tree_with_path
+ ) AS tree
+ ON tree.id = tree_with_path.id
+ SET path = tree.path
+ },
+);
+
done_testing;