X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?p=dbsrgits%2FDBIx-Class.git;a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FReplicated.pm;h=447747514dd38272da3c17fa1c9e635944407822;hp=46ad46286b98971e17ffb29e4d1d7a741f8c33e3;hb=64ae166780d0cb2b9577e506da9b9b240c146d20;hpb=6a247f3368100ac0557e33cc534bc8ad0ccb1175 diff --git a/lib/DBIx/Class/Storage/DBI/Replicated.pm b/lib/DBIx/Class/Storage/DBI/Replicated.pm index 46ad462..4477475 100644 --- a/lib/DBIx/Class/Storage/DBI/Replicated.pm +++ b/lib/DBIx/Class/Storage/DBI/Replicated.pm @@ -314,7 +314,6 @@ has 'write_handler' => ( svp_begin svp_release relname_to_table_alias - _straight_join_to_node _dbh_last_insert_id _fix_bind_params _default_dbi_connect_attributes @@ -357,7 +356,7 @@ has 'write_handler' => ( _resolve_column_info _prune_unused_joins _strip_cond_qualifiers - _parse_order_by + _extract_order_columns _resolve_aliastypes_from_select_args _execute _do_query @@ -377,21 +376,19 @@ my @unimplemented = qw( set_use_dbms_capability get_dbms_capability set_dbms_capability - - sql_limit_dialect - _dbh_details - _use_insert_returning - _supports_insert_returning + sql_limit_dialect - _use_placeholders - _supports_placeholders - _determine_supports_placeholders + _inner_join_to_node + _group_over_selection +); - _use_typeless_placeholders - _supports_typeless_placeholders - _determine_supports_typeless_placeholders +# the capability framework +# not sure if CMOP->initialize does evil things to DBIC::S::DBI, fix if a problem +push @unimplemented, ( grep + { $_ =~ /^ _ (?: use | supports | determine_supports ) _ /x } + ( Class::MOP::Class->initialize('DBIx::Class::Storage::DBI')->get_all_method_names ) ); for my $method (@unimplemented) { @@ -433,8 +430,9 @@ around connect_info => sub { $merge->merge((delete $opts{pool_args} || {}), $self->pool_args) ); - $self->pool($self->_build_pool) - if $self->pool; + ## Since we possibly changed the pool_args, we need to clear the current + ## pool object so that next time it is used it will be rebuilt. + $self->clear_pool; } if (@opts{qw/balancer_type balancer_args/}) { @@ -753,7 +751,7 @@ sub limit_dialect { foreach my $source ($self->all_storages) { $source->limit_dialect(@_); } - return $self->master->quote_char; + return $self->master->limit_dialect; } =head2 quote_char