Disable the RaiseError on the DBH, use HandleError

reyjrar · Dec 21, 2012 · ffee39b · ffee39b
1 parent 815331a
commit ffee39b
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 11 deletions.
diff --git a/bin/dnsmon_sniffer.pl b/bin/dnsmon_sniffer.pl
@@ -80,7 +80,12 @@ sub POE::Kernel::ASSERT_DEFAULT () { 1 }
 if( exists $CFG->{db} && ref $CFG->{db} eq 'HASH' ) {
     try {
         $dbConn = DBIx::Connector->new( $CFG->{db}{dsn}, $CFG->{db}{user}, $CFG->{db}{pass},
-            { RaiseError => 1 }
+            {
+                RaiseError => 0,
+                HandleError => sub {
+                    $poe_kernel->post( 'log' => debug => shift );
+                }
+            }
         );
     };
 }

diff --git a/lib/POE/Component/dns/monitor/sniffer/plugin/packet/store.pm b/lib/POE/Component/dns/monitor/sniffer/plugin/packet/store.pm
@@ -132,16 +132,21 @@ sub process {
 
                 next unless defined $data{value} && length $data{value};
 
-                $heap->{sth}{answer}->execute(
-                    $response_id,
-                    $set->{name},
-                    $pa->ttl,
-                    $pa->class,
-                    $pa->type,
-                    $pa->name,
-                    $data{value},
-                    $data{opts},
-                );
+                try {
+                    my $rc = $heap->{sth}{answer}->execute(
+                        $response_id,
+                        $set->{name},
+                        $pa->ttl,
+                        $pa->class,
+                        $pa->type,
+                        $pa->name,
+                        $data{value},
+                        $data{opts},
+                    );
+                    die "error" unless $rc;
+                } catch {
+                    $kernel->post( $heap->{log} => error => 'Failed to store details for [' . join(' ', $pa->class, $pa->type, $pa->name, $pa->ttl) . "] as $data{value}");
+                };
             }
         }
     }