From: Allen Day Date: Mon, 9 Jun 2003 03:20:16 +0000 (+0000) Subject: linktable traversal seems to be working! haven't tried the code yet, but it looks... X-Git-Tag: v0.02~49 X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=commitdiff_plain;h=df602cfb7afa9c39b370339d16d7518b657d4b37;p=dbsrgits%2FSQL-Translator.git linktable traversal seems to be working! haven't tried the code yet, but it looks good. --- diff --git a/lib/SQL/Translator/Producer/ClassDBI.pm b/lib/SQL/Translator/Producer/ClassDBI.pm index 1abfa0e..db10962 100755 --- a/lib/SQL/Translator/Producer/ClassDBI.pm +++ b/lib/SQL/Translator/Producer/ClassDBI.pm @@ -1,7 +1,7 @@ package SQL::Translator::Producer::ClassDBI; # ------------------------------------------------------------------- -# $Id: ClassDBI.pm,v 1.8 2003-06-09 01:55:12 kycl4rk Exp $ +# $Id: ClassDBI.pm,v 1.9 2003-06-09 03:20:16 allenday Exp $ # ------------------------------------------------------------------- # Copyright (C) 2003 Ying Zhang , # Allen Day , @@ -23,7 +23,7 @@ package SQL::Translator::Producer::ClassDBI; use strict; use vars qw[ $VERSION $DEBUG ]; -$VERSION = sprintf "%d.%02d", q$Revision: 1.8 $ =~ /(\d+)\.(\d+)/; +$VERSION = sprintf "%d.%02d", q$Revision: 1.9 $ =~ /(\d+)\.(\d+)/; $DEBUG = 1 unless defined $DEBUG; use SQL::Translator::Schema::Constants; @@ -35,21 +35,49 @@ sub produce { local $DEBUG = $translator->debug; my $no_comments = $translator->no_comments; my $schema = $translator->schema; - + my $create; $create .= header_comment(__PACKAGE__, "# ") unless ($no_comments); - + $create .= "package " . $translator->format_package_name('DBI'). ";\n\n"; - + $create .= "my \$USER = '';\n"; $create .= "my \$PASS = '';\n\n"; - + my $from = _from($translator->parser_type()); - + $create .= "use base 'Class::DBI::$from';\n\n" . $translator->format_package_name('DBI') . "->set_db('Main', 'dbi:$from:_', \$USER, \$PASS);\n\n"; - + + + # + # Identify link tables, defined as tables that have only PK and FK + # fields + # + my %linkable; + foreach my $table ($schema->get_tables) { + my $is_link = 1; + foreach my $field ($table->get_fields){ + $is_link = 0 and last unless $field->is_primary_key or $field->is_foreign_key; + } + + if($is_link){ + foreach my $left ($table->get_fields){ + next unless $left->is_foreign_key; + foreach my $right ($table->get_fields){ + next unless $right->is_foreign_key; + + $linkable{$left->foreign_key_reference->reference_table} + {$right->foreign_key_reference->reference_table} = $table; + $linkable{$right->foreign_key_reference->reference_table} + {$left->foreign_key_reference->reference_table} = $table; + } + } + } + + } + # # Iterate over all tables # @@ -58,34 +86,33 @@ sub produce { my %pk; unless ( $no_comments ) { - $create .= + $create .= "#\n# Package: " . - $translator->format_package_name($table_name). - "\n#\n" + $translator->format_package_name($table_name). + "\n#\n" } - $create .= "package ". - $translator->format_package_name($table_name). ";\n"; + $create .= "package ".$translator->format_package_name($table_name).";\n"; + $create .= "use base ".$translator->format_package_name('DBI').";\n"; $create .= "use mixin 'Class::DBI::Join';\n"; $create .= "use Class::DBI::Pager;\n\n"; - - $create .= $translator->format_package_name($table_name). - "->set_up_table('$table_name');\n\n"; - + + $create .= $translator->format_package_name($table_name)."->set_up_table('$table_name');\n\n"; + # # Primary key? # foreach my $constraint ( $table->get_constraints ) { next unless $constraint->type eq PRIMARY_KEY; my $field = ($constraint->fields)[0]; - + $pk{ $table_name } = $field; $create .= "sub " .$translator->format_pk_name( $translator->format_package_name( $table_name ), $field ) . " { shift->".$field." }\n\n"; } - + # # Find foreign keys # @@ -106,6 +133,37 @@ sub produce { " {\n return shift->$field_name\n}\n\n"; } } + + my $is_data = 0; + map {(!$_->is_foreign_key and !$_->is_primary_key) ? $is_data++ : 0} $table->get_fields; + if($is_data){ + my %linked; + foreach my $field ( $table->get_fields ) { + if($field->is_foreign_key){ + my $fk = $field->foreign_key_reference; + +# next if $linked{($fk->reference_fields)[0]}; + next unless $linkable{$fk->reference_table}; + + foreach my $link (keys %{$linkable{$fk->reference_table}}){ + my $linkmethodname = "_".$translator->format_fk_name($fk->reference_table,$field->name)."_refs"; + + next if $linked{$linkmethodname}; + + $create .= $translator->format_package_name($table_name). + "->has_many('$linkmethodname','". + $translator->format_package_name($linkable{$fk->reference_table}{$link}->name)."','". + ($fk->reference_fields)[0]."');\n"; + $create .= "sub ". $translator->format_fk_name($fk->reference_table,$field->name). +####HARDCODED S HERE. ADD CALLBACK FOR PLURALIZATION MANGLING + "s {\n my \$self = shift; return map \$_->".($fk->reference_fields)[0].", \$self->".$linkmethodname.";\n}\n\n"; + + $linked{$linkmethodname}++; + } + } + } + } + } $create .= '1;'; @@ -114,16 +172,16 @@ sub produce { # my $table_data = $data->{$table}; # my @fields = keys %{$table_data->{'fields'}}; # my %pk; -# +# # $create .= "##\n## Package: " .$translator->format_package_name($table). "\n##\n" unless $no_comments; # $create .= "package ". $translator->format_package_name($table). ";\n"; -# +# # $create .= "use base \'Chado::DBI\';\n"; # $create .= "use mixin \'Class::DBI::Join\';\n"; # $create .= "use Class::DBI::Pager;\n\n"; -# +# # $create .= $translator->format_package_name($table). "->set_up_table('$table');\n\n"; -# +# # # # # Primary key? # # @@ -132,7 +190,7 @@ sub produce { # my $type = $constraint->{'type'}; # my $ref_table = $constraint->{'reference_table'}; # my $ref_fields = $constraint->{'reference_fields'}; -# +# # if ( $type eq 'primary_key') { # $pk{$table} = $constraint->{'fields'}->[0]; # $create .= "sub " .$translator->format_pk_name( @@ -141,7 +199,7 @@ sub produce { # ) . " { shift->".$constraint->{'fields'}->[0]." }\n\n"; # } # } -# +# # # # # Foreign key? # # @@ -151,9 +209,9 @@ sub produce { # my $ref_table = $field_data->[1]->{'reference_table'}; # my $ref_field = $field_data->[1]->{'reference_fields'}->[0]; # my $field = $field_data->[1]->{'fields'}->[0]; -# +# # if ($type eq 'foreign_key') { -# +# # #THIS IS IMPOSSIBLE UNTIL WE HAVE A BETTER DATA MODEL. THIS GIANT HASH SUCKS !!! # # my $r_link = 0; #not a link table (yet) # # my $r_linkthis = 0; @@ -164,27 +222,27 @@ sub produce { # # foreach my $r_field ( keys %{$r_table->{'fields'}} ){ # # $r_linkthis++ and next if $r_field eq $ref_field; #remote table links to local table # # if($r_table->{'fields'}->{$r_field}->{'constraints'}){ -# +# # # foreach my $r_constraint ($r_table->{'fields'}->{$r_field}->{'constraints'}){ # # $create .= Dumper($r_constraint); # # } -# +# # # } else { # # $r_linkdata++; #if not constraints, assume it's data (safe?) # # } # # foreach my $r_constraint ( @{ $r_table->{'fields'}->{$r_field}->{'constraints'} } ) { # # next unless $r_constraint->{'constraint_type'} eq 'foreign_key'; -# +# # # $r_linkthat++ unless $r_constraint->{'reference_table'} eq $table; #remote table links to non-local table # # } # # } -# +# # # my $link = $r_linkthis && $r_linkthat && !$r_linkdata ? '_link' : ''; # $create .= $translator->format_package_name($table). "->hasa(" .$translator->format_package_name($ref_table). " => \'$field\');\n"; # $create .= "sub " .$translator->format_fk_name($ref_table, $field)." { return shift->$field }\n\n"; # } # } -# +# # #THIS IS IMPOSSIBLE UNTIL WE HAVE A BETTER DATA MODEL. THIS GIANT HASH SUCKS !!! # # # # # # Remote foreign key? @@ -196,31 +254,31 @@ sub produce { # # next if $remote_table eq $table; # # # print "********".$remote_table."\n"; # # my $remote_table_data = $data->{$remote_table}; -# +# # # foreach my $remote_field ( keys %{$remote_table_data->{'fields'}} ){ # # foreach my $remote_constraint ( @{ $remote_table_data->{'fields'}->{$remote_field}->{'constraints'} } ) { # # next unless $remote_constraint->{'constraint_type'} eq 'foreign_key'; #only interested in foreign keys... -# +# # # $refers{$remote_table} = 1 if $pk{$remote_constraint->{'reference_table'}} ;#eq $remote_constraint->{'reference_fields'}->[0]; # # } # # } # # } -# +# # # foreach my $refer (keys %refers){ # # foreach my $refer_field ( keys %{$data->{$refer}->{'fields'}} ){ # # foreach my $refer_constraint ( @{ $data->{$refer}->{'fields'}->{$refer_field}->{'constraints'} } ) { # # next unless $refer_constraint->{'constraint_type'} eq 'foreign_key'; #only interested in foreign keys... # # next if $refer_constraint->{'reference_table'} eq $table; #don't want to consider the current table vs itself # # print "********".$refer."\t".$refer_field."\t****\t".$refer_constraint->{'reference_table'}."\t".$refer_constraint->{'reference_fields'}->[0]."\n"; -# +# # # $create .= "****sub " .$translator->format_fk_name($refer_constraint->{'reference_table'}, $refer_constraint->{'reference_fields'}->[0]). " { return shift->".$refer_constraint->{'reference_fields'}->[0]." }\n\n"; # # } # # } # # } -# +# # $create .= "1;\n\n\n"; # } - + return $create; } @@ -229,7 +287,7 @@ sub _from { my $from = shift; my @temp = split(/::/, $from); $from = $temp[$#temp]; - + if ( $from eq 'MySQL') { $from = lc($from); } elsif ( $from eq 'PostgreSQL') { @@ -239,7 +297,7 @@ sub _from { } else { die "__PACKAGE__ can't handle vendor $from"; } - + return $from; }