hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-27 01:16:36 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Collect SQL with schema editor

Browse Source
This commit is contained in:
tcely 2025-05-04 07:46:36 -04:00 committed by GitHub
parent cc9b5446c1
commit 2a98707254
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
tubesync/sync/management/commands/fix-mariadb.py
View File

@ -119,7 +119,7 @@ class Command(BaseCommand):
else:
self.stdout.write('Time to update the columns!')
schema = db.connection.schema_editor()
schema = db.connection.schema_editor(collect_sql=True)
quote_name = schema.quote_name
media_table_str = quote_name('sync_media')
source_table_str = quote_name('sync_source')
@ -139,8 +139,9 @@ class Command(BaseCommand):
to_column=uuid_column_str,
deferrable='',
)
statement_list = [ f'{statement};' for statement in (
remove_fk,
schema.execute(remove_fk, None)
schema.execute(
schema.sql_alter_column % dict(
table=media_table_str,
changes=schema.sql_alter_column_not_null % dict(
@ -148,6 +149,9 @@ class Command(BaseCommand):
column=uuid_column_str,
),
),
None,
)
schema.execute(
schema.sql_alter_column % dict(
table=media_table_str,
changes=schema.sql_alter_column_not_null % dict(
@ -155,6 +159,9 @@ class Command(BaseCommand):
column=source_id_column_str,
),
),
None,
)
schema.execute(
schema.sql_alter_column % dict(
table=source_table_str,
changes=schema.sql_alter_column_not_null % dict(
@ -162,9 +169,11 @@ class Command(BaseCommand):
column=uuid_column_str,
),
),
add_fk,
) ]
pp( statement_list )
None,
)
schema.execute(add_fk, None)
pp( schema.collected_sql )
self.stdout.write('Tables to delete:')
pp( table_names )