<?php
/**
 * php7-mysql-shim
 *
 * @author Davey Shafik <me@daveyshafik.com>
 * @copyright Copyright (c) 2017 Davey Shafik
 * @license MIT License
 * @link https://github.com/dshafik/php7-mysql-shim
 */
namespace Dshafik\MySQL\Tests;

class MySqlShimTest extends \PHPUnit_Framework_TestCase
{
    /**
     * @var string MySQL Host
     */
    static protected $host;

    /**
     * @var string Docker container
     */
    static protected $container;

    /**
     * @var array Location of binaries
     */
    static protected $bin = array();

    /**
     * @var \SebastianBergmann\Environment\Runtime
     */
    protected $runtime;

    public function __construct($name = null, array $data = array(), $dataName = '')
    {
        parent::__construct($name, $data, $dataName);
        $this->runtime = new \SebastianBergmann\Environment\Runtime();
    }

    public function test_mysql_connect()
    {
        $mysql = mysql_connect(static::$host, 'root');
        $this->assertConnection($mysql);
    }

    /**
     * @requires PHP 7.0.0
     */
    public function test_mysql_connect_defaults()
    {
        ini_set('mysqli.default_host', '127.0.0.1');
        ini_set('mysqli.default_user', 'root');
        ini_set('mysqli.default_pw', '');

        $mysql = mysql_connect();
        $this->assertConnection($mysql);
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^mysql(i?)_connect\(\): (\(HY000\/1045\): )?Access denied for user 'baduser'@'(.*?)' \(using password: YES\)$/
     */
    public function test_mysql_connect_fail_warning()
    {
        $mysql = mysql_connect(static::$host, "baduser", "badpass");
    }

    public function test_mysql_connect_fail_false()
    {
        $mysql = @mysql_connect(static::$host, "baduser", "badpass");
        $this->assertFalse($mysql);
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessage Argument $new is no longer supported in PHP > 7
     * @requires PHP 7.0.0
     */
    public function test_mysql_connect_new()
    {
        $mysql = mysql_connect(static::$host, 'root', null, true);
    }

    public function test_mysql_connect_options()
    {
        $mysql = mysql_connect(static::$host, 'root', null, false, MYSQL_CLIENT_COMPRESS);
        $this->assertConnection($mysql);
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^mysql((i_real)?)_connect\(\): (\(HY000\/1045\): )?Access denied for user 'baduser'@'(.*?)' \(using password: YES\)$/
     */
    public function test_mysql_connect_options_fail()
    {
        mysql_connect(static::$host, "baduser", "badpass", false, MYSQL_CLIENT_COMPRESS);
    }

    public function test_mysql_connect_multi()
    {
        $this->skipForHHVM();

        $conn = mysql_connect(static::$host, 'root');
        $conn2 = mysql_connect(static::$host, 'root');

        $this->assertEquals($conn, $conn2);

        $result = mysql_query("SELECT CONNECTION_ID()", $conn);
        $row = mysql_fetch_row($result);
        $id = $row[0];

        $result = mysql_query("SELECT CONNECTION_ID()", $conn2);
        $row = mysql_fetch_row($result);
        $id2 = $row[0];

        $this->assertEquals($id, $id2);
    }

    public function test_mysql_pconnect()
    {
        $conn = mysql_pconnect(static::$host, 'root');

        $result = mysql_query("SELECT 'persistent'", $conn);
        $row = mysql_fetch_row($result);
        $this->assertEquals('persistent', $row[0]);
    }

    public function test_mysql_constants()
    {
        $this->assertTrue(defined('MYSQL_ASSOC'));
        $this->assertEquals(constant('MYSQL_ASSOC'), 1);
        $this->assertTrue(defined('MYSQL_NUM'));
        $this->assertEquals(constant('MYSQL_NUM'), 2);
        $this->assertTrue(defined('MYSQL_BOTH'));
        $this->assertEquals(constant('MYSQL_BOTH'), 3);
        $this->assertTrue(defined('MYSQL_CLIENT_COMPRESS'));
        $this->assertEquals(constant('MYSQL_CLIENT_COMPRESS'), 32);
        $this->assertTrue(defined('MYSQL_CLIENT_SSL'));
        $this->assertEquals(constant('MYSQL_CLIENT_SSL'), 2048);
        $this->assertTrue(defined('MYSQL_CLIENT_INTERACTIVE'));
        $this->assertEquals(constant('MYSQL_CLIENT_INTERACTIVE'), 1024);
        $this->assertTrue(defined('MYSQL_CLIENT_IGNORE_SPACE'));
        $this->assertEquals(constant('MYSQL_CLIENT_IGNORE_SPACE'), 256);
    }

    public function test_mysql_query_ddl()
    {
        $conn = mysql_connect(static::$host, 'root');
        $result = mysql_query("CREATE DATABASE IF NOT EXISTS shim_test");
        $this->assertTrue($result, mysql_error());
    }

    public function test_mysql_query_insert()
    {
        $this->getConnection("shim_test");
        $result = mysql_query(
            "INSERT INTO
                testing (one, two, three, four, five, six, seven, eight, nine, ten, eleven)
             VALUES
                ('1', '1', '1', '1', '1', '1', '1', '1', '1', '1', '1'),
                ('2', '2', '2', '2', '2', '2', '2', '2', '2', '2', '2'),
                ('3', '3', '3', '3', '3', '3', '3', '3', '3', '3', '3'),
                ('4', '4', '4', '4', '4', '4', '4', '4', '4', '4', '4')"
        );

        $this->assertTrue($result, mysql_error());

        $result = mysql_query(
            "INSERT INTO
                testing2 (one, two, three, four, five, six, seven, eight, nine, ten, eleven)
             VALUES
                ('1', '1', '1', '1', '1', '1', '1', '1', '1', '1', '1'),
                ('2', '2', '2', '2', '2', '2', '2', '2', '2', '2', '2'),
                ('3', '3', '3', '3', '3', '3', '3', '3', '3', '3', '3'),
                ('4', '4', '4', '4', '4', '4', '4', '4', '4', '4', '4')"
        );

        $this->assertTrue($result, mysql_error());
    }

    public function test_mysql_query()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT VERSION()");

        $this->assertResult($result);
    }

    public function test_mysql_query_nodata()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SET @test = 'foo'");

        $this->assertTrue($result);
    }

    public function test_mysql_query_fail()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT VERSION(");

        $this->assertFalse($result);
    }

    public function test_mysql_unbuffered_query()
    {
        $this->getConnection("shim_test");

        $result = mysql_unbuffered_query("SELECT one, two FROM testing LIMIT 4");
        $this->assertResult($result);
        $i = 0;
        while ($row = mysql_fetch_assoc($result)) {
            $i++;
        }
        $this->assertEquals(4, $i);

        $result = mysql_query("SELECT one, two FROM testing LIMIT 4");
        $this->assertResult($result);
    }

    public function test_mysql_unbuffered_query_fail()
    {
        $this->getConnection();

        $result = mysql_unbuffered_query("SELECT VERSION(");
        $this->assertFalse($result);
    }

    public function test_mysql_unbuffered_query_num_rows()
    {
        $this->getConnection("shim_test");

        $result = mysql_unbuffered_query("SELECT one, two FROM testing");
        $this->assertResult($result);
        $this->assertEquals(0, mysql_num_rows($result));
        mysql_free_result($result);
    }

    /**
     * @requires PHP < 7.0.0
     */
    public function test_mysql_unbuffered_query_close_legacy()
    {
        if (!version_compare(PHP_VERSION, '7.0.0', '<')) {
            $this->markTestIncomplete("PHP < 7.0.0 is required");
        }

        $conn = $this->getConnection("shim_test");

        $result = mysql_unbuffered_query("SELECT one, two FROM testing");
        $this->assertResult($result);
        try {
            mysql_close($conn);
        } catch (\PHPUnit_Framework_Error_Notice $e) {
            $this->assertEquals(
                "mysql_close(): Function called without first fetching all rows from a previous unbuffered query",
                $e->getMessage()
            );
        }
    }

    /**
     * @requires PHP 7.0.0
     */
    public function test_mysql_unbuffered_query_close()
    {
        $conn = $this->getConnection("shim_test");
        $result = mysql_unbuffered_query("SELECT one, two FROM testing");
        $this->assertResult($result);
        mysql_close($conn);
    }

    public function test_mysql_db_query()
    {
        $this->skipForHHVM();

        $this->getConnection();
        $result = mysql_db_query("shim_test", "SELECT DATABASE()");
        $this->assertResult($result);
        $rows =  mysql_fetch_row($result);
        $this->assertEquals("shim_test", $rows[0]);
        $result = mysql_db_query("mysql", "SELECT DATABASE()");
        $this->assertResult($result);
        $rows = mysql_fetch_row($result);
        $this->assertEquals("mysql", $rows[0]);
    }

    public function test_mysql_db_query_fail()
    {
        $this->skipForHHVM();

        $this->getConnection();
        $result = mysql_db_query("nonexistent", "SELECT DATABASE()");
        $this->assertFalse($result);
    }

    public function test_mysql_insert_id()
    {
        $this->getConnection("shim_test");
        $result = mysql_query(
            "INSERT INTO
                testing (id, one, two, three, four, five, six, seven, eight, nine, ten, eleven)
             VALUES
                (5, '5', '5', '5', '5', '5', '5', '5', '5', '5', '5', '5')");
        $this->assertTrue($result);
        $this->assertEquals(5, mysql_insert_id());
    }

    public function test_mysql_list_dbs()
    {
        $this->getConnection();
        $result = mysql_list_dbs();
        $this->assertResult($result);
        while ($row = mysql_fetch_assoc($result)) {
            $this->assertArrayHasKey("Database", $row);
        }
    }

    public function test_mysql_list_tables()
    {
        $this->getConnection();
        $result = mysql_list_tables("mysql");
        $this->assertResult($result);

        while ($row = mysql_fetch_assoc($result)) {
            $this->assertArrayHasKey("Tables_in_mysql", $row);
        }
    }

    /**
     * @requires PHP
     */
    public function test_mysql_list_tables_fail()
    {
        $this->skipForHHVM();

        $this->getConnection();
        $result = mysql_list_tables("nonexistent");
        $this->assertFalse($result);
    }

    public function test_mysql_list_tables_specialchars()
    {
        $this->getConnection('shim-test');

        $result = mysql_list_tables('shim-test');
        $this->assertResult($result);
        $i = 0;
        while ($row = mysql_fetch_assoc($result)) {
            $i++;
            $this->assertArrayHasKey("Tables_in_shim-test", $row);
        }
        $this->assertEquals(2, $i);
    }

    /**
     * @requires PHP 7.0.0
     */
    public function test_mysql_list_fields()
    {
        $this->skipForHHVM();

        $mysql = $this->getConnection();

        $sql = "SHOW CREATE TABLE testing";

        $result = mysql_list_fields("shim_test", "testing", $mysql);
        $this->assertResult($result);

        $i = 0;
        while ($row = mysql_fetch_assoc($result)) {
            $i++;

            $this->assertEquals(
                array(
                    'Field',
                    'Type',
                    'Null',
                    'Key',
                    'Default',
                    'Extra'
                ),
                array_keys($row)
            );
        }

        $this->assertEquals(12, $i);

        return;
    }

    /**
     * @requires PHP 7.0.0
     */
    public function test_mysql_list_fields_specialchars()
    {
        $this->skipForHHVM();

        $this->getConnection('shim-test');

        $result = mysql_query(
            "CREATE TABLE IF NOT EXISTS `testing-3` (
                id int AUTO_INCREMENT,
                one varchar(255),
                two varchar(255),
                three varchar(255),
                four varchar(255),
                five varchar(255),
                six varchar(255),
                seven varchar(255),
                eight varchar(255),
                nine ENUM('one', 'two', '\'three'),
                ten SET('one', 'two', '\'\'three'),
                eleven MEDIUMTEXT,
                INDEX one_idx (one),
                UNIQUE INDEX two_unq (two),
                INDEX three_four_idx (three, four),
                UNIQUE INDEX four_five_unq (four, five),
                INDEX seven_eight_idx (seven, eight),
                UNIQUE INDEX seven_eight_unq (seven, eight),
                PRIMARY KEY (id)
            ) CHARACTER SET latin1;"
        );

        $result = mysql_list_fields("shim-test", "testing-3");
        $this->assertResult($result);

        $i = 0;
        while ($row = mysql_fetch_assoc($result)) {
            $i++;
            $this->assertEquals(
                array(
                    'Field',
                    'Type',
                    'Null',
                    'Key',
                    'Default',
                    'Extra'
                ),
                array_keys($row)
            );
        }

        $this->assertEquals(12, $i);

        return;
    }

    public function test_mysql_list_fields_fail()
    {
        $this->skipForHHVM();

        try {
            $this->getConnection();
            mysql_list_fields("shim_test", "nonexistent");
        } catch (\Exception $e) {
            $this->assertInstanceOf('\PHPUnit_Framework_Error_Warning', $e);
            $this->assertEquals('mysql_list_fields(): Unable to save MySQL query result', $e->getMessage());
        }
    }

    public function test_mysql_field()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing LIMIT 1");

        $this->assertEquals("testing", mysql_field_table($result, 0));
        $this->assertEquals("id", mysql_field_name($result, 0));
        $this->assertEquals("int", mysql_field_type($result, 0));
        $this->assertEquals(11, mysql_field_len($result, 0));
        $this->assertEquals("not_null primary_key auto_increment", mysql_field_flags($result, 0));

        $this->assertEquals("testing", mysql_field_table($result, 1));
        $this->assertEquals("one", mysql_field_name($result, 1));
        $this->assertEquals("string", mysql_field_type($result, 1));
        $this->assertEquals(255, mysql_field_len($result, 1));
        $this->assertEquals("multiple_key", mysql_field_flags($result, 1));

        $this->assertEquals("testing", mysql_field_table($result, 2));
        $this->assertEquals("two", mysql_field_name($result, 2));
        $this->assertEquals("string", mysql_field_type($result, 2));
        $this->assertEquals(255, mysql_field_len($result, 2));
        $this->assertEquals("unique_key", mysql_field_flags($result, 2));

        $this->assertEquals("testing", mysql_field_table($result, 3));
        $this->assertEquals("three", mysql_field_name($result, 3));
        $this->assertEquals("string", mysql_field_type($result, 3));
        $this->assertEquals(255, mysql_field_len($result, 3));
        $this->assertEquals("multiple_key", mysql_field_flags($result, 3));

        $this->assertEquals("testing", mysql_field_table($result, 4));
        $this->assertEquals("four", mysql_field_name($result, 4));
        $this->assertEquals("string", mysql_field_type($result, 4));
        $this->assertEquals(255, mysql_field_len($result, 4));
        $this->assertEquals("multiple_key", mysql_field_flags($result, 4));

        $this->assertEquals("testing", mysql_field_table($result, 5));
        $this->assertEquals("five", mysql_field_name($result, 5));
        $this->assertEquals("string", mysql_field_type($result, 5));
        $this->assertEquals(255, mysql_field_len($result, 5));
        $this->assertEmpty(mysql_field_flags($result, 5));

        $this->assertEquals("testing", mysql_field_table($result, 6));
        $this->assertEquals("six", mysql_field_name($result, 6));
        $this->assertEquals("string", mysql_field_type($result, 6));
        $this->assertEquals(255, mysql_field_len($result, 6));
        $this->assertEmpty(mysql_field_flags($result, 6));

        $this->assertEquals("testing", mysql_field_table($result, 7));
        $this->assertEquals("seven", mysql_field_name($result, 7));
        $this->assertEquals("string", mysql_field_type($result, 7));
        $this->assertEquals(255, mysql_field_len($result, 7));
        $this->assertEquals("multiple_key", mysql_field_flags($result, 7));

        $this->assertEquals("testing", mysql_field_table($result, 8));
        $this->assertEquals("eight", mysql_field_name($result, 8));
        $this->assertEquals("string", mysql_field_type($result, 8));
        $this->assertEquals(255, mysql_field_len($result, 8));
        $this->assertEmpty(mysql_field_flags($result, 8));

        $this->assertEquals("testing", mysql_field_table($result, 9));
        $this->assertEquals("nine", mysql_field_name($result, 9));
        $this->assertEquals("string", mysql_field_type($result, 9));
        $this->assertEquals(6, mysql_field_len($result, 9));
        $this->assertEquals("enum", mysql_field_flags($result, 9));

        $this->assertEquals("testing", mysql_field_table($result, 10));
        $this->assertEquals("ten", mysql_field_name($result, 10));
        $this->assertEquals("string", mysql_field_type($result, 10));
        $this->assertEquals(15, mysql_field_len($result, 10));
        $this->assertEquals("set", mysql_field_flags($result, 10));

        $this->assertEquals("testing", mysql_field_table($result, 11));
        $this->assertEquals("eleven", mysql_field_name($result, 11));
        $this->assertEquals("blob", mysql_field_type($result, 11));
        $this->assertEquals(16777215, mysql_field_len($result, 11));
        $this->assertEquals("blob", mysql_field_flags($result, 11));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_field_name\(\): )?Field 999 is invalid for MySQL result index .*$/
     */
    public function test_mysql_field_name_fail()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing LIMIT 1");

