X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2Fmysql.pm;h=6510f7ace1a5ad8e05c1e956fe1f661e6ec8932e;hb=a52c8b220cc34804bf227aea8682aec7c0f10b99;hp=dcdeafe744490556981ea43d7e20b5cf638751e6;hpb=ab807c129724c2be1ce02acf8a5c8f68d149421d;p=dbsrgits%2FDBIx-Class-Historic.git diff --git a/lib/DBIx/Class/Storage/DBI/mysql.pm b/lib/DBIx/Class/Storage/DBI/mysql.pm index dcdeafe..6510f7a 100644 --- a/lib/DBIx/Class/Storage/DBI/mysql.pm +++ b/lib/DBIx/Class/Storage/DBI/mysql.pm @@ -3,16 +3,29 @@ package DBIx::Class::Storage::DBI::mysql; use strict; use warnings; -use base qw/DBIx::Class::Storage::DBI::MultiColumnIn/; +use base qw/ + DBIx::Class::Storage::DBI::MultiColumnIn + DBIx::Class::Storage::DBI::AmbiguousGlob + DBIx::Class::Storage::DBI +/; +use mro 'c3'; -# __PACKAGE__->load_components(qw/PK::Auto/); +__PACKAGE__->sql_maker_class('DBIx::Class::SQLAHacks::MySQL'); sub with_deferred_fk_checks { my ($self, $sub) = @_; - $self->dbh->do('SET foreign_key_checks=0'); + $self->_do_query('SET FOREIGN_KEY_CHECKS = 0'); $sub->(); - $self->dbh->do('SET foreign_key_checks=1'); + $self->_do_query('SET FOREIGN_KEY_CHECKS = 1'); +} + +sub connect_call_set_strict_mode { + my $self = shift; + + # the @@sql_mode puts back what was previously set on the session handle + $self->_do_query(q|SET SQL_MODE = CONCAT('ANSI,TRADITIONAL,ONLY_FULL_GROUP_BY,', @@sql_mode)|); + $self->_do_query(q|SET SQL_AUTO_IS_NULL = 0|); } sub _dbh_last_insert_id { @@ -27,33 +40,33 @@ sub sqlt_type { sub _svp_begin { my ($self, $name) = @_; - $self->dbh->do("SAVEPOINT $name"); + $self->last_dbh->do("SAVEPOINT $name"); } sub _svp_release { my ($self, $name) = @_; - $self->dbh->do("RELEASE SAVEPOINT $name"); + $self->last_dbh->do("RELEASE SAVEPOINT $name"); } sub _svp_rollback { my ($self, $name) = @_; - $self->dbh->do("ROLLBACK TO SAVEPOINT $name") + $self->last_dbh->do("ROLLBACK TO SAVEPOINT $name") } - + sub is_replicating { - my $status = shift->dbh->selectrow_hashref('show slave status'); + my $status = shift->last_dbh->selectrow_hashref('show slave status'); return ($status->{Slave_IO_Running} eq 'Yes') && ($status->{Slave_SQL_Running} eq 'Yes'); } sub lag_behind_master { - return shift->dbh->selectrow_hashref('show slave status')->{Seconds_Behind_Master}; + return shift->last_dbh->selectrow_hashref('show slave status')->{Seconds_Behind_Master}; } # MySql can not do subquery update/deletes, only way is slow per-row operations. # This assumes you have set proper transaction isolation and use innodb. -sub subq_update_delete { +sub _subq_update_delete { return shift->_per_row_update_delete (@_); } @@ -61,21 +74,26 @@ sub subq_update_delete { =head1 NAME -DBIx::Class::Storage::DBI::mysql - Automatic primary key class for MySQL +DBIx::Class::Storage::DBI::mysql - Storage::DBI class implementing MySQL specifics =head1 SYNOPSIS - # In your table classes - __PACKAGE__->load_components(qw/PK::Auto Core/); - __PACKAGE__->set_primary_key('id'); +Storage::DBI autodetects the underlying MySQL database, and re-blesses the +C<$storage> object into this class. + + my $schema = MyDb::Schema->connect( $dsn, $user, $pass, { set_strict_mode => 1 } ); =head1 DESCRIPTION -This class implements autoincrements for MySQL. +This class implements MySQL specific bits of L. + +It also provides a one-stop on-connect macro C which sets +session variables such that MySQL behaves more predictably as far as the +SQL standard is concerned. =head1 AUTHORS -Matt S. Trout +See L =head1 LICENSE