tbrehm
2008-12-20 4f68a7fe3e250d59c0fc17304c6ea227d22ebca1
server/lib/classes/modules.inc.php
@@ -88,12 +88,15 @@
         $records = $app->dbmaster->queryAllRecords($sql);
         foreach($records as $d) {
            
            $data = unserialize(stripslashes($d["data"]));
            if(!$data = unserialize(stripslashes($d["data"]))) {
               $data = unserialize($d["data"]);
            }
            $replication_error = false;
            
            $this->current_datalog_id = $d["datalog_id"];
            
            if($d["action"] == 'i') {
            if(count($data['new']) > 0) {
               if($d["action"] == 'i' || $d["action"] == 'u') {
               $idx = explode(":",$d["dbidx"]);
               $tmp_sql1 = '';
               $tmp_sql2 = '';
@@ -113,7 +116,7 @@
               }
               $app->log("Replicated from master: ".$sql,LOGLEVEL_DEBUG);
            }
               /*
            if($d["action"] == 'u') {
               $sql = "UPDATE $d[dbtable] SET ";
               foreach($data['new'] as $fieldname => $val) {
@@ -129,7 +132,7 @@
               }
               $app->log("Replicated from master: ".$sql,LOGLEVEL_DEBUG);
            }
               */
            if($d["action"] == 'd') {
               $idx = explode(":",$d["dbidx"]);
               $sql = "DELETE FROM $d[dbtable] ";
@@ -157,6 +160,9 @@
                */
               return;
            }
            } else {
               $app->log("Datalog does not conatin any changes for this record ".$d["datalog_id"],LOGLEVEL_DEBUG);
            }
         }
         
      //* if we have a single server setup
@@ -164,7 +170,9 @@
         $sql = "SELECT * FROM sys_datalog WHERE datalog_id > ".$conf['last_datalog_id']." AND (server_id = ".$conf["server_id"]." OR server_id = 0) ORDER BY datalog_id";
         $records = $app->db->queryAllRecords($sql);
         foreach($records as $d) {
            $data = unserialize(stripslashes($d["data"]));
            if(!$data = unserialize(stripslashes($d["data"]))) {
               $data = unserialize($d["data"]);
            }
            $this->current_datalog_id = $d["datalog_id"];
            $this->raiseTableHook($d["dbtable"],$d["action"],$data);
            //$app->db->query("DELETE FROM sys_datalog WHERE datalog_id = ".$rec["datalog_id"]);