Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

migration::V20

Browse Source
This commit is contained in:
shimon
2023-09-21 15:42:02 +03:00
parent f34b8a6865
commit fe703e3137
2 changed files with 25 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Migration/Migration.php
+3 -1
View File
@@ -191,7 +191,9 @@ abstract class Migration
$sum = 0;
$nextDocument = null;
$collectionCount = $this->projectDB->count($collectionId);
var_dump('###################');
var_dump($collectionCount);
var_dump('###################');
do {
$queries = [Query::limit($this->limit)];
if ($nextDocument !== null) {
src/Appwrite/Migration/Version/V20.php
+22 -16
View File
@@ -5,6 +5,7 @@ namespace Appwrite\Migration\Version;
use Appwrite\Migration\Migration;
use Utopia\CLI\Console;
use Utopia\Database\Database;
use Utopia\Database\Document;
use Utopia\Database\Query;
class V20 extends Migration
@@ -53,13 +54,31 @@ class V20 extends Migration
protected function migrateStatsMetric(string $from, string $to): void
{
try {
$sum = $this->projectDB->sum('stats', 'value', [
Query::equal('metric', [$from]),
Query::equal('period', ['1d']),
Query::greaterThan('value', 0),
]);
$this->projectDB->createDocument('stats', new Document([
'$id' => \md5("null_inf_{$to}"),
'metric' => $to,
'period' => 'inf',
'value' => ($sum + 0),
'time' => null,
'region' => 'default',
]));
$stats = $this->projectDB->find('stats', [
Query::equal('metric', [$from]),
]);
$cnt = 0;
foreach ($stats as $stat) {
$stat->setAttribute('metric', $to);
$this->projectDB->updateDocument('stats', $stat->getId(), $stat);
var_dump([
'id' => $stat->getInternalId(),
@@ -67,21 +86,8 @@ class V20 extends Migration
'to' => $to,
]);
if ($stat['period'] === '1d') {
$sum = $this->projectDB->sum('stats', 'value', [
Query::equal('metric', [$from]),
Query::equal('period', ['1d']),
Query::greaterThan('value', 0),
]);
$stat
->setAttribute('$id', \md5("null_inf_{$to}"))
->setAttribute('period', 'inf')
->setAttribute('value', ($sum + 0))
->setAttribute('region', 'default')
;
$this->projectDB->createDocument('stats', $stat);
}
$cnt++;
var_dump($cnt);
}
} catch (\Throwable $th) {
Console::warning("Migrating steps from {$this->projectDB->getDefaultDatabase()}`.`_{$this->project->getInternalId()}_stats:" . $th->getMessage());