PHP Classes

File: example/benchmark.php

Recommend this page to a friend!
  Classes of Kacper Rowinski   PHP MySQL Replication   example/benchmark.php   Download  
File: example/benchmark.php
Role: Example script
Content type: text/plain
Description: Example script
Class: PHP MySQL Replication
Client to get MySQL replication events in pure PHP
Author: By
Last change: Feature/php71 (#53)

- Removed: support for lesser then php7
- Added: strong and string types
- Changed: ConfigFactory removed and method make form array moved to Config
- Changed: MariaDbGtidLogDTO replaced getSequenceNumber with getMariaDbGtid
- Fixed: Insert NULL in a boolean column returns no rows
- Fixed: float problem about time field type
- Fixed: column order
- Changed: getFields and getMasterStatus returns no VO
- Changed: Column to ColumnDTO and added ColumnDTOCollection
- Changed: replaced getFields with getColumnDTOCollection in TableMap
- Added: more compatibility for mysql 5.5, 5.6, 5.7, maria 10 and 8.0
- Removed: makeConfigFromArray
Date: 4 years ago
Size: 3,555 bytes
 

Contents

Class file image Download
<?php
declare(strict_types=1);
error_reporting(E_ALL);
date_default_timezone_set('UTC');
include
__DIR__ . '/../vendor/autoload.php';

use
Doctrine\DBAL\Connection;
use
Doctrine\DBAL\DriverManager;
use
MySQLReplication\Config\ConfigBuilder;
use
MySQLReplication\Definitions\ConstEventType;
use
MySQLReplication\Event\DTO\UpdateRowsDTO;
use
MySQLReplication\Event\EventSubscribers;
use
MySQLReplication\MySQLReplicationFactory;

/**
 * Simple benchmark to test how fast events are consumed
 */
class benchmark
{
    private const
DB_NAME = 'mysqlreplication_test';
    private const
DB_USER = 'root';
    private const
DB_PASS = 'root';
    private const
DB_HOST = '127.0.0.1';
    private const
DB_PORT = 3306;

    private
$binLogStream;

    public function
__construct()
    {
       
$conn = $this->getConnection();
       
$conn->exec('DROP DATABASE IF EXISTS ' . self::DB_NAME);
       
$conn->exec('CREATE DATABASE ' . self::DB_NAME);
       
$conn->exec('USE ' . self::DB_NAME);
       
$conn->exec('CREATE TABLE test (i INT) ENGINE = MEMORY');
       
$conn->exec('INSERT INTO test VALUES(1)');
       
$conn->exec('CREATE TABLE test2 (i INT) ENGINE = MEMORY');
       
$conn->exec('INSERT INTO test2 VALUES(1)');
       
$conn->exec('RESET MASTER');

       
$this->binLogStream = new MySQLReplicationFactory(
            (new
ConfigBuilder())
                ->
withUser(self::DB_USER)
                ->
withPassword(self::DB_PASS)
                ->
withHost(self::DB_HOST)
                ->
withPort(self::DB_PORT)
                ->
withEventsOnly([ConstEventType::UPDATE_ROWS_EVENT_V2])
                ->
withSlaveId(9999)
                ->
withDatabasesOnly([self::DB_NAME])
                ->
build()
        );

       
$this->binLogStream->registerSubscriber(
            new class extends
EventSubscribers
           
{
                private
$start;
                private
$counter = 0;

                public function
__construct()
                {
                   
$this->start = microtime(true);
                }

                public function
onUpdate(UpdateRowsDTO $event): void
               
{
                    ++
$this->counter;
                    if (
0 === ($this->counter % 1000)) {
                        echo ((int)(
$this->counter / (microtime(true) - $this->start)) . ' event by seconds (' . $this->counter . ' total)') . PHP_EOL;
                    }
                }
            }
        );
    }

    private function
getConnection(): Connection
   
{
        return
DriverManager::getConnection(
            [
               
'user' => self::DB_USER,
               
'password' => self::DB_PASS,
               
'host' => self::DB_HOST,
               
'port' => self::DB_PORT,
               
'driver' => 'pdo_mysql',
               
'dbname' => self::DB_NAME
           
]
        );
    }

    public function
run(): void
   
{
       
$pid = pcntl_fork();
        if (
$pid === -1) {
            throw new
InvalidArgumentException('Could not fork');
        }

        if (
$pid) {
           
$this->consume();
           
pcntl_wait($status);
        } else {
           
$this->produce();
        }
    }

    private function
consume(): void
   
{
       
$this->binLogStream->run();
    }

    private function
produce(): void
   
{
       
$conn = $this->getConnection();

        echo
'Start insert data' . PHP_EOL;
        while (
1) {
           
$conn->exec('UPDATE test SET i = i + 1;');
           
$conn->exec('UPDATE test2 SET i = i + 1;');
        }
    }
}

(new
benchmark())->run();