<?php

/**

* This file is part of the sshilko/php-sql-mydb package.

*

* (c) Sergei Shilko <contact@sshilko.com>

*

* MIT License

*

* For the full copyright and license information, please view the LICENSE

* file that was distributed with this source code.

* @license https://opensource.org/licenses/mit-license.php MIT

*/

// @codeCoverageIgnoreStart

declare(strict_types = 1);

use MydbRepository\UserRepository;

use sql\MydbCredentials;

use sql\MydbFactory;

use sql\MydbLogger;

use sql\MydbOptions;

use sql\MydbRegistry;

include_once __DIR__ . '/../vendor/autoload.php';

include_once __DIR__ . '/MydbRepository/UserRepository.php';

$registry = new MydbRegistry();

$mylogger = new MydbLogger();

$sqlHost = getenv('MYSQL_HOST') ?: 'mysql';

$auth = new MydbCredentials($sqlHost, 'root', 'root', 'mydb', 3306);

$factory = new MydbFactory();

$opts = $factory->createOptions();

$opts->setTransactionIsolationLevel(MydbOptions::TRANSACTION_ISOLATION_LEVEL_READ_COMMITTED);

$mydb = $factory->create($auth, $mylogger, $opts);

$mydb->beginTransaction();

$array1 = $mydb->select("SELECT 123");

$array2 = $mydb->query("SELECT 123");

assert($array1 === $array2);

$created = $mydb->command('CREATE TEMPORARY TABLE `users` (

`id` int(10) unsigned NOT NULL AUTO_INCREMENT,

`name` varchar(200) NOT NULL,

`myenum` enum ("e1","e2") NOT NULL DEFAULT "e1",

PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4');

assert(true === $created);

$insertedStringId = $mydb->insert("INSERT INTO users (id, name) VALUES (10, 'user10')");

assert('10' === $insertedStringId);

$insertedStringId = $mydb->insertOne(['id' => 20, 'name' => 'user20'], 'users');

assert('20' === $insertedStringId);

$statement = $mydb->prepare('INSERT INTO users (id, name) VALUES (?, ?)');

$statement->bind([25, 'user25']);

assert(true === $statement->execute());

assert('25' === (string) $statement->getInsertId());

$statement->close();

assert([['id' => 25, 'name' => 'user25']] === $mydb->execute('SELECT id, name FROM users WHERE id = ?', [25]));

$mydb->insertMany([[30, 'user30'], [40, 'user40']], ['id', 'name'], 'users');

assert(['10', '20', '25', '30', '40'] === array_column($mydb->query("SELECT id, name FROM users ORDER BY id ASC"), 'id'));

$deletedRowsCount = $mydb->delete('DELETE FROM users WHERE id = 40');

assert(1 === $deletedRowsCount);

assert(['10', '20', '25', '30'] === array_column($mydb->select("SELECT id, name FROM users ORDER BY id ASC"), 'id'));

$enum = $mydb->getEnumValues('users', 'myenum');

assert(['e1', 'e2'] === $enum);

$prim = $mydb->getPrimaryKeys('users');

assert(['id'] === $prim);

$deletedRowsCount = $mydb->deleteWhere(['id' => '30'], 'users');

assert(1 === $deletedRowsCount);

assert(['10', '20', '25'] === array_column($mydb->select("SELECT id, name FROM users ORDER BY id ASC"), 'id'));

assert(1 === $mydb->updateWhere(['id' => 99], ['id' => 10], 'users'));

assert(['20', '25', '99'] === array_column($mydb->select("SELECT id, name FROM users ORDER BY id ASC"), 'id'));

$db10 = $factory->create($auth, $mylogger, $opts);

$db10->open();

$db20 = $factory->create($auth, $mylogger, $opts);

$registry['db1'] = $mydb;

$registry['db2'] = $db10;

$registry['db3'] = $db20;

$db10->close();

$db20->close();

$userRepo = new UserRepository($registry);

$user20 = $userRepo->findById(20);

assert('user20' === $user20[0]['name']);

$mydb->rollbackTransaction();

echo 'OK' . PHP_EOL;

exit(0);

// @codeCoverageIgnoreEnd