|
@@ 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," |