--- db/prgsrc/updatedb.pl 2000/10/20 03:18:38 1.11 +++ db/prgsrc/updatedb.pl 2003/02/24 13:59:27 1.35 @@ -6,13 +6,19 @@ updatedb.pl - a script for creation of n =head1 SYNOPSIS -updatedb.pl I I.... +updatedb.pl B<[-i]> I I.... =head1 DESCRIPTION Updates information in the B databse. Uses file +=head1 OPTIONS + +=item B<-i> + +Ask about ParentId. + =head1 BUGS @@ -22,10 +28,19 @@ The database, user and password are hard Dmitry Rubinstein -=head1 $Id: updatedb.pl,v 1.11 2000/10/20 03:18:38 boris Exp $ +=head1 $Id: updatedb.pl,v 1.35 2003/02/24 13:59:27 roma7 Exp $ =cut +use vars qw($opt_i); + +use Getopt::Std; +my $unsortedname="../dump/unsorted"; +getopts('i'); +#open STDERR, ">errors"; +my $Interactive=$opt_i || 0; +my $DUMPDIR = $ENV{DUMPDIR} || "../dump"; + my (%RevMonths) = ('Jan', '1', 'Feb', '2', 'Mar', '3', 'Apr', '4', 'May', '5', 'Jun', '6', 'Jul', '7', 'Aug', '8', 'Sep', '9', 'Oct', '10', 'Nov', '11', @@ -33,18 +48,18 @@ my (%RevMonths) = 'JAN', '1', 'FEB', '2', 'MAR', '3', 'APR', '4', 'MAY', '5', 'JUN', '6', 'JUL', '7', 'AUG', '8', 'SEP', '9', 'OCT', '10', 'NOV', '11', 'DEC', '12', - 'Янв', '0', 'Фев', 1, 'Мар', 2, 'Апр', 3, 'Май', '4', - 'Июн', '5', 'Июл', 6, 'Авг', '7', 'Сен', '8', - 'Окт', '9', 'Ноя', '19', 'Дек', '11'); + 'Янв', '1', 'Фев', '2', 'Мар', '3', 'Апр', '4', 'Май', '5', + 'Июн', '6', 'Июл', '7', 'Авг', '8', 'Сен', '9', + 'Окт', '10', 'Ноя', '11', 'Дек', '12'); my ($sth); -use vars qw($/); + use DBI; use strict; - +my $isunsorted=0; sub UpdateParents { my ($dbh, $ParentId, $all_qnum) = @_; if ($ParentId) { @@ -67,19 +82,23 @@ sub getField { s/[ ]//g; if ($key && /^\s*$/) { chomp $value; + $value =~ s/\s+$//; chomp $key; if ($key eq 'Дата') { $value =~ s/^(.*)-(.*)-(.*)$/$3-$2-$1/; - my($month) = $RevMonths{$2} || '000'; - $value =~ s/$2/$month/; + my($month) = $RevMonths{$2} || '01'; + $value =~ s/-(.*)-/-$month-/; + $value =~ s/-00*$/-01/; } + if ($key eq 'Автор') {$value=~s/\.$//;} $value = $dbh->quote($value); return ($key, $value); } next if (/^\s*$/); - if (/^(.*)[:\.][\s]*$/ && !$key) { + if (!$key && /^(.*?)[:\.]\s*(.*)$/s) { $key = $1; + $value=$2; next; } if ($key) { @@ -88,6 +107,7 @@ sub getField { } } if ($key && $value) { + $value=~s/\s+$//; $value = $dbh->quote($value); return ($key, $value); } @@ -97,30 +117,49 @@ sub getField { sub SelectGroup { my ($dbh, $source, $TourName) = @_; my ($sth, $ParentId, $i, @arr); - - $sth = $dbh->prepare("SELECT Id, Title FROM + + if ($Interactive) { + $sth = $dbh->prepare("SELECT Id, Title FROM Tournaments WHERE Type = 'Г'"); - $sth->execute; - print "Выберите группу для турнира:\n$TourName, файл $source\n\n"; - while (@arr=$sth->fetchrow) { - print "[$arr[0]] $arr[1]\n"; - } - $ParentId = ; - chomp $ParentId; - if (!$ParentId) { - print "Пропускаем файл $source\n"; - print STDERR "Файл $source отвергнут оператором\n"; - return (0,0); + $sth->execute; + print "Выберите группу для турнира:\n$TourName, файл $source\n\n"; + while (@arr=$sth->fetchrow) { + print "[$arr[0]] $arr[1]\n"; + } + $ParentId = ; + chomp $ParentId; + if (!$ParentId) { + print "Пропускаем файл $source\n"; + print STDERR "Файл $source отвергнут оператором\n"; + return (0,0); + } else { + print "Вы выбрали турнир: $ParentId\n"; + $sth = $dbh->prepare("INSERT INTO Tournaments + (Title, Type, ParentId, FileName) + VALUES ($TourName, 'Ч', $ParentId, + $source)"); + $sth->execute; + my $TournamentId = $sth->{mysql_insertid}; + return ($TournamentId,$ParentId); + } } else { - print "Вы выбрали турнир: $ParentId\n"; - $sth = $dbh->prepare("INSERT INTO Tournaments +# Теперь, если файла нет в дереве турниров, никаких вопросов не +# задаётся, а вместо этого он добавляется в группу 9999 + $ParentId = 9999; + my $tempsource=$source; + my $temptname=$TourName; + $tempsource=~s/^\'(.*)\'$/$1/; + $temptname=~s/^\'(.*)\'$/$1/; + print UNSORTED "$tempsource".((12 -length($source))x' ')."\t$temptname\n"; + $isunsorted=1; + $sth = $dbh->prepare("INSERT INTO Tournaments (Title, Type, ParentId, FileName) VALUES ($TourName, 'Ч', $ParentId, $source)"); - $sth->execute; - my $TournamentId = $sth->{mysql_insertid}; - return ($TournamentId,$ParentId); - } + $sth->execute; + my $TournamentId = $sth->{mysql_insertid}; + return ($TournamentId,$ParentId); + } } @@ -169,7 +208,7 @@ sub DeleteTournament { } my (@Tours) = &GetTours($dbh, $Id); foreach my $Tour (@Tours) { - DeleteTournament($dbh,$Tour,1); + DeleteTournament($dbh,$Tour,$Id,0,1); } my $sth = $dbh->prepare("DELETE FROM Questions WHERE ParentId=$Id"); @@ -197,20 +236,54 @@ sub GetTours { return @Tours; } +sub CreateTour { + my ($dbh,$title,$ParentId,$TourNum,$rh_defaults)=@_; + my $sth = $dbh->prepare("INSERT INTO Tournaments + (Title, Type, ParentId, Number) + VALUES ($title, 'Т', $ParentId, $TourNum)"); + $sth->execute; + my $TourId = $sth->{mysql_insertid}; + while (my ($key,$value)=each %$rh_defaults) { + &UpdateTournament($dbh, $TourId, $key, $value); + } + return $TourId; +} + MAIN: { my($key, $value, $addition); - + # + # Inherited fields for a Tour or Tournament + # + my %TourFields = ('Копирайт' => 'Copyright', + 'Инфо' => 'Info', 'URL' => 'URL', + 'Ссылка' => 'URL', 'Редактор' => 'Editors', + 'Обработан'=> 'EnteredBy', + 'Дата'=>'PlayedAt'); + # + # Inherited fields for a Question + # + my %QuestionFields = ('Тип'=> 'Type', 'Вид'=> 'Type', + 'Автор' => 'Authors', 'Рейтинг'=>'Rating', + 'Источник' => 'Sources', + 'Тема' => 'Topic'); + + my($source); my($dbh) = DBI->connect("DBI:mysql:chgk", "piataev", "") or die "Can't connect to DB chgk\n"; - + my @sources; + open UNSORTED, ">$unsortedname"; while ($source = shift) { + push @sources,glob($source); + } + foreach $source(@sources) { + my $TourNum=0; my($PlayedAt) = ''; my($QuestionId, $TourId, $TournamentId, $ParentId) = (0, 0, 0, 0); - my($tournum, $qnum, $all_qnum, $qtype) = (0, 0, 0, 'Ч'); + my($tournum, $qnum, $all_qnum) = (0, 0, 0); my (@d) = (localtime((stat($source))[9]))[5,4,3]; $d[1]++; $d[0]+=1900; @@ -222,6 +295,9 @@ MAIN: $source =~ s/^.*\/([^\/]*)$/$1/; $source = $dbh->quote($source); print STDERR "Файл: $source, дата: $CreatedAt "; + my %TourDefaults=('CreatedAt'=>$CreatedAt); + my %QuestionDefaults=(); + my %QuestionGlobalDefaults=('Type'=>$dbh->quote('Ч')); while (($key, $value) = getField(\*INFD, $dbh)) { last if (!$key); @@ -249,36 +325,31 @@ MAIN: WHERE Id=$TourId"); } $qnum = 0; - $sth = $dbh->prepare("INSERT INTO Tournaments - (Title, Type, ParentId, CreatedAt) - VALUES ($value, 'Т', $TournamentId, - $CreatedAt)"); - $sth->execute; - $TourId = $sth->{mysql_insertid}; - next; - } - if ($key =~ /Вид/ || $key =~ /Тип/) { - $qtype = $value; - $qtype =~ s/\'//g; - next; + $TourNum++; + $TourId=CreateTour($dbh,$value,$TournamentId,$TourNum, + \%TourDefaults); + %QuestionDefaults=%QuestionGlobalDefaults; + $QuestionId=0; + next; } if ($key =~ /Вопрос/) { if (!$TourId) { $qnum = 0; - $sth = $dbh->prepare("INSERT INTO Tournaments - (Title, Type, ParentId, CreatedAt) - VALUES ('1', 'Т', $TournamentId, - $CreatedAt)"); - $sth->execute; - $TourId = $sth->{mysql_insertid}; + $TourNum++; + $TourId=CreateTour($dbh,'1',$TournamentId,$TourNum, + \%TourDefaults); + %QuestionDefaults=%QuestionGlobalDefaults; } my $query = "INSERT INTO Questions - (ParentId, Number, Type) - VALUES ($TourId, $qnum+1, \'$qtype\')"; + (ParentId, Number) + VALUES ($TourId, $qnum+1)"; $sth = $dbh->prepare($query); $sth->execute or print $query;; $QuestionId = $sth->{mysql_insertid}; &UpdateQuestion($dbh, $QuestionId, "Question", $value); + while (my ($key,$value)=each %QuestionDefaults) { + &UpdateQuestion($dbh, $QuestionId, $key, $value); + } $qnum++; $all_qnum++; next; @@ -289,67 +360,43 @@ MAIN: next; } - if ($key =~ /Рейтинг/) { - &UpdateQuestion($dbh, $QuestionId, "Rating", $value); - next; - } - - - if ($key =~ /Автор/) { - &UpdateQuestion($dbh, $QuestionId, "Authors", $value); - next; - } - - - if ($key =~ /Источник/) { - &UpdateQuestion($dbh, $QuestionId, "Sources", $value); - next; - } - - if ($key =~ /Комментари/) { &UpdateQuestion($dbh, $QuestionId, "Comments", $value); next; } + my @Fields = grep { $key =~ /$_/ } keys %QuestionFields; - if ($key =~ /URL/ || $key =~ /Ссылка/) { - &UpdateTournament($dbh, $TournamentId, "URL", $value); - next; - } - - - if ($key =~ /Копирайт/) { - &UpdateTournament($dbh, $TournamentId, "Copyright", $value); + if (scalar @Fields) { + my $word = shift @Fields; + my $field = $QuestionFields{$word}; + if ($QuestionId) { + &UpdateQuestion($dbh, $QuestionId, $field, $value); + } elsif ($TourId) { + $QuestionDefaults{$field}=$value; + } else { + $QuestionGlobalDefaults{$field}=$value; + } next; } - - if ($key =~ /Инфо/) { - &UpdateTournament($dbh, $TournamentId, "Info", $value); - next; - } - + @Fields = grep { $key =~ /$_/ } keys %TourFields; - if ($key =~ /Редактор/) { - &UpdateTournament($dbh, $TournamentId, "Editors", $value); - next; - } - - - if ($key =~ /Обработан/) { - &UpdateTournament($dbh, $TournamentId, "EnteredBy", $value); - next; - } - - if ($key =~ /Дата/) { - if ($TourId) { - &UpdateTournament($dbh, $TourId, "PlayedAt", $value); + if (scalar @Fields) { + my $word = shift @Fields; + my $field = $TourFields{$word}; + if ($QuestionId) { + print STDERR "ОШИБКА: $key $value недопустимы после", + " начала вопросов\n"; + } elsif ($TourId) { + &UpdateTournament($dbh, $TourId, $field, $value); } else { - &UpdateTournament($dbh, $TournamentId, "PlayedAt", $value); + &UpdateTournament($dbh, $TournamentId, $field, $value); + $TourDefaults{$field}=$value; } next; } + # # If we are here, something got wrong! @@ -364,5 +411,7 @@ MAIN: &UpdateParents($dbh, $ParentId, $all_qnum); print STDERR "Всего вопросов: $all_qnum \n"; } + close UNSORTED; + unlink $unsortedname unless $isunsorted; $dbh->disconnect; }