danog/MadelineProto
1
0
Fork 0
mirror of https://github.com/danog/MadelineProto.git synced 2024-11-27 06:34:41 +01:00
Code Issues Projects Releases Wiki Activity

Fix: Don`t connect to previous instance of same db.

Browse Source
This commit is contained in:
Alexander Pankratov 2021-08-16 03:42:18 +03:00
parent 36029ce56a
commit 32c5417895
2 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -48,7 +48,7 @@ interface DbArray extends DbType, \ArrayAccess, \Countable
*
* @psalm-param T $value
*
* @return void
* @return Promise
*/
public function offsetSet($index, $value);
/**

24
src/danog/MadelineProto/Db/DriverArray.php
View File

@ -84,12 +84,8 @@ abstract class DriverArray implements DbArray
*/
public static function getInstance(string $table, $previous, $settings): Promise
{
if ($previous && \get_class($previous) === static::class && $previous->getTable() === $table) {
$instance = &$previous;
} else {
$instance = new static();
$instance->setTable($table);
}
/** @psalm-suppress UndefinedPropertyAssignment */
$instance->dbSettings = $settings;
@ -101,7 +97,7 @@ abstract class DriverArray implements DbArray
yield from $instance->initConnection($settings);
yield from $instance->prepareTable();
if ($instance !== $previous) {
if (static::getClassName($previous) !== static::getClassName($instance)) {
if ($previous instanceof DriverArray) {
yield from $previous->initStartup();
}
@ -125,7 +121,7 @@ abstract class DriverArray implements DbArray
*/
protected static function renameTmpTable(self $new, $old): \Generator
{
if ($old && \str_replace('NullCache\\', '', \get_class($old)) === \str_replace('NullCache\\', '', \get_class($new)) && $old->getTable()) {
if ($old instanceof SqlArray && $old->getTable()) {
if (
$old->getTable() !== $new->getTable() &&
\mb_strpos($new->getTable(), 'tmp') !== 0
@ -146,10 +142,7 @@ abstract class DriverArray implements DbArray
*/
protected static function migrateDataToDb(self $new, $old): \Generator
{
if (!empty($old) && !$old instanceof static) {
if (\str_replace('NullCache\\', '', \get_class($old)) === \str_replace('NullCache\\', '', \get_class($new))) {
return;
}
if (!empty($old) && static::getClassName($old) !== static::getClassName($new)) {
Logger::log('Converting '.\get_class($old).' to '.\get_class($new), Logger::ERROR);
if (!$old instanceof DbArray) {
@ -217,4 +210,15 @@ abstract class DriverArray implements DbArray
{
throw new \RuntimeException('Native isset not support promises. Use isset method');
}
protected static function getClassName($instance): ?string
{
if ($instance === null) {
return null;
} elseif (is_array($instance)) {
return 'Array';
} else {
return \str_replace('NullCache\\', '', \get_class($instance));
}
}
}