switch to nextras/multi-query-parser [closes #59]

composer.json

@@ -23,6 +23,7 @@
 		"nette/utils": "~3.0",
 		"nette/finder": "~2.5",
 		"nette/neon": "~3.0",
+		"nextras/multi-query-parser": "1.0.0",
 		"phpstan/extension-installer": "1.2.0",
 		"phpstan/phpstan": "1.10.10",
 		"phpstan/phpstan-deprecation-rules": "1.1.3",
@@ -32,6 +33,9 @@
 		"symfony/http-kernel": "~4.4 || ~5.0",
 		"tracy/tracy": "~2.7"
 	},
+	"suggest": {
+		"nextras/multi-query-parser": "Install this to support SQL file import."
+	},
 	"autoload": {
 		"psr-4": { "Nextras\\Dbal\\": "src/" }
 	},

src/Bridges/NetteCaching/CachedPlatform.php

@@ -7,6 +7,7 @@
 use DateTimeInterface;
 use Nette\Caching\Cache;
 use Nextras\Dbal\Platforms\IPlatform;
+use Nextras\MultiQueryParser\IMultiQueryParser;
 
 
 class CachedPlatform implements IPlatform
@@ -124,6 +125,12 @@ public function formatLimitOffset(?int $limit, ?int $offset): string
 	}
 
 
