Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате
Форум программистов > Perl: Общие вопросы > Помогите оптимизировать код


Автор: gers 24.3.2008, 12:23
Доброго времени суток Уважаемые!
Вот написал код демона который висит и периодически лезет в бд mysql за информацией, но после нескольких часов, бывает дней появляется ошибка mysql server going away(точно непомню). Код рабочий, но с этой проблемой немогу справиться, почитав форумы узнал о InactiveDestroy, прописав ее проблема не исчезла, может быть вы натолкнете на ошибку?
часть проблеммного кода:

Код

while ($sock->recv($newmsg, $MAXLEN)) {
    my($port, $ipaddr) = sockaddr_in($sock->peername);
        my $call= IO::Socket::INET->new(PeerAddr => inet_ntoa($ipaddr), PeerPort => $PORTNO, Proto=> 'udp' ) or die "socket: $@";
        my $hishost = inet_ntoa($ipaddr);
        my $addr_bill = inet_aton_bill($hishost);
            if ($newmsg eq "deposit") {
                my ($sth, $balans);
                $db->{ InactiveDestroy } = 1;
                $sth = $db->prepare("SELECT * FROM users WHERE addr='$addr_bill'");
                $sth->execute();
                $balans = $sth->fetchrow_hashref();
                my $new = $db->prepare("select * from news ORDER BY time DESC LIMIT 1");
                $new->execute();
                my $news = $new->fetchrow_hashref();
                my $ppp = $db->prepare("SELECT * FROM sessions WHERE id_user=$balans->{'id'}");
                $ppp->execute();
                my $sess = $ppp->fetchrow_hashref();
                my ($ss, $mm, $hh, $dd, $mo, $y) = (localtime($news->{'time'}))[0,1,2,3,4,5];
                my $year = $y+1901;
                my $format_win = "$dd.$mo.$year $hh:$mm:$ss";
                my $data = $db->prepare("select sum(incoming), sum(outgoing) from data where id_user='$balans->{'id'}' and (log_time between '$sess->{'connected'}' and '".time()."')");
                $data->execute();
                my $traff = $data->fetchrow_hashref();
                my $tarif = $db->prepare("select * FROM tariffs WHERE id=$balans->{'id_tariff'}");
                $tarif->execute();
                my $period = $tarif->fetchrow_hashref();
                my $abonplata = $balans->{'last_period'} + $period->{'period'};
                $call->send($balans->{'deposit'}."|".$currency."|".$traff->{'sum(incoming)'}."|".$traff->{'sum(outgoing)'}."|".$balans->{'p_in'}."|".$balans->{'p_out'}."|".$abonplata."|".$format_win."|".$news->{'text'}."");
                }
        }
        $db->disconnect;
        die "recv: $!";

Автор: ginnie 24.3.2008, 12:43
Уважаемый gers, возможно, поможет

Код

$dbh->{mysql_auto_reconnect} = 1;


если включен AutoCommit.

Автор: KSURi 24.3.2008, 15:02
Еще можно сделать отдельный тред, который, каждые N минут будет делать тестовый запрос ('SELECT 1' например). Что-нибудь вроде вот этого:
Код

threads->create(\&knock_knock, $db)->detach;
sub knock_knock {
    sleep 60 * 5;
    shift->prepare('SELECT 1')->execute
}

Автор: Bulat 29.3.2008, 14:52
При ошибке  mysql going away , как правило нужно рыть в сторону самой базы. На моей практике такая ошибка могла возникать, если в коде нет нормального дисконнекта от базы, не более того smile

Автор: gers 30.3.2008, 22:23
Код

$dbh->{mysql_auto_reconnect} = 1;

да, этот код помог моей проблеме,

подскажи еще по коду насколько безопасно сравнивать пришедшее значение переменной тут:
Код

if ($newmsg eq "deposit") 

я так понимаю если $newmsg подсунуть сформированную специальным образом , то можно ли навредить бд?

Автор: PanamOS 30.3.2008, 22:29
Цитата(gers @  30.3.2008,  22:23 Найти цитируемый пост)
$newmsg подсунуть сформированную специальным образом

думаю при таком жестком сравнении врятли.

Powered by Invision Power Board (http://www.invisionboard.com)
© Invision Power Services (http://www.invisionpower.com)