Changeset 3856 for branches/centreon-1.4.2.4/ODS/lib/verifyHostServiceIdName.pm

Timestamp:

01/28/08 21:15:20 (11 months ago)

Author:

jmathis

Message:

 

Files:

• branches/centreon-1.4.2.4/ODS/lib/verifyHostServiceIdName.pm (modified) (9 diffs)

branches/centreon-1.4.2.4/ODS/lib/verifyHostServiceIdName.pm

@@ -23 +23 @@
 
 sub getLastRestart(){
-        my $sth1_oreon = $con_oreon->prepare("SELECT last_restart FROM nagios_server");
+        
+        # Create connection
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_oreon.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
+        
+        my $sth1_oreon = $con->prepare("SELECT last_restart FROM nagios_server");
     if (!$sth1_oreon->execute) {writeLogFile("Error - getLastRestart : " . $sth1_oreon->errstr . "\n");}
     my $data_oreon = $sth1_oreon->fetchrow_hashref();
     undef($sth1_oreon);
+    $con->disconnect();
     return $data_oreon->{'last_restart'};
 }
@@ -33 +38 @@
 
 sub getLastRestartInMemory(){
-        my $sth = $con_ods->prepare("SELECT last_restart FROM statistics");
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_ods.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
+        my $sth = $con->prepare("SELECT last_restart FROM statistics");
     if (!$sth->execute) {writeLogFile("Error - getLastRestartInMemory :" . $sth->errstr . "\n");}
     my $data = $sth->fetchrow_hashref();
     undef($sth);
+    $con->disconnect();
     return $data->{'last_restart'};
 }
 
 sub saveLastRestartInMemory($){
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_ods.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
         my $sth = $con_ods->prepare("UPDATE statistics SET `last_restart` = '".$_[0]."'");
-    if (!$sth->execute) {writeLogFile("Error - saveLastRestartInMemory : " . $sth->errstr . "\n");}
+    if (!$sth->execute) {
+        writeLogFile("Error - saveLastRestartInMemory : " . $sth->errstr . "\n");
+    }
+    $con->disconnect();
     undef($sth);
 }
@@ -49 +60 @@
 
 sub getPurgeConfig(){
-        my $sth = $con_ods->prepare("SELECT autodelete_rrd_db FROM config");
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_ods.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
+        my $sth = $con->prepare("SELECT autodelete_rrd_db FROM config");
     if (!$sth->execute) {writeLogFile("Error - getPurgeConfig :" . $sth->errstr . "\n");}
     my $data = $sth->fetchrow_hashref();
     undef($sth);
+    $con->disconnect();
     return $data->{'autodelete_rrd_db'};
 }
@@ -59 +72 @@
 
 sub getStorageDir(){
-        my $sth = $con_ods->prepare("SELECT RRDdatabase_path FROM config");
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_ods.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
+        my $sth = $con->prepare("SELECT RRDdatabase_path FROM config");
     if (!$sth->execute) {writeLogFile("Error - getStorageDir : " . $sth->errstr . "\n");}
     my $data = $sth->fetchrow_hashref();
     undef($sth);
+    $con->disconnect();
     return $data->{'RRDdatabase_path'};
 }
@@ -70 +85 @@
 sub DeleteOldRrdDB(){
         my ($data, %base);
-        my $sth = $con_ods->prepare("SELECT metric_id FROM metrics");
-    if (!$sth->execute) {writeLogFile("Error:" . $sth->errstr . "\n");}
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_ods.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
+        my $sth = $con->prepare("SELECT metric_id FROM metrics");
+    if (!$sth->execute) {
+        writeLogFile("Error:" . $sth->errstr . "\n");
+    }
     while ($data = $sth->fetchrow_hashref()){
         $base{$data->{'metric_id'}.".rrd"} = 1;
@@ -93 +111 @@
                         }
                 }
-        }     
+        }
+        $con->disconnect();
         undef($some_dir);
         undef(@files);
@@ -106 +125 @@
 sub check_HostServiceID(){
         my ($data, $host_name, $service_description, $purge_mod);
-        my $sth1 = $con_ods->prepare("SELECT * FROM index_data ORDER BY host_name");
+        $con = DBI->connect("DBI:mysql:database=".$mysql_database_ods.";host=".$mysql_host, $mysql_user, $mysql_passwd, {'RaiseError' => 0, 'PrintError' => 0, 'AutoCommit' => 1});
+        my $sth1 = $con->prepare("SELECT * FROM index_data ORDER BY host_name");
     if (!$sth1->execute) {writeLogFile("Error : " . $sth1->errstr . "\n");}
     while ($data = $sth1->fetchrow_hashref()){
@@ -113 +133 @@
         if (defined($host_name) && $host_name && defined($service_description) && $service_description && defined($data->{'host_name'}) && defined($data->{'service_description'}) && (($host_name ne $data->{'host_name'}) || ($service_description ne $data->{'service_description'}))){
                 $str =  "UPDATE index_data SET `host_name` = '".$host_name."', `service_description` = '".$service_description."' WHERE `host_id` = '".$data->{'host_id'}."' AND `service_id` = '".$data->{'service_id'}."'";
-                my $sth2 = $con_ods->prepare($str);
+                my $sth2 = $con->prepare($str);
                 writeLogFile("Error:" . $sth2->errstr . "\n") if (!$sth2->execute);
                 undef($sth2);
@@ -119 +139 @@
     }
         if (defined($last_restart) && $last_restart){
-                $sth1 = $con_ods->prepare("UPDATE statistics SET `last_restart` = '".$last_restart."'");
+                $sth1 = $con->prepare("UPDATE statistics SET `last_restart` = '".$last_restart."'");
                 if (!$sth1->execute) {writeLogFile("Error:" . $sth1->errstr . "\n");}
                 undef($sth1);
         }
+        $con->disconnect();
 }