lib/DBIx/Class/Storage/DBI/mysql.pm

   1 package DBIx::Class::Storage::DBI::mysql;
   2
   3 use strict;
   4 use warnings;
   5
   6 use base qw/DBIx::Class::Storage::DBI::MultiColumnIn/;
   7
   8 __PACKAGE__->sql_maker_class('DBIx::Class::SQLAHacks::MySQL');
   9
  10 sub with_deferred_fk_checks {
  11   my ($self, $sub) = @_;
  12
  13   $self->dbh->do('SET foreign_key_checks=0');
  14   $sub->();
  15   $self->dbh->do('SET foreign_key_checks=1');
  16 }
  17
  18 sub _dbh_last_insert_id {
  19   my ($self, $dbh, $source, $col) = @_;
  20   $dbh->{mysql_insertid};
  21 }
  22
  23 sub sqlt_type {
  24   return 'MySQL';
  25 }
  26
  27 sub _svp_begin {
  28     my ($self, $name) = @_;
  29
  30     $self->dbh->do("SAVEPOINT $name");
  31 }
  32
  33 sub _svp_release {
  34     my ($self, $name) = @_;
  35
  36     $self->dbh->do("RELEASE SAVEPOINT $name");
  37 }
  38
  39 sub _svp_rollback {
  40     my ($self, $name) = @_;
  41
  42     $self->dbh->do("ROLLBACK TO SAVEPOINT $name")
  43 }
  44
  45 sub is_replicating {
  46     my $status = shift->dbh->selectrow_hashref('show slave status');
  47     return ($status->{Slave_IO_Running} eq 'Yes') && ($status->{Slave_SQL_Running} eq 'Yes');
  48 }
  49
  50 sub lag_behind_master {
  51     return shift->dbh->selectrow_hashref('show slave status')->{Seconds_Behind_Master};
  52 }
  53
  54 # MySql can not do subquery update/deletes, only way is slow per-row operations.
  55 # This assumes you have set proper transaction isolation and use innodb.
  56 sub _subq_update_delete {
  57   return shift->_per_row_update_delete (@_);
  58 }
  59
  60 # MySql chokes on things like:
  61 # COUNT(*) FROM (SELECT tab1.col, tab2.col FROM tab1 JOIN tab2 ... )
  62 # claiming that col is a duplicate column (it loses the table specifiers by
  63 # the time it gets to the *). Thus for any subquery count we select only the
  64 # primary keys of the main table in the inner query. This hopefully still
  65 # hits the indexes and keeps mysql happy.
  66 # (mysql does not care if the SELECT and the GROUP BY match)
  67 sub _grouped_count_select {
  68   my ($self, $source, $rs_args) = @_;
  69   my @pcols = map { join '.', $rs_args->{alias}, $_ } ($source->primary_columns);
  70   return @pcols ? \@pcols : $rs_args->{group_by};
  71 }
  72
  73 1;
  74
  75 =head1 NAME
  76
  77 DBIx::Class::Storage::DBI::mysql - Automatic primary key class for MySQL
  78
  79 =head1 SYNOPSIS
  80
  81   # In your table classes
  82   __PACKAGE__->load_components(qw/PK::Auto Core/);
  83   __PACKAGE__->set_primary_key('id');
  84
  85 =head1 DESCRIPTION
  86
  87 This class implements autoincrements for MySQL.
  88
  89 =head1 AUTHORS
  90
  91 Matt S. Trout <mst@shadowcatsystems.co.uk>
  92
  93 =head1 LICENSE
  94
  95 You may distribute this code under the same terms as Perl itself.
  96
  97 =cut