1 package Data::Query::Renderer::SQL::Slice::RowNumberOver;
3 use Data::Query::Constants qw(
4 DQ_SELECT DQ_ALIAS DQ_IDENTIFIER DQ_ORDER DQ_SLICE DQ_WHERE DQ_OPERATOR
11 die "Slice's inner is not a Select"
12 unless (my $orig_select = $dq->{from})->{type} eq DQ_SELECT;
15 my (@inside_select_list, @outside_select_list);
16 my $default_inside_alias;
17 SELECT: foreach my $s (@{$orig_select->{select}}) {
19 if ($s->{type} eq DQ_ALIAS) {
24 if ($s->{type} eq DQ_IDENTIFIER) {
25 if (!$name and @{$s->{elements}} == 2) {
26 $default_inside_alias ||= $s->{elements}[0];
27 if ($s->{elements}[0] eq $default_inside_alias) {
28 $alias_map{join('.',@{$s->{elements}})} = $s;
29 push @inside_select_list, $s;
30 push @outside_select_list, $s;
34 $name ||= join('__', @{$s->{elements}});
35 $key = join('.', @{$s->{elements}});
37 die "XXX not implemented yet" unless $name;
40 $name ||= sprintf("GENSYM__%03i",++$gensym_count);
41 push @inside_select_list, +{
46 push @outside_select_list, $alias_map{$key} = +{
47 type => DQ_IDENTIFIER,
51 my $order = $orig_select->{from};
52 my $order_gensym_count;
53 my (@order_nodes, %order_map);
54 while ($order->{type} eq DQ_ORDER) {
55 my $by = $order->{by};
56 if ($by->{type} eq DQ_IDENTIFIER) {
57 $default_inside_alias ||= $by->{elements}[0]
58 if @{$by->{elements}} == 2;
60 = $alias_map{join('.', @{$by->{elements}})}
63 @{$by->{elements}} == 2
64 and $by->{elements}[0] eq $default_inside_alias
68 my $name = sprintf("ORDER__BY__%03i",++$order_gensym_count);
69 push @inside_select_list, +{
75 type => DQ_IDENTIFIER,
76 elements => [ $name ],
81 die "XXX not implemented yet";
83 push @order_nodes, $order;
84 $order = $order->{from};
86 my $inside_order = $order;
90 reverse => $_->{reverse},
92 } for reverse @order_nodes;
93 my $inside_select = +{
95 select => \@inside_select_list,
96 from => $inside_order,
98 $default_inside_alias ||= 'me';
101 from => $inside_select,
102 to => $default_inside_alias,
107 by => $order_map{$_->{by}},
108 reverse => !$_->{reverse},
109 from => $outside_order
110 } for reverse @order_nodes;
111 my $outside_select = +{
114 @outside_select_list,
117 from => $self->_rno_literal($outside_order),
118 to => 'rno__row__index',
121 from => $bridge_from,
124 type => DQ_IDENTIFIER,
125 elements => [ 'rno__row__index' ],
127 my $offset_value = $dq->{offset} ? $dq->{offset}{value} : 0;
132 operator => { 'SQL.Naive' => 'AND' },
136 operator => { 'SQL.Naive' => '>=' },
139 { %{$dq->{limit}}, value => $offset_value + 1 },
144 operator => { 'SQL.Naive' => '<=' },
147 { %{$dq->{limit}}, value => $dq->{limit}{value} + $offset_value },
154 select => \@outside_select_list,
157 from => $outside_select,
158 to => $default_inside_alias,
162 return $self->_render($final);
166 my ($self, $order) = @_;
167 my ($order_str, @order_bind) = (
169 ? @{$self->render($order)}
175 literal => "ROW_NUMBER() OVER( $order_str )",
176 values => \@order_bind