mirror of
https://github.com/dg/dibi.git
synced 2025-08-05 05:37:39 +02:00
DibiConnection::loadFile() supports DELIMITER [Closes #119]
This commit is contained in:
@@ -641,14 +641,21 @@ class DibiConnection extends DibiObject
|
|||||||
}
|
}
|
||||||
|
|
||||||
$count = 0;
|
$count = 0;
|
||||||
|
$delimiter = ';';
|
||||||
$sql = '';
|
$sql = '';
|
||||||
while (!feof($handle)) {
|
while (!feof($handle)) {
|
||||||
$s = fgets($handle);
|
$s = rtrim(fgets($handle));
|
||||||
$sql .= $s;
|
if (substr($s, 0, 10) === 'DELIMITER ') {
|
||||||
if (substr(rtrim($s), -1) === ';') {
|
$delimiter = substr($s, 10);
|
||||||
|
|
||||||
|
} elseif (substr($s, -strlen($delimiter)) === $delimiter) {
|
||||||
|
$sql .= substr($s, 0, -strlen($delimiter));
|
||||||
$this->driver->query($sql);
|
$this->driver->query($sql);
|
||||||
$sql = '';
|
$sql = '';
|
||||||
$count++;
|
$count++;
|
||||||
|
|
||||||
|
} else {
|
||||||
|
$sql .= $s . "\n";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (trim($sql) !== '') {
|
if (trim($sql) !== '') {
|
||||||
|
Reference in New Issue
Block a user