        $this->assertEquals("testing", mysql_field_name($result, 999));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_field_table\(\): )?Field 999 is invalid for MySQL result index .*$/
     */
    public function test_mysql_field_table_fail()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing LIMIT 1");

        $this->assertEquals("testing", mysql_field_table($result, 999));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_field_type\(\): )?Field 999 is invalid for MySQL result index .*$/
     */
    public function test_mysql_field_type_fail()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing LIMIT 1");

        $this->assertEquals("testing", mysql_field_type($result, 999));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_field_len\(\): )?Field 999 is invalid for MySQL result index .*$/
     */
    public function test_mysql_field_len_fail()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing LIMIT 1");

        $this->assertEquals("testing", mysql_field_len($result, 999));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_field_flags\(\): )?Field 999 is invalid for MySQL result index .*$/
     */
    public function test_mysql_field_flags_fail()
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing LIMIT 1");

        $this->assertEquals("testing", mysql_field_flags($result, 999));
    }

    public function test_mysql_num_fields()
    {
        $this->getConnection('shim_test');
        $result = mysql_query("SELECT one, two FROM testing LIMIT 1");
        $this->assertResult($result);

        $this->assertEquals(2, mysql_num_fields($result));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^mysql_num_fields\(\) expects parameter 1 to be resource, boolean given$/
     */
    public function test_mysql_num_fields_fail()
    {
        $this->getConnection('shim_test');
        $result = mysql_query("SELECT one, two FROM nonexistent");

        mysql_num_fields($result);
    }

    /**
     * @dataProvider mysql_function_invalid_result_DataProvider
     */
    public function test_mysql_function_invalid_result($function, $error, $args, $skipHHVM = false)
    {
        $this->skipForHHVM($skipHHVM);

        try {
            if ($args !== array()) {
                array_unshift($args, null);
                call_user_func_array($function, $args);
            }
            call_user_func($function, null);
        } catch (\Exception $e) {
            $this->assertInstanceOf('\PHPUnit_Framework_Error_Warning', $e);
            $this->assertRegExp('@' . $error . '@', $e->getMessage());
        }
    }

    /**
     * @dataProvider mysql_fetch_DataProvider
     */
    public function test_mysql_fetch($function, $results, $resultType = null)
    {
        $this->getConnection("shim_test");

        $result = mysql_query("SELECT one, two FROM testing LIMIT 4");
        $this->assertResult($result);

        $this->assertEquals(sizeof($results), mysql_num_rows($result));

        $function = function ($result) use ($function, $resultType) {
            if ($resultType) {
                return $function($result, $resultType);
            }
            return $function($result);
        };

        $i = 0;
        while ($row = $function($result, $resultType)) {
            $this->assertEquals($results[$i], $row);
            $i++;
        }

        $this->assertEquals(sizeof($results), $i);
    }

    /**
     * @dataProvider mysql_fetch_no_rows_dataProvider
     */
    public function test_mysql_fetch_no_rows($function)
    {
        $this->getConnection("shim_test");
        $result = mysql_query("SELECT * FROM testing WHERE one = 'fail'");

        $this->assertResult($result);
        $this->assertEquals(0, mysql_num_rows($result));
        $this->assertFalse($function($result));
    }

    public function test_mysql_num_rows()
    {
        $this->getConnection("shim_test");

        $result = mysql_query("SELECT * FROM testing LIMIT 4");
        $this->assertResult($result);
        $this->assertEquals(4, mysql_num_rows($result));
    }

    public function test_mysql_affected_rows()
    {
        $this->getConnection("shim_test");

        $result = mysql_query("UPDATE testing SET one = one + 1000, two = two + 1000 ORDER BY one DESC LIMIT 4");
        $this->assertTrue($result);
        $this->assertEquals(4, mysql_affected_rows());
        $result = mysql_query("UPDATE testing SET one = one - 1000, two = two - 1000 ORDER BY one DESC LIMIT 4");
        $this->assertTrue($result, mysql_error());
        $this->assertEquals(4, mysql_affected_rows());
    }

    public function test_mysql_result()
    {
        $this->getConnection();

        $result = mysql_query("SELECT one, two AS aliased FROM testing");
        $this->assertResult($result);

        for($i = 0; $i < mysql_num_rows($result); $i++) {
            $this->assertEquals($i+1, mysql_result($result, $i, 0));
            $this->assertEquals($i+1, mysql_result($result, $i, 'one'));
            $this->assertEquals($i+1, mysql_result($result, $i, 1));
            $this->assertEquals($i+1, mysql_result($result, $i, 'aliased'));
        }
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_result\(\): )?three not found in MySQL result index (.*?)$/
     */
    public function test_mysql_result_fail()
    {
        $this->getConnection();

        $result = mysql_query("SELECT one, two FROM testing LIMIT 1");
        $this->assertResult($result);

        mysql_result($result, 0, "three");
    }

    public function test_mysql_result_prefixed()
    {
        $this->getConnection();

        $result = mysql_query("SELECT one, two FROM testing LIMIT 1");
        $this->assertResult($result);

        $this->assertEquals(1, mysql_result($result, 0, "testing.one"));
        $this->assertEquals(1, mysql_result($result, 0, "testing.two"));
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_result\(\): )?testing.three not found in MySQL result index (.*?)$/
     */
    public function test_mysql_result_prefixed_fail()
    {
        $this->getConnection();

        $result = mysql_query("SELECT one, two FROM testing LIMIT 1");
        $this->assertResult($result);

        mysql_result($result, 0, "testing.three");
    }

    /**
     * @expectedException \PHPUnit_Framework_Error_Warning
     * @expectedExceptionMessageRegExp /^(mysql_result\(\): )?Unable to jump to row 1 on MySQL result index (.*?)$/
     */
    public function test_mysql_result_invalid_row()
    {
        $this->getConnection();

        $result = mysql_query("SELECT one FROM testing LIMIT 1");
        $this->assertResult($result);

        mysql_result($result, 1, 0);
    }

    /**
     * @see https://github.com/dshafik/php7-mysql-shim/issues/7
     */
    public function test_mysql_result_multiple_calls()
    {
        $this->getConnection();

        $result = mysql_query("SELECT * FROM testing LIMIT 1");
        $this->assertResult($result);

        $this->assertEquals(1, mysql_result($result, 0, 'testing.one'));
        $this->assertEquals(1, mysql_result($result, 0, 'testing.one'));
    }

    public function test_mysql_close()
    {
        mysql_connect(static::$host, 'root');
        $this->assertTrue(mysql_close());
    }

    public function test_mysql_close_fail()
    {
        $this->skipForHHVM();

        try {
            mysql_close();
        } catch (\Exception $e) {
            $this->assertInstanceOf('\PHPUnit_Framework_Error_Warning', $e);
            $this->assertEquals("mysql_close(): no MySQL-Link resource supplied", $e->getMessage());
        }
    }

    public function test_mysql_error()
    {
        $this->getConnection();

        $this->assertEmpty(mysql_error());

        $result = mysql_query("SELECT VERSION(");
        $this->assertFalse($result);

        $this->assertRegExp(
            '@You have an error in your SQL syntax; check the manual that corresponds to your (.*?) ' .
            'server version for the right syntax to use near \'\' at line 1@', mysql_error());
    }

    public function test_mysql_errno()
    {
        $this->getConnection();

        $this->assertEmpty(mysql_errno());

        $result = mysql_query("SELECT VERSION(");
        $this->assertFalse($result);

        $this->assertEquals(1064, mysql_errno());
    }

    public function test_mysql_escape_string()
    {
        $this->assertEquals('\\\'\0\Z\r\n\"\\\\safestring', @mysql_escape_string("'\0\032\r\n\"\\safestring"));
    }

    /**
     * @requires PHP 7.0.0
     * @expectedException \PHPUnit_Framework_Error_Notice
     * @expectedExceptionMessage mysql_escape_string() is insecure; use mysql_real_escape_string() instead!
     */
    public function test_mysql_escape_string_notice()
    {
        mysql_escape_string("'\0\032\r\n\"\\");
    }

    public function tearDown()
    {
        @mysql_close();
    }

    public function test_mysql_select_db()
    {
        $this->getConnection();

        $this->assertTrue(mysql_select_db('shim_test'));
    }

    public function test_mysql_select_db_specialchars()
    {
        $this->getConnection('shim-test');

        $this->assertTrue(mysql_select_db('shim-test'));
    }
    
    public function test_mysql_select_db_invalid()
    {
        $this->getConnection();
        
        $this->assertFalse(mysql_select_db('nonexistent'));
    }

    public static function setUpBeforeClass()
    {
        error_reporting(E_ALL & ~E_DEPRECATED);
        if (getenv('TRAVIS') === false) {
            fwrite(STDERR, "=> Finding binaries\n");
            static::$bin['docker'] = $docker = exec('/usr/bin/env which docker');
            if (empty($docker)) {
                static::markTestSkipped('Docker is required to run these tests');
            }

            fwrite(STDERR, "=> Running Docker Container: ");
            static::$container = exec($docker . ' run -e MYSQL_ALLOW_EMPTY_PASSWORD=1 -P -d  mysql/mysql-server:5.7');

            if (empty(static::$container)) {
                static::markTestSkipped("Unable to start docker container");
            }

            fwrite(STDERR, static::$container . "\n");

            fwrite(STDERR, "=> Finding MySQL Host: ");
            static::$host = exec($docker . ' port ' . self::$container . ' 3306');
            fwrite(STDERR, static::$host . "\n");

            fwrite(STDERR, "=> Waiting on mysqld to start:");
            $out = '';
            while (trim($out) != 'mysqld') {
                $out = exec(static::$bin['docker'] . ' exec ' . static::$container . ' ps ax | awk \'/mysqld/ {print $NF}\'');
            }
            fwrite(STDERR, " started\n");
            sleep(3);

            fwrite(STDERR, "=> Docker Container Running\n\n");

            return;
        }


        static::$host = '0.0.0.0';
    }

    public static function tearDownAfterClass()
    {
        if (getenv('TRAVIS') === false) {
            fwrite(STDERR, "\n\nStopping Docker Container: ");
            $output = exec(static::$bin['docker'] . ' stop ' . static::$container);
            if (trim($output) !== static::$container) {
                fwrite(STDERR, " Failed to stop container!\n");
                return;
            }

            $output = exec(static::$bin['docker'] . ' rm ' . static::$container);
            if (trim($output) !== static::$container) {
                fwrite(STDERR, " Failed to remove container!\n");
                return;
            }
            fwrite(STDERR, "Done\n");

            return;
        }

        mysql_connect(static::$host, "root");
        mysql_query("DROP DATABASE IF EXISTS shim_test");
        mysql_query("DROP DATABASE IF EXISTS `shim-test`");
    }

    public function mysql_fetch_DataProvider()
    {
        $numeric = array(
            array('1', '1'),
            array('2', '2'),
            array('3', '3'),
            array('4', '4'),
        );

        $assoc = array(
            array('one' => '1', 'two' => '1'),
            array('one' => '2', 'two' => '2'),
            array('one' => '3', 'two' => '3'),
            array('one' => '4', 'two' => '4'),
        );

        $array = array(
            array('1', '1', 'one' => '1', 'two' => '1'),
            array('2', '2', 'one' => '2', 'two' => '2'),
            array('3', '3', 'one' => '3', 'two' => '3'),
            array('4', '4', 'one' => '4', 'two' => '4'),
        );

        $object = array(
            (object) array('one' => '1', 'two' => '1'),
            (object) array('one' => '2', 'two' => '2'),
            (object) array('one' => '3', 'two' => '3'),
            (object) array('one' => '4', 'two' => '4'),
        );

        return array(
            array(
                'function' => 'mysql_fetch_array',
                'results' => $assoc,
                'resultType' => MYSQL_ASSOC
            ),
            array(
                'function' => 'mysql_fetch_array',
                'results' => $array,
                'resultType' => MYSQL_BOTH
            ),
            array(
                'function' => 'mysql_fetch_array',
                'results' => $numeric,
                'resultType' => MYSQL_NUM
            ),
            array(
                'function' => 'mysql_fetch_assoc',
                'results' => $assoc
            ),
            array(
                'function' => 'mysql_fetch_row',
                'results' => $numeric
            ),
            array(
                'function' => 'mysql_fetch_object',
                'results' => $object,
            )
        );
    }

    public function mysql_fetch_no_rows_dataProvider()
    {
        return array(
            array(
                'function' => 'mysql_fetch_array',
            ),
            array(
                'function' => 'mysql_fetch_assoc',
            ),
            array(
                'function' => 'mysql_fetch_row',
            ),
            array(
                'function' => 'mysql_fetch_object',
            ),
        );
    }

    public function mysql_function_invalid_result_DataProvider()
    {
        return array(
            array(
                "function" => "mysql_result",
                "message" => "mysql_result\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_num_rows",
                "message" => "mysql_num_rows\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(),
            ),
            array(
                "function" => "mysql_num_fields",
                "message" => "mysql_num_fields\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(),
            ),
            array(
                "function" => "mysql_fetch_row",
                "message" => "mysql_fetch_row\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(),
                "skipHHVM" => true
            ),
            array(
                "function" => "mysql_fetch_array",
                "message" => "mysql_fetch_array\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(),
            ),
            array(
                "function" => "mysql_fetch_assoc",
                "message" => "mysql_fetch_assoc\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(),
                "skipHHVM" => true
            ),
            array(
                "function" => "mysql_fetch_object",
                "message" => "(mysql_fetch_object\(\): )?supplied argument is not a valid MySQL result resource",
                "args" => array("StdClass")
            ),
            array(
                "function" => "mysql_data_seek",
                "message" => "mysql_data_seek\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_fetch_lengths",
                "message" => "mysql_fetch_lengths\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array()
            ),
            array(
                "function" => "mysql_fetch_field",
                "message" => "mysql_fetch_field\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array()
            ),
            array(
                "function" => "mysql_field_seek",
                "message" => "mysql_field_seek\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_free_result",
                "message" => "mysql_free_result\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array()
            ),
            array(
                "function" => "mysql_field_name",
                "message" => "mysql_field_name\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_field_table",
                "message" => "mysql_field_table\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_field_len",
                "message" => "mysql_field_len\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_field_type",
                "message" => "mysql_field_type\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_field_flags",
                "message" => "mysql_field_flags\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0)
            ),
            array(
                "function" => "mysql_db_name",
                "message" => "mysql_db_name\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0),
                "skipHHVM" => true
            ),
            array(
                "function" => "mysql_tablename",
                "message" => "mysql_tablename\(\) expects parameter 1 to be resource, (null|NULL) given",
                "args" => array(0),
                "skipHHVM" => true
            ),
        );
    }

    /**
     * @param $result
     */
    protected function assertResult($result)
    {
        $this->assertTrue(
            is_resource($result) && get_resource_type($result) == 'mysql result'
            || $result instanceof \mysqli_result,
            mysql_error()
        );
    }

    protected function getConnection($db = 'shim_test')
    {
        $mysql = mysql_connect(static::$host, 'root');
        $this->assertConnection($mysql);

        mysql_query("SET NAMES latin1");

        $result = mysql_query("CREATE DATABASE IF NOT EXISTS `$db` CHARACTER SET latin1;");
        $this->assertTrue($result);
        $result = mysql_select_db($db);
        $this->assertTrue($result);
        $result = mysql_query(
            "CREATE TABLE IF NOT EXISTS testing (
                id int AUTO_INCREMENT,
                one varchar(255),
                two varchar(255),
                three varchar(255),
                four varchar(255),
                five varchar(255),
                six varchar(255),
                seven varchar(255),
                eight varchar(255),
                nine ENUM('one', 'two', '\'three'),
                ten SET('one', 'two', '\'\'three'),
                eleven MEDIUMTEXT,
                INDEX one_idx (one),
                UNIQUE INDEX two_unq (two),
                INDEX three_four_idx (three, four),
                UNIQUE INDEX four_five_unq (four, five),
                INDEX seven_eight_idx (seven, eight),
                UNIQUE INDEX seven_eight_unq (seven, eight),
                PRIMARY KEY (id)
            ) CHARACTER SET latin1;"
        );

        $result = mysql_query(
            "CREATE TABLE IF NOT EXISTS testing2 (
                id int AUTO_INCREMENT,
                one varchar(255),
                two varchar(255),
                three varchar(255),
                four varchar(255),
                five varchar(255),
                six varchar(255),
                seven varchar(255),
                eight varchar(255),
                nine ENUM('one', 'two', '\'three'),
                ten SET('one', 'two', '\'\'three'),
                eleven MEDIUMTEXT,
                INDEX one_idx (one),
                UNIQUE INDEX two_unq (two),
                INDEX three_four_idx (three, four),
                UNIQUE INDEX four_five_unq (four, five),
                INDEX seven_eight_idx (seven, eight),
                UNIQUE INDEX seven_eight_unq (seven, eight),
                PRIMARY KEY (id)
            ) CHARACTER SET latin1;"
        );

        if ($db !== null) {
            $this->assertTrue(mysql_select_db($db));
        }

        return $mysql;
    }

    /**
     * @param $mysql
     */
    protected function assertConnection($mysql)
    {
        $this->assertTrue(
            is_resource($mysql) && get_resource_type($mysql) == 'mysql link'
            ||
            $mysql instanceof \mysqli,
            "Not a valid MySQL connection"
        );
    }

    protected function skipForHHVM($condition = true)
    {
        if ($this->runtime->isHHVM() && $condition) {
            $this->markTestSkipped("HHVM Behavior differs from PHP");
        }
    }
}