Merge 'mssql_rno_pagination' into 'trunk'

diff --combined Changes

index d670a58,8cf2fbe..cd21c5a
--- 1/Changes
--- 2/Changes
+++ b/Changes
@@@ -1,5 -1,6 +1,6 @@@
  Revision history for DBIx::Class
  
+         - Real limit/offset support for MSSQL server (via Row_Number)
          - Fix distinct => 1 with non-selecting order_by (the columns
            in order_by also need to be aded to the resulting group_by)
          - Do not attempt to deploy FK constraints pointing to a View
@@@ -10,7 -11,6 +11,7 @@@
          - Fix count/objects from search_related on limited resultset
          - Make get_inflated_columns behave identically to get_columns
            wrt +select/+as (RT#46953)
+ +        - Fix problems with scalarrefs under InflateColumn (RT#51559)
  
  0.08114 2009-11-14 17:45:00 (UTC)
          - Preliminary support for MSSQL via DBD::ADO
diff --combined lib/DBIx/Class/Storage/DBI.pm

index f7a9955,c337b5d..d69af71
--- 1/lib/DBIx/Class/Storage/DBI.pm
--- 2/lib/DBIx/Class/Storage/DBI.pm
+++ b/lib/DBIx/Class/Storage/DBI.pm
@@@ -1290,12 -1290,6 +1290,12 @@@ sub _query_end 
      }
  }
  
+ +sub _sth_bind_param {
+ +  my ($self, $sth, $placeholder_index, $data, $attributes) = @_;
+ +
+ +  $sth->bind_param($placeholder_index, $data, $attributes);
+ +}
+ +
  sub _dbh_execute {
    my ($self, $dbh, $op, $extra_bind, $ident, $bind_attributes, @args) = @_;
  
@@@ -1320,7 -1314,7 +1320,7 @@@
        my $ref = ref $data;
        $data = $ref && $ref ne 'ARRAY' ? ''.$data : $data; # stringify args (except arrayrefs)
  
- -      $sth->bind_param($placeholder_index, $data, $attributes);
+ +      $self->_sth_bind_param($sth, $placeholder_index, $data, $attributes);
        $placeholder_index++;
      }
    }
@@@ -1587,14 -1581,6 +1587,14 @@@ sub _subq_update_delete 
  
    # quick check if we got a sane rs on our hands
    my @pcols = $rsrc->primary_columns;
+ +  unless (@pcols) {
+ +    $self->throw_exception (
+ +      sprintf (
+ +        "You must declare primary key(s) on source '%s' (via set_primary_key) in order to update or delete complex resultsets",
+ +        $rsrc->source_name || $rsrc->from
+ +      )
+ +    );
+ +  }
  
    my $sel = $rs->_resolved_attrs->{select};
    $sel = [ $sel ] unless ref $sel eq 'ARRAY';
@@@ -1779,12 -1765,52 +1779,52 @@@ sub _select_args 
    if (
      ( $attrs->{rows} && keys %{$attrs->{collapse}} )
         ||
-     ( $attrs->{group_by} && @{$attrs->{group_by}} &&
-       $attrs->{_prefetch_select} && @{$attrs->{_prefetch_select}} )
+     ( $attrs->{group_by}
+         &&
+       @{$attrs->{group_by}}
+         &&
+       $attrs->{_prefetch_select}
+         &&
+       @{$attrs->{_prefetch_select}}
+     )
    ) {
+ 
      ($ident, $select, $where, $attrs)
        = $self->_adjust_select_args_for_complex_prefetch ($ident, $select, $where, $attrs);
    }
+ 
+   elsif (
+     ($attrs->{rows} || $attrs->{offset})
+       &&
+     $sql_maker->limit_dialect eq 'RowNumberOver'
+       &&
+     (ref $ident eq 'ARRAY' && @$ident > 1)  # indicates a join
+       &&
+     scalar $sql_maker->_order_by_chunks ($attrs->{order_by})
+   ) {
+     # the RNO limit dialect above mangles the SQL such that the join gets lost
+     # wrap a subquery here
+ 
+     push @limit, delete @{$attrs}{qw/rows offset/};
+ 
+     my $subq = $self->_select_args_to_query (
+       $ident,
+       $select,
+       $where,
+       $attrs,
+     );
+ 
+     $ident = {
+       -alias => $attrs->{alias},
+       -source_handle => $ident->[0]{-source_handle},
+       $attrs->{alias} => $subq,
+     };
+ 
+     # all part of the subquery now
+     delete @{$attrs}{qw/order_by group_by having/};
+     $where = undef;
+   }
+ 
    elsif (! $attrs->{software_limit} ) {
      push @limit, $attrs->{rows}, $attrs->{offset};
    }
		1	2
Changes	patch \|	diff1 \|	diff2 \|	blob \| history
lib/DBIx/Class/Storage/DBI.pm	patch \|	diff1 \|	diff2 \|	blob \| history