@@ 415-421 (lines=7) @@ | ||
412 | // Doing queue |
|
413 | $i_batch_done = $this->iBatchDone; // Temp save |
|
414 | $this->iBatchDone = 0; |
|
415 | if (!empty($config['queue']) && is_array($config['queue'])) { |
|
416 | foreach ($config['queue'] as $tbl_srce => $tbl_dest) |
|
417 | if ($this->iBatchDone < $this->iBatchSize) |
|
418 | // Notice, $tbl_dest maybe an array |
|
419 | $this->iBatchDone += $this->SyncChkDelTbl( |
|
420 | $this->oDbSrce, $this->oDbDest, $tbl_srce, $tbl_dest); |
|
421 | } |
|
422 | ||
423 | // Output message |
|
424 | global $i_db_query_times; |
|
@@ 550-556 (lines=7) @@ | ||
547 | // Doing queue |
|
548 | $i_batch_done = $this->iBatchDone; // Temp save |
|
549 | $this->iBatchDone = 0; |
|
550 | if (!empty($config['queue']) && is_array($config['queue'])) { |
|
551 | foreach ($config['queue'] as $tbl_srce => $tbl_dest) |
|
552 | if ($this->iBatchDone < $this->iBatchSize) |
|
553 | // Notice, $tbl_dest maybe an array |
|
554 | $this->iBatchDone += $this->SyncOnewayTbl( |
|
555 | $this->oDbSrce, $this->oDbDest, $tbl_srce, $tbl_dest); |
|
556 | } |
|
557 | // Output message |
|
558 | global $i_db_query_times; |
|
559 | $this->Log("SyncOneway done, total {$this->iBatchDone} rows wrote," |