andromeda/Andromeda.Commands/MigrateCommand.cs at 23af211a2a620747eb6799ba573fe8b669c184a3 · Jellyfish-Insights/andromeda · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
using System;
using DataLakeModels;
using Andromeda.Common;
using System.Collections.Generic;

namespace Andromeda.Commands {

    public static class MigrateCommand {

        public static void Migrate(Databases db, bool force_update = false) {
            switch (db) {
                case Databases.LakeYouTubeData:
                    DatabaseOperations.Migrate<DataLakeYouTubeDataContext>();
                    break;
                case Databases.LakeYouTubeStudio:
                    DatabaseOperations.Migrate<DataLakeYouTubeStudioContext>();
                    break;
                case Databases.LakeYouTubeAnalytics:
                    DatabaseOperations.Migrate<DataLakeYouTubeAnalyticsContext>();
                    break;
                case Databases.LakeAdWords:
                    DatabaseOperations.Migrate<DataLakeAdWordsContext>();
                    break;
                case Databases.LakeLogging:
                    DatabaseOperations.Migrate<DataLakeLoggingContext>();
                    break;
                case Databases.LakeTwitterData:
                    DatabaseOperations.Migrate<DataLakeTwitterDataContext>();
                    break;
                case Databases.LakeTwitterAds:
                    DatabaseOperations.Migrate<DataLakeTwitterAdsContext>();
                    break;
                case Databases.LakeFacebook:
                    Jobs.Fetcher.Facebook.DatabaseInitializer.Init(force_update);
                    Jobs.Fetcher.Facebook.DatabaseInitializer.Init(new List<string> { "instagram" });
                    break;
                case Databases.LakeTikTok:
                    DatabaseOperations.Migrate<DataLakeTikTokContext>();
                    break;
                case Databases.LakeReels:
                    DatabaseOperations.Migrate<DataLakeReelsContext>();
                    break;
                default:
                    throw new Exception("Invalid database");
            }
        }

        public static void MigrateDataLake() {
            DatabaseOperations.Migrate<DataLakeYouTubeDataContext>();
            DatabaseOperations.Migrate<DataLakeYouTubeStudioContext>();
            DatabaseOperations.Migrate<DataLakeYouTubeAnalyticsContext>();
            DatabaseOperations.Migrate<DataLakeAdWordsContext>();
            DatabaseOperations.Migrate<DataLakeTwitterDataContext>();
            DatabaseOperations.Migrate<DataLakeTwitterAdsContext>();
            DatabaseOperations.Migrate<DataLakeLoggingContext>();
            DatabaseOperations.Migrate<DataLakeTikTokContext>();
            DatabaseOperations.Migrate<DataLakeReelsContext>();
            Console.WriteLine("Successfully migrated data-lake.");
        }

        public static void MigrateFacebook(bool force_update = false) {
            Migrate(Databases.LakeFacebook, force_update);
            Console.WriteLine("Successfully migrated Facebook-lake.");
        }
    }
}