From: Rafael Kitover Date: Thu, 8 Apr 2010 16:38:59 +0000 (+0000) Subject: use min dbms_version for ::Replicated X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=commitdiff_plain;h=fecb38cba68186d579ef96f89bf6ce557e55ab1c;p=dbsrgits%2FDBIx-Class-Historic.git use min dbms_version for ::Replicated --- diff --git a/lib/DBIx/Class/Storage/DBI/Replicated.pm b/lib/DBIx/Class/Storage/DBI/Replicated.pm index afd8d5c..37f13d7 100644 --- a/lib/DBIx/Class/Storage/DBI/Replicated.pm +++ b/lib/DBIx/Class/Storage/DBI/Replicated.pm @@ -367,12 +367,6 @@ has 'write_handler' => ( _dbh_sth _dbh_execute _prefetch_insert_auto_nextvals - /, - - # TODO these need to be spread out to ALL servers not just the master - qw/ - _get_server_version - _server_info _server_info_hash /], ); @@ -1016,6 +1010,33 @@ sub _ping { return min map $_->_ping, $self->all_storages; } +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]; + + $self->_server_info_hash($min_version_info); # on master + } + + return $self->_server_info_hash; +} + +sub _get_server_version { + my $self = shift; + + return $self->_server_info->{dbms_version}; +} + =head1 GOTCHAS Due to the fact that replicants can lag behind a master, you must take care to