danog/MadelineProto
2
2
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Additional mysql settings

Browse Source
This commit is contained in:
Alexander Pankratov 2020-05-04 23:09:39 +03:00
parent ae9edd5512
commit ab168ce655
3 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/danog/MadelineProto/Db/Mysql.php
View File

@ -4,6 +4,7 @@ namespace danog\MadelineProto\Db;
use Amp\Mysql\ConnectionConfig; use Amp\Mysql\ConnectionConfig;
use Amp\Mysql\Pool; use Amp\Mysql\Pool;
use Amp\Sql\Common\ConnectionPool;
use function Amp\call; use function Amp\call;
use function Amp\Mysql\Pool; use function Amp\Mysql\Pool;
use function Amp\Promise\wait; use function Amp\Promise\wait;
@ -20,6 +21,9 @@ class Mysql
* @param string $password * @param string $password
* @param string $db * @param string $db
* *
* @param int $maxConnections
* @param int $idleTimeout
*
* @return Pool * @return Pool
* @throws \Amp\Sql\ConnectionException * @throws \Amp\Sql\ConnectionException
* @throws \Amp\Sql\FailureException * @throws \Amp\Sql\FailureException
@ -30,7 +34,9 @@ class Mysql
int $port = 3306, int $port = 3306,
string $user = 'root', string $user = 'root',
string $password = '', string $password = '',
string $db = 'MadelineProto' string $db = 'MadelineProto',
int $maxConnections = ConnectionPool::DEFAULT_MAX_CONNECTIONS,
int $idleTimeout = ConnectionPool::DEFAULT_IDLE_TIMEOUT
): Pool ): Pool
{ {
$dbKey = "$host:$port:$db"; $dbKey = "$host:$port:$db";
@ -40,7 +46,7 @@ class Mysql
); );
static::createDb($config); static::createDb($config);
static::$connections[$dbKey] = pool($config); static::$connections[$dbKey] = pool($config, $maxConnections, $idleTimeout);
} }
return static::$connections[$dbKey]; return static::$connections[$dbKey];

2
src/danog/MadelineProto/Db/MysqlArray.php
View File

@ -247,6 +247,8 @@ class MysqlArray implements DbArray
$settings['user'], $settings['user'],
$settings['password'], $settings['password'],
$settings['database'], $settings['database'],
$settings['max_connections'],
$settings['idle_timeout']
); );
} }

6
src/danog/MadelineProto/MTProto.php
View File

@ -1320,8 +1320,10 @@ class MTProto extends AsyncConstruct implements TLCallback
'port' => 3306, 'port' => 3306,
'user' => 'root', 'user' => 'root',
'password' => '', 'password' => '',
'database' => 'MadelineProto', 'database' => 'MadelineProto', //will be created automatically
'cache_ttl' => '+1 day', 'max_connections' => 10,
'idle_timeout' => 60,
'cache_ttl' => '+1 day', //keep records in memory after last read
] ]
], ],
'upload' => ['allow_automatic_upload' => true, 'part_size' => 512 * 1024, 'parallel_chunks' => 20], 'download' => ['report_broken_media' => true, 'part_size' => 1024 * 1024, 'parallel_chunks' => 20], 'pwr' => [ 'upload' => ['allow_automatic_upload' => true, 'part_size' => 512 * 1024, 'parallel_chunks' => 20], 'download' => ['report_broken_media' => true, 'part_size' => 1024 * 1024, 'parallel_chunks' => 20], 'pwr' => [