use SQL::Abstract::Test import => [ qw(is_same_sql_bind is_same_sql) ];
use SQL::Abstract::ExtraClauses;
-my $sqlac = SQL::Abstract::ExtraClauses->new(unknown_unop_always_func => 1);
+my $sqlac = SQL::Abstract::ExtraClauses->new(
+ unknown_unop_always_func => 1,
+ lazy_join_sql_parts => 1,
+);
+
+is_deeply(
+ [ $sqlac->statement_list ],
+ [ sort qw(select update insert delete) ],
+);
my ($sql, @bind) = $sqlac->select({
select => [ qw(artist.id artist.name), { -json_agg => 'cd' } ],
having => { '>' => [ { -count => 'cd.id' }, 3 ] }
});
+::Dwarn([ $sql->formatter->_simplify($sql->to_array), $sql->stringify ]);
+
is_same_sql_bind(
$sql, \@bind,
q{
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 ]
);
);
{
-
my $sqlac = $sqlac->clone
->clauses_of(
select => (
);
}
+$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
+ },
+);
+
+
+($sql, @bind) = $sqlac->insert({
+ with => [
+ faculty => {
+ -select => {
+ _ => [qw /p.person p.email/],
+ from => [ person => -as => 'p' ],
+ where => {
+ 'p.person_type' => 'faculty',
+ 'p.person_status' => { '!=' => 'pending' },
+ 'p.default_license_id' => undef,
+ },
+ },
+ },
+ grandfather => {
+ -insert => {
+ into => 'license',
+ fields => [ qw(kind expires_on valid_from) ],
+ select => {
+ select => [\(qw('grandfather' '2017-06-30' '2016-07-01'))],
+ from => 'faculty',
+ },
+ returning => 'license_id',
+ }
+ },
+ ],
+ into => 'license_person',
+ fields => [ qw(person_id license_id) ],
+ select => {
+ _ => ['person_id', 'license_id'],
+ from => ['grandfather'],
+ where => {
+ 'a.index' => { -ident => 'b.index' },
+ },
+ },
+});
+
+is_same_sql_bind(
+ $sql, \@bind,
+ q{
+ WITH faculty AS (
+ SELECT p.person, p.email FROM person AS p
+ WHERE (
+ p.default_license_id IS NULL
+ AND p.person_status != ?
+ AND p.person_type = ?
+ )
+ ), grandfather AS (
+ INSERT INTO license (kind, expires_on, valid_from)
+ SELECT 'grandfather', '2017-06-30', '2016-07-01'
+ FROM faculty RETURNING license_id
+ ) INSERT INTO license_person (person_id, license_id)
+ SELECT person_id, license_id FROM grandfather WHERE a.index = b.index
+ },
+ [ qw(pending faculty) ],
+);
+
+
+($sql, @bind) = $sqlac->delete({
+ with => [
+ instructors => {
+ -select => {
+ _ => [qw/p.person_id email default_license_id/],
+ from => [
+ person => -as => 'p',
+ -join => {
+ to => 'license_person',
+ as => 'lp',
+ on => { 'lp.person_id' => 'p.person_id' },
+ },
+ -join => {
+ to => 'license',
+ as => 'l',
+ on => { 'l.license_id' => 'lp.license_id' },
+ },
+ ],
+ where => {
+ 'p.person_type' => 'faculty',
+ 'p.person_status' => { '!=' => 'pending' },
+ 'l.kind' => 'pending',
+ },
+ group_by => [qw/ p.person_id /],
+ having => { '>' => [ { -count => 'l.license_id' }, 1 ] }
+ },
+ },
+ deletable_licenses => {
+ -select => {
+ _ => [qw/lp.ctid lp.person_id lp.license_id/],
+ from => [
+ instructors => -as => 'i',
+ -join => {
+ to => 'license_person',
+ as => 'lp',
+ on => { 'lp.person_id' => 'i.person_id' },
+ },
+ -join => {
+ to => 'license',
+ as => 'l',
+ on => { 'l.license_id' => 'lp.license_id' },
+ },
+ ],
+ where => {
+ 'lp.license_id' => {
+ '<>' => {-ident => 'i.default_license_id'}
+ },
+ 'l.kind' => 'pending',
+ },
+ },
+ },
+ ],
+ from => 'license_person',
+ where => {
+ ctid => { -in =>
+ {
+ -select => {
+ _ => ['ctid'],
+ from => 'deletable_licenses',
+ }
+ }
+ }
+ }
+});
+
+is_same_sql_bind(
+ $sql, \@bind,
+ q{
+ with instructors as (
+ select p.person_id, email, default_license_id
+ from person as p
+ join license_person as lp on lp.person_id = p.person_id
+ join license as l on l.license_id = lp.license_id
+ where l.kind = ?
+ AND p.person_status != ?
+ AND p.person_type = ?
+ group by p.person_id
+ having COUNT(l.license_id) > ?),
+ deletable_licenses as (
+ select lp.ctid, lp.person_id, lp.license_id
+ from instructors as i
+ join license_person as lp on lp.person_id = i.person_id
+ join license as l on l.license_id = lp.license_id
+ where l.kind = ?
+ and lp.license_id <> i.default_license_id
+ )
+ delete from license_person
+ where ctid IN (
+ (select ctid from deletable_licenses)
+ )
+ },
+ [qw(
+ pending pending faculty 1 pending
+ )]
+);
+
+($sql, @bind) = $sqlac->update({
+ _ => ['survey'],
+ set => {
+ license_id => { -ident => 'info.default_license_id' },
+ },
+ from => [
+ -select => {
+ select => [qw( s.survey_id p.default_license_id p.person_id)],
+ from => [
+ person => -as => 'p',
+ -join => {
+ to => 'class',
+ as => 'c',
+ on => { 'c.faculty_id' => 'p.person_id' },
+ },
+ -join => {
+ to => 'survey',
+ as => 's',
+ on => { 's.class_id' => 'c.class_id' },
+ },
+ ],
+ where => { 'p.institution_id' => { -value => 15031 } },
+ },
+ -as => 'info',
+ ],
+ where => {
+ 'info.survey_id' => { -ident => 'survey.survey_id' },
+ }
+});
+
+is_same_sql_bind(
+ $sql, \@bind,
+ q{
+ update survey
+ set license_id=info.default_license_id
+ from (
+ select s.survey_id, p.default_license_id, p.person_id
+ from person AS p
+ join class AS c on c.faculty_id = p.person_id
+ join survey AS s on s.class_id = c.class_id
+ where p.institution_id = ?
+ ) AS info
+ where info.survey_id=survey.survey_id
+ },
+ [qw(
+ 15031
+ )]
+);
+
+
+
done_testing;