Commitbfca726

authored

Print a warning when the number of rows dumped does not match the expected count (#85)

1 parent979d73c commitbfca726Copy full SHA for bfca726

File tree

-0

lines changed

-0

lines changed

Lines changed: 7 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -183,6 +183,7 @@ public function dumpData($table, Table $tableConfig, Connection $db, bool $noPro`
`183`	`183`	`/** @var PDOConnection $wrappedConnection */`
`184`	`184`	`$wrappedConnection =$db->getWrappedConnection();`
`185`	`185`	`$wrappedConnection->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY,false);`
	`186`	`+$actualRows =0;`
`186`	`187`
`187`	`188`	`foreach ($db->query($s)as$row) {`
`188`	`189`	`$b =$this->rowLengthEstimate($row);`
`@@ -222,6 +223,8 @@ public function dumpData($table, Table $tableConfig, Connection $db, bool $noPro`
`222`	`223`	`if (null !==$progress) {`
`223`	`224`	`$progress->advance();`
`224`	`225`	`}`
	`226`	`+`
	`227`	`+ ++$actualRows;`
`225`	`228`	`}`
`226`	`229`
`227`	`230`	`if (null !==$progress) {`
`@@ -232,6 +235,10 @@ public function dumpData($table, Table $tableConfig, Connection $db, bool $noPro`
`232`	`235`	`}`
`233`	`236`	`}`
`234`	`237`
	`238`	`+if ($actualRows !==$numRows) {`
	`239`	`+$this->output->getErrorOutput()->writeln(sprintf('<error>Expected %d rows, actually processed %d – verify results!</error>',$numRows,$actualRows));`
	`240`	`+ }`
	`241`	`+`
`235`	`242`	`$wrappedConnection->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY,true);`
`236`	`243`
`237`	`244`	`if ($bufferSize) {`

Comments

(0)