Coco\SourceWatcher\Tests\Core\Database\Connections\MySqlConnectorTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	testSetGetUnixSocket()	0	10	1
A	testInsertUsingWrongConnectionParameters()	0	17	1
A	testGetConnection()	0	12	1
A	testSetGetCharset()	0	10	1

<?php declare( strict_types = 1 );

namespace Coco\SourceWatcher\Tests\Core\Database\Connections;

use Coco\SourceWatcher\Core\Database\Connections\MySqlConnector;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;
use Coco\SourceWatcher\Utils\i18n;
use PHPUnit\Framework\TestCase;

/**
 * Class MySqlConnectorTest
 * @package Coco\SourceWatcher\Tests\Core\Database\Connections
 */
class MySqlConnectorTest extends TestCase
{
    /**
     *
     */
    public function testSetGetUnixSocket () : void
    {
        $connector = new MySqlConnector();

        $given = "/var/run/mysqld/mysqld.sock";
        $expected = "/var/run/mysqld/mysqld.sock";

        $connector->setUnixSocket( $given );

        $this->assertEquals( $expected, $connector->getUnixSocket() );
    }

    /**
     *
     */
    public function testSetGetCharset () : void
    {
        $connector = new MySqlConnector();

        $given = "utf8";
        $expected = "utf8";

        $connector->setCharset( $given );

        $this->assertEquals( $expected, $connector->getCharset() );
    }

    /**
     * @throws SourceWatcherException
     */
    public function testGetConnection () : void
    {
        $connector = new MySqlConnector();
        $connector->setUser( "admin" );
        $connector->setPassword( "secret" );
        $connector->setHost( "localhost" );
        $connector->setPort( 3306 );;
        $connector->setDbName( "people" );
        $connector->setUnixSocket( "/var/run/mysqld/mysqld.sock" );
        $connector->setCharset( "utf-8" );

        $this->assertNotNull( $connector->connect() );
    }

    /**
     * @throws SourceWatcherException
     */
    public function testInsertUsingWrongConnectionParameters () : void
    {
        $this->expectException( SourceWatcherException::class );
        $this->expectExceptionMessage( i18n::getInstance()->getText( MySqlConnector::class, "No_Table_Name_Found" ) );

        $connector = new MySqlConnector();
        $connector->setUser( "admin" );
        $connector->setPassword( "secret" );
        $connector->setHost( "localhost" );
        $connector->setPort( 3306 );;
        $connector->setDbName( "people" );
        $connector->setUnixSocket( "/var/run/mysqld/mysqld.sock" );
        $connector->setCharset( "utf-8" );

        $row = new Row( [ "id" => "1", "name" => "John Doe", "email_address" => "johndoe@email.com" ] );

        $connector->insert( $row );
    }
}