php-dibi/tests/dibi/Connection.connect.phpt

<?php

/**
 * @dataProvider ../databases.ini
 */

declare(strict_types=1);

use Dibi\Connection;
use Tester\Assert;

require __DIR__ . '/bootstrap.php';


test('', function () use ($config) {
	$conn = new Connection($config);
	Assert::true($conn->isConnected());

	$conn->disconnect();
	Assert::false($conn->isConnected());
});


test('lazy', function () use ($config) {
	$conn = new Connection($config + ['lazy' => true]);
	Assert::false($conn->isConnected());

	$conn->query('SELECT 1');
	Assert::true($conn->isConnected());
});


test('', function () use ($config) {
	$conn = new Connection($config);
	Assert::true($conn->isConnected());

	Assert::null($conn->getConfig('lazy'));
	Assert::same($config['driver'], $conn->getConfig('driver'));
	Assert::type(Dibi\Driver::class, $conn->getDriver());
});


test('', function () use ($config) {
	$conn = new Connection($config);
	Assert::true($conn->isConnected());

	$conn->disconnect();
	Assert::false($conn->isConnected());

	$conn->disconnect();
	Assert::false($conn->isConnected());
});


test('', function () use ($config) {
	$conn = new Connection($config);
	Assert::equal('hello', $conn->query('SELECT %s', 'hello')->fetchSingle());

	$conn->disconnect();

	$conn->connect();
	Assert::equal('hello', $conn->query('SELECT %s', 'hello')->fetchSingle());
});


test('', function () use ($config) {
	$conn = new Connection($config);
	Assert::true($conn->isConnected());

	$conn->__destruct();
	Assert::false($conn->isConnected());
});


test('', function () use ($config) {
	Assert::exception(function () use ($config) {
		new Connection($config + ['onConnect' => '']);
	}, InvalidArgumentException::class, "Configuration option 'onConnect' must be array.");

	$e = Assert::exception(function () use ($config) {
		new Connection($config + ['onConnect' => ['STOP']]);
	}, Dibi\DriverException::class);
	Assert::same('STOP', $e->getSql());

	$e = Assert::exception(function () use ($config) {
		new Connection($config + ['onConnect' => [['STOP %i', 123]]]);
	}, Dibi\DriverException::class);
	Assert::same('STOP 123', $e->getSql());

	// lazy
	$conn = new Connection($config + ['lazy' => true, 'onConnect' => ['STOP']]);
	$e = Assert::exception(function () use ($conn) {
		$conn->query('SELECT 1');
	}, Dibi\DriverException::class);
	Assert::same('STOP', $e->getSql());
});