X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2Fmysql.pm;h=6224d5323e66a344c0341a19ed1de896a27e1561;hb=0bd8e0585b592d2583f28b6922b47afa78559cf4;hp=3e54a025743d8bc7ca56755d792f1075ef6b2af4;hpb=5cf7285e8d248e01718a3d691208a469c5dee1d1;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 3e54a02..6224d53 100644 --- a/lib/DBIx/Class/Storage/DBI/mysql.pm +++ b/lib/DBIx/Class/Storage/DBI/mysql.pm @@ -3,7 +3,12 @@ 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__->sql_maker_class('DBIx::Class::SQLAHacks::MySQL'); @@ -15,9 +20,11 @@ sub with_deferred_fk_checks { $self->_do_query('SET FOREIGN_KEY_CHECKS = 1'); } -sub connect_call_set_ansi_mode { +sub connect_call_set_strict_mode { my $self = shift; - $self->_do_query(q|SET SQL_MODE = 'ANSI,TRADITIONAL'|); + + # 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|); } @@ -33,28 +40,28 @@ sub sqlt_type { sub _svp_begin { my ($self, $name) = @_; - $self->dbh->do("SAVEPOINT $name"); + $self->_get_dbh->do("SAVEPOINT $name"); } sub _svp_release { my ($self, $name) = @_; - $self->dbh->do("RELEASE SAVEPOINT $name"); + $self->_get_dbh->do("RELEASE SAVEPOINT $name"); } sub _svp_rollback { my ($self, $name) = @_; - $self->dbh->do("ROLLBACK TO SAVEPOINT $name") + $self->_get_dbh->do("ROLLBACK TO SAVEPOINT $name") } - + sub is_replicating { - my $status = shift->dbh->selectrow_hashref('show slave status'); + my $status = shift->_get_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->_get_dbh->selectrow_hashref('show slave status')->{Seconds_Behind_Master}; } # MySql can not do subquery update/deletes, only way is slow per-row operations. @@ -63,38 +70,30 @@ sub _subq_update_delete { return shift->_per_row_update_delete (@_); } -# MySql chokes on things like: -# COUNT(*) FROM (SELECT tab1.col, tab2.col FROM tab1 JOIN tab2 ... ) -# claiming that col is a duplicate column (it loses the table specifiers by -# the time it gets to the *). Thus for any subquery count we select only the -# primary keys of the main table in the inner query. This hopefully still -# hits the indexes and keeps mysql happy. -# (mysql does not care if the SELECT and the GROUP BY match) -sub _subq_count_select { - my ($self, $source, $rs_attrs) = @_; - my @pcols = map { join '.', $rs_attrs->{alias}, $_ } ($source->primary_columns); - return @pcols ? \@pcols : [ 1 ]; -} - 1; =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, { on_connect_call => 'set_strict_mode' } ); =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