1 package DBIx::Class::Schema::Loader::mysql;
4 use base 'DBIx::Class::Schema::Loader::Generic';
9 DBIx::Class::Schema::Loader::mysql - DBIx::Schema::Class::Loader mysql Implementation.
13 use DBIx::Class::Schema::Loader;
15 # $loader is a DBIx::Class::Schema::Loader::mysql
16 my $loader = DBIx::Class::Schema::Loader->new(
17 dsn => "dbi:mysql:dbname",
24 See L<DBIx::Class::Schema::Loader>.
29 return qw/DBIx::Class::PK::Auto::MySQL/;
32 # Very experimental and untested!
35 my @tables = $class->tables;
36 my $dbh = $class->storage->dbh;
37 my $dsn = $class->loader_data->{_datasource}[0];
39 $dsn =~ m/\Adbi:\w+(?:\(.*?\))?:(.+)\z/i
40 && index( $1, '=' ) >= 0
43 my $dbname = $conn{database} || $conn{dbname} || $conn{db};
44 die("Can't figure out the table name automatically.") if !$dbname;
46 foreach my $table (@tables) {
47 my $query = "SHOW CREATE TABLE ${dbname}.${table}";
48 my $sth = $dbh->prepare($query)
49 or die("Cannot get table definition: $table");
51 my $table_def = $sth->fetchrow_arrayref->[1] || '';
53 my (@cols) = ($table_def =~ /CONSTRAINT `.*` FOREIGN KEY \(`(.*)`\) REFERENCES `(.*)` \(`(.*)`\)/g);
55 while (scalar @cols > 0) {
56 my $column = shift @cols;
57 my $remote_table = shift @cols;
58 my $remote_column = shift @cols;
60 eval { $class->_belongs_to_many( $table, $column, $remote_table, $remote_column) };
61 warn qq/\# belongs_to_many failed "$@"\n\n/ if $@ && $class->debug_loader;
70 my $dbh = $class->storage->dbh;
72 foreach my $table ( $dbh->tables ) {
73 my $quoter = $dbh->get_info(29);
74 $table =~ s/$quoter//g if ($quoter);
76 if $table =~ /\A(\w+)\z/;
82 my ( $class, $table ) = @_;
83 my $dbh = $class->storage->dbh;
85 # MySQL 4.x doesn't support quoted tables
86 my $query = "DESCRIBE $table";
87 my $sth = $dbh->prepare($query) or die("Cannot get table status: $table");
90 while ( my $hash = $sth->fetchrow_hashref ) {
91 my ($col) = $hash->{Field} =~ /(\w+)/;
93 push @pri, $col if $hash->{Key} eq "PRI";
96 return ( \@cols, \@pri );
101 L<DBIx::Class::Schema::Loader>