X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2FReplicated.pm;h=ef0cdaf65798b10f3194cf52eb830e1a7cd5afd9;hb=572338e0c6b2b119362ae59880813b0d5188c62f;hp=37f13d76bc51790de31440566ec7f9ae70926684;hpb=fecb38cba68186d579ef96f89bf6ce557e55ab1c;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/Replicated.pm b/lib/DBIx/Class/Storage/DBI/Replicated.pm index 37f13d7..ef0cdaf 100644 --- a/lib/DBIx/Class/Storage/DBI/Replicated.pm +++ b/lib/DBIx/Class/Storage/DBI/Replicated.pm @@ -15,7 +15,7 @@ use DBIx::Class::Storage::DBI::Replicated::Types qw/BalancerClassNamePart DBICSc use MooseX::Types::Moose qw/ClassName HashRef Object/; use Scalar::Util 'reftype'; use Hash::Merge; -use List::Util qw/min max/; +use List::Util qw/min max reduce/; use namespace::clean -except => 'meta'; @@ -343,7 +343,6 @@ has 'write_handler' => ( _dbh_commit _execute_array _placeholders_supported - _verify_pid savepoints _sqlt_minimum_version _sql_maker_opts @@ -371,6 +370,18 @@ has 'write_handler' => ( /], ); +my @unimplemented = qw( + _arm_global_destructor + _preserve_foreign_dbh + _verify_pid + _verify_tid +); + +for my $method (@unimplemented) { + __PACKAGE__->meta->add_method($method, sub { + croak "$method must not be called on ".(blessed shift).' objects'; + }); +} has _master_connect_info_opts => (is => 'rw', isa => HashRef, default => sub { {} }); @@ -1010,20 +1021,23 @@ sub _ping { return min map $_->_ping, $self->all_storages; } +my $numify_ver = sub { + my $ver = shift; + my @numparts = split /\D+/, $ver; + my $format = '%d.' . (join '', ('%05d') x (@numparts - 1)); + + return sprintf $format, @numparts; +}; + sub _server_info { my $self = shift; if (not $self->_server_info_hash) { - no warnings 'numeric'; # in case dbms_version doesn't normalize - - my @infos = - map $_->[1], - sort { $a->[0] <=> $b->[0] } - map [ (defined $_->{normalized_dbms_version} ? $_->{normalized_dbms_version} - : $_->{dbms_version}), $_ ], - map $_->_server_info, $self->all_storages; - - my $min_version_info = $infos[0]; + my $min_version_info = ( + reduce { $a->[0] < $b->[0] ? $a : $b } + map [ $numify_ver->($_->{dbms_version}), $_ ], + map $_->_server_info, $self->all_storages + )->[1]; $self->_server_info_hash($min_version_info); # on master }