Added Transation statements.

git-svn-id: https://oss.gonicus.de/repositories/gosa/trunk@8345 594d385d-05f5-0310-b6e9-bd551577e9d8

diff --git a/gosa-si/modules/DBsqlite.pm b/gosa-si/modules/DBsqlite.pm
index 21d7200711fdf77b3a7046b171f4f59c602c6c92..97e843506a327aad737ef004830f89480cfb9714 100644 (file)
--- a/gosa-si/modules/DBsqlite.pm
+++ b/gosa-si/modules/DBsqlite.pm
@@ -90,7 +90,7 @@ sub add_dbentry {
             }
         }    
 
-        my $sql_statement = " INSERT INTO $table VALUES ('".join("', '", @add_list)."')";
+        my $sql_statement = "BEGIN TRANSACTION; INSERT INTO $table VALUES ('".join("', '", @add_list)."'); COMMIT;";
         my $db_res = $obj->{dbh}->do($sql_statement);
         if( $db_res != 1 ) {
             return 1;
@@ -168,7 +168,7 @@ sub update_dbentry {
         $update_statement .= join(', ', @update_list);
     }
 
-    my $sql_statement = "UPDATE $table SET $update_statement $where_statement";
+    my $sql_statement = "BEGIN TRANSACTION; UPDATE $table SET $update_statement $where_statement; COMMIT;";
     my $db_answer = $obj->{dbh}->do($sql_statement);
     return $db_answer;
 }  
@@ -204,7 +204,7 @@ sub del_dbentry {
         $where_statement = "WHERE ".join(' AND ', @del_list);
     }
 
-    my $sql_statement = "DELETE FROM $table $where_statement";
+    my $sql_statement = "BEGIN TRANSACTION; DELETE FROM $table $where_statement; COMMIT;";
     my $db_res = $obj->{dbh}->do($sql_statement);
  
     return $db_res;

diff --git a/gosa-si/modules/GosaPackages.pm b/gosa-si/modules/GosaPackages.pm
index b53919b5d93554f1884876cc28c148c6546e332d..278752c50ff229fdce385f31ff905ebd9753d93d 100644 (file)
--- a/gosa-si/modules/GosaPackages.pm
+++ b/gosa-si/modules/GosaPackages.pm
@@ -333,7 +333,7 @@ sub process_incoming_msg {
 
     if ($out_msg =~ /<jobdb_id>(\d*?)<\/jobdb_id>/) {
         my $job_id = $1;
-        my $sql = "UPDATE '$main::job_queue_table_name' SET status='done', result='$out_msg' WHERE id='$job_id'";
+        my $sql = "BEGIN TRANSATION; UPDATE '$main::job_queue_table_name' SET status='done', result='$out_msg' WHERE id='$job_id'; COMMIT;";
         my $res = $main::job_db->exec_statement($sql);
         return;