migration gamersclub from bronze to silver

src/03.silver/gamersclub/ingestion.py

@@ -0,0 +1,24 @@
+# Databricks notebook source
+import sys
+
+sys.path.insert(0, '../../lib')
+
+import dbtools
+
+# COMMAND ----------
+
+database = "silver.gamersclub"
+table_name = dbutils.widgets.get("table_name")
+
+query = dbtools.import_query(f"sql/{table_name}.sql")
+
+# COMMAND ----------
+
+(spark.sql(query)
+      .coalesce(1)
+      .write
+      .mode("overwrite")
+      .format("delta")
+      .option("overwriteSchema", "true")
+      .saveAsTable(f"{database}.{table_name}")
+)

src/03.silver/gamersclub/sql/estatisticas_partidas_jogadores.sql

@@ -0,0 +1,42 @@
+SELECT
+    int(idLobbyGame) AS idLobbyJogo,
+    int(idPlayer) AS idJogador,
+    int(idRoom) AS idSala,
+    descMapName AS descNomeMapa,
+    int(qtKill) AS qtAbates,
+    int(qtAssist) AS qtdAssistencias,
+    int(qtDeath) AS qtMortes,
+    int(qtHs) AS qtHS,
+    int(qtBombeDefuse) AS qtBombasDesarmadas,
+    int(qtBombePlant) AS qtBombasArmadas,
+    int(qtTk) AS qtAbateAmigo,
+    int(qtTkAssist) AS qtAssistenciaAbateAmigo,
+    int(qt1Kill) AS qt1AbateRound,
+    int(qt2Kill) AS qt2AbateRound,
+    int(qt3Kill) AS qt3AbateRound,
+    int(qt4Kill) AS qt4AbateRound,
+    int(qt5Kill) AS qt5AbateRound,
+    int(qtPlusKill) AS qtMultiplosAbates,
+    int(qtFirstKill) AS qtPrimeiroAbate,
+    int(vlDamage) AS vlDano,
+    int(qtHits) AS qtAcertos,
+    int(qtShots) AS qtDisparos,
+    int(qtLastAlive) AS qtUltimoSobrevivente,
+    int(qtClutchWon) AS qtClutchsVencidos,
+    int(qtRoundsPlayed) AS qtRoundsJogados,
+    int(qtSurvived) AS qtRoundVivos,
+    int(qtTrade) AS qtTrocaAbates,
+    int(qtFlashAssist) AS qtAssistenciaFlash,
+    int(qtHitHeadshot) AS qtAcertosCabeca,
+    int(qtHitChest) AS qtAcertosPeito,
+    int(qtHitStomach) AS qtAcertosEstomago,
+    int(qtHitLeftAtm) AS qtAcertosBracoEsquerdo,
+    int(qtHitRightArm) AS qtAcertosBracoDireito,
+    int(qtHitLeftLeg) AS qtAcertosPernaEsquerda,
+    int(qtHitRightLeg) AS qtAcertosPernaDireita,
+    case when int(flWinner) = 1 then TRUE else FALSE end as flVitoria ,
+    int(vlLevel) AS vlLevel,
+    timestamp(dtCreatedAt) AS dtPartida
+
+FROM bronze.gamersclub.tb_lobby_stats_player
+

src/03.silver/gamersclub/sql/jogadores.sql

@@ -0,0 +1,10 @@
+SELECT 
+       int(idPlayer) AS idJogador,
+       case when int(flFacebook) = 1 then TRUE else FALSE end as flFacebook,
+       case when int(flTwitter) = 1 then TRUE else FALSE end as flTwitter,
+       case when int(flTwitch) = 1 then TRUE else FALSE end as flTwitch,
+       descCountry AS descPais,
+       date(dtBirth) AS dtNascimento,
+       timestamp(dtRegistration) AS dtCadastro
+
+FROM bronze.gamersclub.tb_players

src/03.silver/gamersclub/sql/medalhas.sql

@@ -0,0 +1,5 @@
+SELECT int(idMedal) AS idMedalha,
+       descMedal AS descMedalha,
+       descTypeMedal AS descTipoMedalha
+
+FROM bronze.gamersclub.tb_medalha

src/03.silver/gamersclub/sql/medalhas_jogadores.sql

@@ -0,0 +1,9 @@
+SELECT int(id) AS id, 
+       int(idPlayer) AS idJogador,
+       int(idMedal) AS idMedalha,
+       date(dtCreatedAt) AS dtCriacao,
+       date(dtExpiration) AS dtExpiracao,
+       date(dtRemove) AS dtRemocao,
+       int(flActive) AS flAtiva
+
+FROM bronze.gamersclub.tb_players_medalha