packages/ztd-query-mysqli-adapter/tests/Integration/MysqliLoadDataTest.php

1<?php
2
3declare(strict_types=1);
4
5namespace Tests\Integration;
6
7use Container\Endpoint;
8use Container\MySqlRelease;
9use mysqli;
10use mysqli_result;
11use PHPUnit\Framework\Attributes\Large;
12use PHPUnit\Framework\TestCase;
13use Testcontainers\Testcontainers;
14use ZtdQuery\Adapter\Mysqli\ZtdMysqli;
15
16#[\PHPUnit\Framework\Attributes\CoversClass(ZtdMysqli::class)]
17#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Session\ConnectionExecution::class)]
18#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\ZtdMysqliStatement::class)]
19#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Session\StatementExecution::class)]
20#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Driver\MysqliConnection::class)]
21#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Driver\MysqliResultStatement::class)]
22#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Driver\MysqliResultColumnExtractor::class)]
23#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Native\MysqliStatementBindingBridge::class)]
24#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\ZtdMysqliException::class)]
25#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Native\MysqliPropertyReader::class)]
26#[\PHPUnit\Framework\Attributes\CoversClass(\ZtdQuery\Adapter\Mysqli\Session\MysqliResultProcessor::class)]
27#[Large]
28final class MysqliLoadDataTest extends TestCase
29{
30    public function testLocalInfileLoadsOnlyTheShadowTable(): void
31    {
32        $container = Testcontainers::run(MySqlRelease::fromEnvironment());
33        $endpoint = $container->getData(Endpoint::class);
34        try {
35            $rawMysqli = new mysqli($endpoint->host, $endpoint->username, $endpoint->password, $endpoint->database, $endpoint->port);
36            $rawMysqli->set_charset('utf8mb4');
37            $table = 'load_' . bin2hex(random_bytes(8));
38            $rawMysqli->query(sprintf('CREATE TABLE `%s` (id INT PRIMARY KEY, name VARCHAR(100))', $table));
39            $ztdMysqli = ZtdMysqli::fromMysqli($rawMysqli);
40
41            $stream = tmpfile();
42            self::assertIsResource($stream);
43            self::assertSame(14, fwrite($stream, "1\tAlice\n2\tBob\n"));
44            $metadata = stream_get_meta_data($stream);
45            $path = $metadata['uri'] ?? null;
46            self::assertIsString($path);
47
48            self::assertNotFalse($ztdMysqli->query(sprintf(
49                "LOAD DATA LOCAL INFILE '%s' INTO TABLE `%s`",
50                str_replace("'", "''", $path),
51                $table,
52            )));
53            self::assertSame(2, $ztdMysqli->lastAffectedRows());
54
55            $rows = $ztdMysqli->query(sprintf('SELECT id, name FROM `%s` ORDER BY id', $table));
56            self::assertInstanceOf(mysqli_result::class, $rows);
57            self::assertSame([
58                ['id' => 1, 'name' => 'Alice'],
59                ['id' => 2, 'name' => 'Bob'],
60            ], $rows->fetch_all(MYSQLI_ASSOC));
61
62            $physical = $rawMysqli->query(sprintf('SELECT COUNT(*) AS count FROM `%s`', $table));
63            self::assertInstanceOf(mysqli_result::class, $physical);
64            self::assertSame([['count' => '0']], $physical->fetch_all(MYSQLI_ASSOC));
65        } finally {
66            $container->stop();
67        }
68    }
69}
70