README

Parallel MySQL query execution for raw PHP projects using the msquery.

No framework required. PHP 7.4+.

Requirements

• PHP 7.4+
• msquery installed on server

Installation

composer require mojahed/php-multiquery

Binary Setup

cp msquery-linux-amd64 /usr/local/bin/msquery
chmod +x /usr/local/bin/msquery

Usage

use Mojahed\Raw\MultiQuery;

$results = MultiQuery::setConfig([
    'binary'   => '/usr/local/bin/msquery',
    'host'     => '127.0.0.1',
    'port'     => '3306',
    'user'     => 'root',
    'pass'     => 'secret',
    'database' => 'my_database',
    'timeout'  => 30,
    'throw'    => true,
])->run([
    'users'   => "SELECT COUNT(*) as total FROM users",
    'orders'  => "SELECT COUNT(*) as total FROM orders",
    'revenue' => "SELECT SUM(amount) as total FROM payments",
]);

$results['users']   // [['total' => 150]]
$results['orders']  // [['total' => 320]]
$results['revenue'] // [['total' => 250000]]

Reuse Instance

$mq = MultiQuery::setConfig([...]);

$stats   = $mq->run([...]);
$reports = $mq->run([...]);

Error Handling

use Mojahed\Raw\Exceptions\MultiQueryException;

try {
    $results = MultiQuery::setConfig([...])->run([
        'users'  => "SELECT COUNT(*) as total FROM users",
        'broken' => "SELECT * FROM non_existing_table",
    ]);
} catch (MultiQueryException $e) {
    $e->getFailedIndex();  // which query failed
    $e->getErrorString();  // MySQL error message
    $e->getResults();      // all raw results
}

Config Options