lib/SQLAbstraction/mysql.pm

   1 package SQLAbstraction::mysql;
   2
   3 use strict;
   4
   5 =head1 NAME
   6
   7 SQLAbstraction::mysql - Implementation of SQLAbstraction for mysql.
   8
   9 =cut
  10
  11 use SQLAbstraction;
  12
  13 use base qw(SQLAbstraction);
  14 use fields qw( dbhost dbname dbuser dbpassword );
  15
  16 use Carp;
  17
  18 use UTF8DBI;
  19
  20 sub new {
  21   my SQLAbstraction::mysql $self = shift;
  22   my( $p, $first ) = @_;
  23
  24   if( not ref $self ) {
  25     $self = fields::new($self);
  26   }
  27   $self->SUPER::new( $p, 1 );
  28
  29   my @required_params = qw( dbhost dbname dbuser dbpassword );
  30
  31   my %optional_params = ( );
  32
  33   # Initialize new properties.
  34   $self->init( $p, \@required_params, \%optional_params );
  35
  36   $self->check_unknown( $p, $first );
  37
  38   return $self;
  39 }
  40
  41 sub Connect {
  42   my SQLAbstraction::mysql $self = shift;
  43
  44   my $host = $self->{dbhost};
  45   my $database = $self->{dbname};
  46
  47   my $dsn = "DBI:mysql:database=$database;host=$host";
  48
  49   $self->{dbh} = UTF8DBI->connect($dsn, $self->{dbuser}, $self->{dbpassword})
  50       or die "Cannot connect: " . $DBI::errstr;
  51
  52   $self->{dbh}->do("set character set utf8");
  53   $self->{dbh}->do("set names utf8");
  54
  55   return 1;
  56 }
  57
  58 sub last_inserted_id {
  59   my SQLAbstraction::mysql $self = shift;
  60
  61   return $self->{dbh}->{'mysql_insertid'};
  62 }
  63
  64 1;
  65