Обработка критических ошибок DBD :: Ошибки ODBC

Question

У меня есть простой скрипт Perl, который прослушивает сетевой порт, принимает данные и записывает данные в базу данных с использованием DBD :: ODBC. Это выглядит примерно так:

#!/usr/bin/perl 
my $dbh = DBI->connect('dbi:ODBC:SqlProd',"yay","ooo",{AutoCommit => 0}) || die "Couldn't connect to db"; 
my $sth = $dbh->prepare("insert into table some stuff"); 

$sock = IO::Socket::INET->new(LocalPort => '1234', Proto => 'udp')||die("Socket: $@"); 
do { 
    $sock->recv($buf, $MAXLEN); 

    /*parse some data here*/ 
    /*bind some parameters to $sth here*/ 

    my $rv = $sth->execute() || warn logit('warning', "Error inserting to db: $! $msg"); 
    $dbh->commit() || warn logit('err',"Error committing db transaction: $! $msg"); 

}while(1); 

Это, будучи немного сырым, работает достаточно хорошо. Однако, по неизвестным причинам, база данных идет вниз и сценарий аварий говорить вещи, как:

DBD::ODBC::st execute failed: [unixODBC][FreeTDS][SQL Server]Write to the server failed  (SQL-08S01) at /usr/local/bin/haproxy-syslog line 117. 
0 at /usr/local/bin/haproxy-syslog line 117. 
DBD::ODBC::db commit failed: [unixODBC][FreeTDS][SQL Server]Could not perform COMMIT or  ROLLBACK (SQL-HY000) at /usr/local/bin/haproxy-syslog line 118. 
Error committing db transaction: Connection reset by peer 
DBD::ODBC::db DESTROY failed: [unixODBC][FreeTDS][SQL Server]Could not perform COMMIT or ROLLBACK (SQL-HY000) during global destruction. 

Если бы я хотел сценарий быть resiliant к такого рода неудачи, либо просто ждет в течение заданного периода времени и увидев, что если база данных снова проснулась или отбросила полученные данные и вытащила больше данных из сокета, что было бы лучшим способом обойти это? Вызывает ли вышеупомянутая ошибка, что $ dbh заканчивается нежелательным и нуждается в повторной инициализации?

Answer 1

Проблема вызвана тем, что несмотря на то, что функция execute() не работает, вы все равно вызываете commit(). Поскольку соединение отсутствует, вы не можете отправить БД на вызов фиксации. Кроме того, похоже, что у вас есть AutoCommit, так что БД пытается закрыть любые открытые транзакции при удалении соединения в вызове DESTROY.

Вы могли бы попробовать что-то вроде этого (простите мой ржавый Perl):

do { 
    $sock->recv($buf, $MAXLEN); 

    # parse some data here 
    # bind some parameters to $sth here 

    my $rv = $sth->execute() || warn logit('warning', "Error inserting to db: $! $msg"); 
    if ($msg ~= /connection reset/i) 
    { 
     warn logit('warning', "Connection disconnected."); 
     $sth->disconnect(); 
     break; # exit while 
    } 
    $dbh->commit() || warn logit('err',"Error committing db transaction: $! $msg"); 

}while(1);