+	public function createMultiQueryParser(): IMultiQueryParser
+	{
+		return $this->platform->createMultiQueryParser();
+	}
+
+
 	public function isSupported(int $feature): bool
 	{
 		return $this->platform->isSupported($feature);

src/Platforms/IPlatform.php

@@ -8,6 +8,7 @@
 use Nextras\Dbal\Platforms\Data\Column;
 use Nextras\Dbal\Platforms\Data\ForeignKey;
 use Nextras\Dbal\Platforms\Data\Table;
+use Nextras\MultiQueryParser\IMultiQueryParser;
 
 
 interface IPlatform
@@ -117,6 +118,13 @@ public function formatBlob(string $value): string;
 	public function formatLimitOffset(?int $limit, ?int $offset): string;
 
 
+	/**
+	 * Returns SQL file parser
+	 * !!!This function requires nextras/multi-query-parser dependency!!!
+	 */
+	public function createMultiQueryParser(): IMultiQueryParser;
+
+
 	/**
 	 * Checks whether any feature from IPlatform::SUPPORT_* is supported.
 	 * @internal

src/Platforms/MySqlPlatform.php

@@ -15,6 +15,8 @@
 use Nextras\Dbal\Utils\DateTimeHelper;
 use Nextras\Dbal\Utils\JsonHelper;
 use Nextras\Dbal\Utils\StrictObjectTrait;
+use Nextras\MultiQueryParser\IMultiQueryParser;
+use Nextras\MultiQueryParser\MySqlMultiQueryParser;
 use function addcslashes;
 use function explode;
 use function str_replace;
@@ -220,6 +222,15 @@ public function formatLimitOffset(?int $limit, ?int $offset): string
 	}
 
 
+	public function createMultiQueryParser(): IMultiQueryParser
+	{
+		if (!class_exists(MySqlMultiQueryParser::class)) {
+			throw new \RuntimeException("Missing nextras/multi-query-parser dependency. Install it first to use IPlatform::createMultiQueryParser().");
+		}
+		return new MySqlMultiQueryParser();
+	}
+
+
 	public function isSupported(int $feature): bool
 	{
 		static $supported = [

src/Platforms/PostgreSqlPlatform.php

@@ -14,6 +14,8 @@
 use Nextras\Dbal\Utils\DateTimeHelper;
 use Nextras\Dbal\Utils\JsonHelper;
 use Nextras\Dbal\Utils\StrictObjectTrait;
+use Nextras\MultiQueryParser\IMultiQueryParser;
+use Nextras\MultiQueryParser\PostgreSqlMultiQueryParser;
 use function bin2hex;
 use function str_replace;
 use function strtr;
@@ -255,6 +257,15 @@ public function formatLimitOffset(?int $limit, ?int $offset): string
 	}
 
 
+	public function createMultiQueryParser(): IMultiQueryParser
+	{
+		if (!class_exists(PostgreSqlMultiQueryParser::class)) {
+			throw new \RuntimeException("Missing nextras/multi-query-parser dependency. Install it first to use IPlatform::createMultiQueryParser().");
+		}
+		return new PostgreSqlMultiQueryParser();
+	}
+
+
 	public function isSupported(int $feature): bool
 	{
 		static $supported = [

src/Platforms/SqlServerPlatform.php

@@ -14,6 +14,8 @@
 use Nextras\Dbal\Platforms\Data\Table;
 use Nextras\Dbal\Utils\JsonHelper;
 use Nextras\Dbal\Utils\StrictObjectTrait;
+use Nextras\MultiQueryParser\IMultiQueryParser;
+use Nextras\MultiQueryParser\SqlServerMultiQueryParser;
 
 
 class SqlServerPlatform implements IPlatform
@@ -244,6 +246,15 @@ public function formatLimitOffset(?int $limit, ?int $offset): string
 	}
 
 
+	public function createMultiQueryParser(): IMultiQueryParser
+	{
+		if (!class_exists(SqlServerMultiQueryParser::class)) {
+			throw new \RuntimeException("Missing nextras/multi-query-parser dependency. Install it first to use IPlatform::createMultiQueryParser().");
+		}
+		return new SqlServerMultiQueryParser();
+	}
+
+
 	public function isSupported(int $feature): bool
 	{
 		static $supported = [

tests/inc/IntegrationTestCase.php

@@ -2,9 +2,9 @@
 
 namespace NextrasTests\Dbal;
 
+
 use Nextras\Dbal\Connection;
 use Nextras\Dbal\Exception\InvalidArgumentException;
-use Nextras\Dbal\Utils\FileImporter;
 use Tester\Environment;
 
 
@@ -20,8 +20,12 @@ class IntegrationTestCase extends TestCase
 	public function initData(Connection $connection)
 	{
 		$this->lockConnection($connection);
-		$platform = $connection->getPlatform()->getName();
-		FileImporter::executeFile($connection, __DIR__ . "/../data/$platform-data.sql");
+		$platform = $connection->getPlatform();
+		$platformName = $platform->getName();
+		$parser = $platform->createMultiQueryParser();
+		foreach ($parser->parseFile(__DIR__ . "/../data/$platformName-data.sql") as $sql) {
+			$connection->query('%raw', $sql);
+		}
 	}
 
 
@@ -35,8 +39,8 @@ protected function lockConnection(Connection $connection)
 	protected function createConnection($params = [])
 	{
 		$options = array_merge([
-			'user' => NULL,
-			'password' => NULL,
+			'user' => null,
+			'password' => null,
 			'searchPath' => ['public'],
 		], Environment::loadData(), $params);
 		return new Connection($options);
@@ -46,7 +50,7 @@ protected function createConnection($params = [])
 	public function __get($name)
 	{
 		if ($name === 'connection') {
-			if ($this->defaultConnection === NULL) {
+			if ($this->defaultConnection === null) {
 				$this->defaultConnection = $this->createConnection();
 			}
 			return $this->defaultConnection;

tests/inc/setup.php

@@ -1,7 +1,7 @@
 <?php
 
+
 use Nextras\Dbal\Connection;
-use Nextras\Dbal\Utils\FileImporter;
 
 
 if (@!include __DIR__ . '/../../vendor/autoload.php') {
@@ -28,11 +28,15 @@
 	echo "[setup] Bootstrapping '{$name}' structure.\n";
 
 	$connection = new Connection($configDatabase);
-	$platform = $connection->getPlatform()->getName();
-	$resetFunction = require __DIR__ . "/../data/{$platform}-reset.php";
+	$platform = $connection->getPlatform();
+	$platformName = $platform->getName();
+	$resetFunction = require __DIR__ . "/../data/{$platformName}-reset.php";
 	$resetFunction($connection, $configDatabase);
 
-	FileImporter::executeFile($connection, __DIR__ . "/../data/{$platform}-init.sql");
+	$parser = $platform->createMultiQueryParser();
+	foreach ($parser->parseFile(__DIR__ . "/../data/{$platformName}-init.sql") as $sql) {
+		$connection->query('%raw', $sql);
+	}
 }
 
 echo "[setup] All done.\n\n";