refactor: templatize db name in migration

Also refactors migration to use `create or replace` instead of dropping
and recreating tables and dictionaries.

Author: SoryRawyer

tutoraspects/templates/aspects/apps/aspects/migrations/alembic/versions/0014_add_course_names_fields.py

@@ -13,18 +13,7 @@
 def upgrade():
     op.execute(
         """
-        DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names;
-    """
-    )
-    op.execute(
-        """
-        DROP DICTIONARY IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names_dict;
-    """
-    )
-
-    op.execute(
-        """
-        CREATE DICTIONARY {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names_dict (
+        CREATE OR REPLACE DICTIONARY {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names_dict (
             course_key String,
             course_name String,
             course_run String,
@@ -34,18 +23,18 @@ def upgrade():
         SOURCE(CLICKHOUSE(
             user '{{ CLICKHOUSE_ADMIN_USER }}'
             password '{{ CLICKHOUSE_ADMIN_PASSWORD }}'
-            db 'event_sink'
+            db '{{ ASPECTS_EVENT_SINK_DATABASE }}'
             query 'with most_recent_overviews as (
                     select org, course_key, max(modified) as last_modified
-                    from event_sink.course_overviews
+                    from {{ ASPECTS_EVENT_SINK_DATABASE }}.course_overviews
                     group by org, course_key
             )
             select
                 course_key,
                 display_name,
                 splitByString(\\'+\\', course_key)[-1] as course_run,
                 org
-            from event_sink.course_overviews co
+            from {{ ASPECTS_EVENT_SINK_DATABASE }}.course_overviews co
             inner join most_recent_overviews mro on
                 co.org = mro.org and
                 co.course_key = mro.course_key and
@@ -72,35 +61,24 @@ def upgrade():
 def downgrade():
     op.execute(
         """
-        DROP TABLE IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names;
-    """
-    )
-    op.execute(
-        """
-        DROP DICTIONARY IF EXISTS {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names_dict;
-    """
-    )
-
-    op.execute(
-        """
-        CREATE DICTIONARY {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names_dict (
+        CREATE OR REPLACE DICTIONARY {{ ASPECTS_EVENT_SINK_DATABASE }}.course_names_dict (
             course_key String,
             course_name String
         )
         PRIMARY KEY course_key
         SOURCE(CLICKHOUSE(
             user '{{ CLICKHOUSE_ADMIN_USER }}'
             password '{{ CLICKHOUSE_ADMIN_PASSWORD }}'
-            db 'event_sink'
+            db '{{ ASPECTS_EVENT_SINK_DATABASE }}'
             query 'with most_recent_overviews as (
                     select org, course_key, max(modified) as last_modified
-                    from event_sink.course_overviews
+                    from {{ ASPECTS_EVENT_SINK_DATABASE }}.course_overviews
                     group by org, course_key
             )
             select
                 course_key,
                 display_name
-            from event_sink.course_overviews co
+            from {{ ASPECTS_EVENT_SINK_DATABASE }}.course_overviews co
             inner join most_recent_overviews mro on
                 co.org = mro.org and
                 co.course_key = mro.course_key and