X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=blobdiff_plain;f=lib%2FDBIx%2FClass%2FStorage%2FDBI%2Fmysql.pm;h=7d0ad04f9389d4bb2549a015616297e5c9ac0816;hb=HEAD;hp=90b9fe979e8f4992f3778b7de1bf707726ebf9dd;hpb=7c4de2c37d9577b3579fe6a1e621f95a36f50363;p=dbsrgits%2FDBIx-Class.git diff --git a/lib/DBIx/Class/Storage/DBI/mysql.pm b/lib/DBIx/Class/Storage/DBI/mysql.pm index 90b9fe9..7d0ad04 100644 --- a/lib/DBIx/Class/Storage/DBI/mysql.pm +++ b/lib/DBIx/Class/Storage/DBI/mysql.pm @@ -3,26 +3,28 @@ package DBIx::Class::Storage::DBI::mysql; use strict; use warnings; -use base qw/ - DBIx::Class::Storage::DBI::MultiColumnIn - DBIx::Class::Storage::DBI::AmbiguousGlob - DBIx::Class::Storage::DBI -/; +use base qw/DBIx::Class::Storage::DBI/; -__PACKAGE__->sql_maker_class('DBIx::Class::SQLAHacks::MySQL'); +__PACKAGE__->sql_maker_class('DBIx::Class::SQLMaker::MySQL'); +__PACKAGE__->sql_limit_dialect ('LimitXY'); +__PACKAGE__->sql_quote_char ('`'); + +__PACKAGE__->_use_multicolumn_in (1); 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_ansi_mode { +sub connect_call_set_strict_mode { my $self = shift; - $self->dbh->do(q|SET sql_mode = 'ANSI,TRADITIONAL'|); - $self->dbh->do(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|); } sub _dbh_last_insert_id { @@ -30,65 +32,191 @@ sub _dbh_last_insert_id { $dbh->{mysql_insertid}; } +sub _prep_for_execute { + my $self = shift; + #(my $op, $ident, $args) = @_; + + # Only update and delete need special double-subquery treatment + # Insert referencing the same table (i.e. SELECT MAX(id) + 1) seems + # to work just fine on MySQL + return $self->next::method(@_) if ( $_[0] eq 'select' or $_[0] eq 'insert' ); + + + # FIXME FIXME FIXME - this is a terrible, gross, incomplete, MySQL-specific + # hack but it works rather well for the limited amount of actual use cases + # which can not be done in any other way on MySQL. This allows us to fix + # some bugs without breaking MySQL support in the process and is also + # crucial for more complex things like Shadow to be usable + # + # This code is just a pre-analyzer, working in tandem with ::SQLMaker::MySQL, + # where the possibly-set value of {_modification_target_referenced_re} is + # used to demarcate which part of the final SQL to double-wrap in a subquery. + # + # This is covered extensively by "offline" tests, so when the DQ work + # resumes, this will get flagged. Afaik there are no AST-visitor code of that + # magnitude yet (Oct 2015) within DQ, so a good exercise overall. + + # extract the source name, construct modification indicator re + my $sm = $self->sql_maker; + + my $target_name = $_[1]->from; + + if (ref $target_name) { + if ( + ref $target_name eq 'SCALAR' + and + $$target_name =~ /^ (?: + \` ( [^`]+ ) \` #` + | ( [\w\-]+ ) + ) $/x + ) { + # this is just a plain-ish name, which has been literal-ed for + # whatever reason + $target_name = (defined $1) ? $1 : $2; + } + else { + # this is something very complex, perhaps a custom result source or whatnot + # can't deal with it + undef $target_name; + } + } + + local $sm->{_modification_target_referenced_re} = + qr/ (?next::method(@_); +} + +# here may seem like an odd place to override, but this is the first +# method called after we are connected *and* the driver is determined +# ($self is reblessed). See code flow in ::Storage::DBI::_populate_dbh +sub _run_connection_actions { + my $self = shift; + + # default mysql_auto_reconnect to off unless explicitly set + if ( + $self->_dbh->{mysql_auto_reconnect} + and + ! exists $self->_dbic_connect_attributes->{mysql_auto_reconnect} + ) { + $self->_dbh->{mysql_auto_reconnect} = 0; + } + + $self->next::method(@_); +} + +# we need to figure out what mysql version we're running +sub sql_maker { + my $self = shift; + + # it is critical to get the version *before* calling next::method + # otherwise the potential connect will obliterate the sql_maker + # next::method will populate in the _sql_maker accessor + my $mysql_ver = $self->_server_info->{normalized_dbms_version}; + + my $sm = $self->next::method(@_); + + # mysql 3 does not understand a bare JOIN + $sm->{_default_jointype} = 'INNER' if $mysql_ver < 4; + + $sm; +} + sub sqlt_type { return 'MySQL'; } -sub _svp_begin { +sub deployment_statements { + my $self = shift; + my ($schema, $type, $version, $dir, $sqltargs, @rest) = @_; + + $sqltargs ||= {}; + + if ( + ! exists $sqltargs->{producer_args}{mysql_version} + and + my $dver = $self->_server_info->{normalized_dbms_version} + ) { + $sqltargs->{producer_args}{mysql_version} = $dver; + } + + $self->next::method($schema, $type, $version, $dir, $sqltargs, @rest); +} + +sub _exec_svp_begin { my ($self, $name) = @_; - $self->dbh->do("SAVEPOINT $name"); + $self->_dbh->do("SAVEPOINT $name"); } -sub _svp_release { +sub _exec_svp_release { my ($self, $name) = @_; - $self->dbh->do("RELEASE SAVEPOINT $name"); + $self->_dbh->do("RELEASE SAVEPOINT $name"); } -sub _svp_rollback { +sub _exec_svp_rollback { my ($self, $name) = @_; - $self->dbh->do("ROLLBACK TO SAVEPOINT $name") + $self->_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}; -} - -# 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 { - return shift->_per_row_update_delete (@_); + return shift->_get_dbh->selectrow_hashref('show slave status')->{Seconds_Behind_Master}; } 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 = MyApp::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, +like AutoIncrement column support and savepoints. Also it augments the +SQL maker to support the MySQL-specific C join type, which +you can use by specifying C<< join_type => 'straight' >> in the +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 STORAGE OPTIONS + +=head2 set_strict_mode + +Enables session-wide strict options upon connecting. Equivalent to: -=head1 AUTHORS + ->connect ( ... , { + on_connect_do => [ + q|SET SQL_MODE = CONCAT('ANSI,TRADITIONAL,ONLY_FULL_GROUP_BY,', @@sql_mode)|, + q|SET SQL_AUTO_IS_NULL = 0|, + ] + }); -Matt S. Trout +=head1 FURTHER QUESTIONS? -=head1 LICENSE +Check the list of L. -You may distribute this code under the same terms as Perl itself. +=head1 COPYRIGHT AND LICENSE -=cut +This module is free software L +by the L. You can +redistribute it and/or modify it under the same terms as the +L.