X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2Fmysql.pm;h=5c59d18e3fb7c826e75242db0a7f326f23b71009;hb=de5dc9efd2c3575f78a7dc71c50d571c9a17c38d;hp=19b035cccb07a9f096bd7ed2c84d96acc48704a7;hpb=adb3554a3f72bf9c9b267c5eb84a8401da64bf37;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/mysql.pm b/lib/DBIx/Class/Storage/DBI/mysql.pm index 19b035c..5c59d18 100644 --- a/lib/DBIx/Class/Storage/DBI/mysql.pm +++ b/lib/DBIx/Class/Storage/DBI/mysql.pm @@ -17,21 +17,30 @@ sub sqlt_type { } sub _svp_begin { - my ($self, $dbh, $name) = @_; + my ($self, $name) = @_; - $dbh->do("SAVEPOINT $name"); + $self->dbh->do("SAVEPOINT $name"); } sub _svp_release { - my ($self, $dbh, $name) = @_; + my ($self, $name) = @_; - $dbh->do("RELEASE SAVEPOINT $name"); + $self->dbh->do("RELEASE SAVEPOINT $name"); } sub _svp_rollback { - my ($self, $dbh, $name) = @_; + my ($self, $name) = @_; - $dbh->do("ROLLBACK TO SAVEPOINT $name") + $self->dbh->do("ROLLBACK TO SAVEPOINT $name") +} + +sub is_replicating { + my $self = shift @_; +} + +sub lag_behind_master { + my $self = shift @_; + return $self->dbh->selectrow_hashref('show slave status'); } 1;