switch to plugin style

[scpubgit/Q-Branch.git] / xt / clauses.t

use strict;
use warnings;
use Test::More;
use SQL::Abstract::Test import => [ qw(is_same_sql_bind is_same_sql) ];
use SQL::Abstract;
use SQL::Abstract::ExtraClauses;

my $sqlac = SQL::Abstract->new(
  unknown_unop_always_func => 1,
  lazy_join_sql_parts => 1,
);

SQL::Abstract::ExtraClauses->apply_to($sqlac);

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' } ],
  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 => { '>' => [ { -count => 'cd.id' }, 3 ] }
});

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 @> ?
    GROUP BY artist.id
    HAVING COUNT(cd.id) > ?
    ORDER BY artist.name
  },
  [ [ 'Rock' ], 3 ]
);

($sql) = $sqlac->select({
  select => [ 'a' ],
  from => [ { -values => [ [ 1, 2 ], [ 3, 4 ] ] }, -as => [ qw(t a b) ] ],
});

is_same_sql($sql, q{SELECT a FROM (VALUES (1, 2), (3, 4)) AS t(a,b)});

($sql) = $sqlac->update({
  update => 'employees',
  set => { sales_count => { sales_count => { '+', \1 } } },
  from => 'accounts',
  where => {
    'accounts.name' => { '=' => \"'Acme Corporation'" },
    'employees.id' => { -ident => 'accounts.sales_person' },
  }
});

is_same_sql(
  $sql,
  q{UPDATE employees SET sales_count = sales_count + 1 FROM accounts
    WHERE accounts.name = 'Acme Corporation'
    AND employees.id = accounts.sales_person
  }
);

($sql) = $sqlac->update({
  update => [ qw(tab1 tab2) ],
  set => {
    'tab1.column1' => { -ident => 'value1' },
    'tab1.column2' => { -ident => 'value2' },
  },
  where => { 'tab1.id' => { -ident => 'tab2.id' } },
});

is_same_sql(
  $sql,
  q{UPDATE tab1, tab2 SET tab1.column1 = value1, tab1.column2 = value2
     WHERE tab1.id = tab2.id}
);

is_same_sql(
  $sqlac->delete({
    from => 'x',
    using => 'y',
    where => { 'x.id' => { -ident => 'y.x_id' } }
  }),
  q{DELETE FROM x USING y WHERE x.id = y.x_id}
);

is_same_sql(
  $sqlac->select({
    select => [ 'x.*', 'y.*' ],
    from => [ 'x', -join => [ 'y', using => 'y_id' ] ],
  }),
  q{SELECT x.*, y.* FROM x JOIN y USING (y_id)},
);

is_same_sql(
  $sqlac->select({
    select => 'x.*',
    from => [ { -select => { select => '*', from => 'y' } }, -as => 'x' ],
  }),
  q{SELECT x.* FROM (SELECT * FROM y) AS x},
);

is_same_sql(
  $sqlac->insert({
    into => 'foo',
    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
  },
);


($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;