easyswoole/mysqli-pool

An efficient swoole framework

Maintainers

Details

github.com/easy-swoole/mysqli-pool

Homepage

Source

Issues

Installs: 8 017

Dependents: 1

Suggesters: 0

Security: 0

Stars: 5

Watchers: 2

Forks: 4

Open Issues: 1

1.0.4 2019-08-09 03:44 UTC

Requires

Requires (Dev)

Apache-2.0 6bb1a92703ee796c0dc7fd907fdff5f261db66f6

  • YF <291323003.woop@qq.com>

frameworkasyncswooleeasyswoole

This package is auto-updated.

Last update: 2024-12-09 15:45:49 UTC

README

Pool Register

Register connection config before worker start ( master process);

use EasySwoole\Mysqli\Config;
use EasySwoole\MysqliPool;

$config1 = new Config();
$config2 = new Config;

Mysql::getInstance()->register('mysql1',$config1);
Mysql::getInstance()->register('mysql2',$config2);

Pool Usage

use EasySwoole\MysqliPool\Mysql;
use EasySwoole\MysqliPool\Connection;
use EasySwoole\Mysqli\Config;

$config1 = new Config([
    'host'          => '',
    'port'          => 3306,
    'user'          => '',
    'password'      => '',
    'database'      => '',
    'timeout'       => 5,
    'charset'       => 'utf8mb4',
]);

$config2 = new Config([
    'host' => '',
    'port' => 3306,
    'user' => '',
    'password' => '',
    'database' => '',
    'timeout' => 5,
    'charset' => 'utf8mb4',
]);

//注册的时候会返回对应的poolConf
Mysql::getInstance()->register('my1',$config1);

Mysql::getInstance()->register('my2',$config2);

go(function (){
    $conn = Mysql::defer('my1');
    var_dump(count($conn->rawQuery('show tables')));

    $ret =  Mysql::invoker('my1',function (Connection $conn){
        return $conn->rawQuery('show tables');
    });
    var_dump(count($ret));
});

go(function (){
    $conn = Mysql::defer('my2');
    var_dump(count($conn->rawQuery('show tables')));

    $ret =  Mysql::invoker('my2',function (Connection $conn){
        return $conn->rawQuery('show tables');
    });
    var_dump(count($ret));
});