mysql

开源

一个用于 PHP 的异步 MySQL 客户端,可通过高效的非阻塞功能优化数据库交互。非常适用于响应速度快、性能高的应用程序。

377 stars0 点赞0 次浏览

工具介绍

一个用于 PHP 的异步 MySQL 客户端,可通过高效的非阻塞功能优化数据库交互。非常适用于响应速度快、性能高的应用程序。

amphp/mysql

AMPHP is a collection of event-driven libraries for PHP designed with fibers and concurrency in mind. amphp/mysql is an asynchronous MySQL client. The library implements concurrent querying by transparently distributing queries across a scalable pool of available connections. The MySQL client protocol is implemented using 100% PHP code; there are no external extension dependencies (e.g. ext/mysqli, ext/pdo, etc.).

Features

Exposes a non-blocking API for issuing multiple MySQL queries concurrently
Transparent connection pooling to overcome MySQL's fundamentally synchronous connection protocol
MySQL transfer encoding support (gzip, TLS encryption)
Support for parameterized prepared statements
Nested transactions with commit and rollback event hooks
Unbuffered results to reduce memory usage for large result sets
Full MySQL protocol support including all† available commands asynchronously

† As documented in official Mysql Internals Manual

Installation

This package can be installed as a Composer dependency.

bash

composer require amphp/mysql

Requirements

PHP 8.1+

Usage

More extensive code examples reside in the examples directory.

php

use Amp\Mysql\MysqlConfig;
use Amp\Mysql\MysqlConnectionPool;

$config = MysqlConfig::fromString(
    "host=localhost user=username password=password db=test"
);

$pool = new MysqlConnectionPool($config);

$statement = $pool->prepare("SELECT * FROM `table_name` WHERE `id` = :id");

$result = $statement->execute(['id' => 1337]);
foreach ($result as $row) {
    // $row is an associative-array of column values, e.g.: $row['column_name']
}