update script

Author: giancarloromeo

…/028ada3e3ec9_move_projects_workbench.py …/1d74a6de5e36_move_projects_workbench.pypackages/postgres-database/src/simcore_postgres_database/migration/versions/028ada3e3ec9_move_projects_workbench.py renamed to packages/postgres-database/src/simcore_postgres_database/migration/versions/1d74a6de5e36_move_projects_workbench.py packages/postgres-database/src/simcore_postgres_database/migration/versions/028ada3e3ec9_move_projects_workbench.py renamed to packages/postgres-database/src/simcore_postgres_database/migration/versions/1d74a6de5e36_move_projects_workbench.py

@@ -1,26 +1,27 @@
 """Move projects workbench
 
-Revision ID: 028ada3e3ec9
+Revision ID: 1d74a6de5e36
 Revises: 307017ee1a49
-Create Date: 2025-01-07 10:25:54.137095+00:00
+Create Date: 2025-01-07 11:54:32.232909+00:00
 
 """
 import sqlalchemy as sa
 from alembic import op
 from sqlalchemy.dialects import postgresql
 
 # revision identifiers, used by Alembic.
-revision = "028ada3e3ec9"
+revision = "1d74a6de5e36"
 down_revision = "307017ee1a49"
 branch_labels = None
 depends_on = None
 
 
 def upgrade():
     # ### commands auto generated by Alembic - please adjust! ###
-    op.add_column("projects_nodes", sa.Column("key", sa.String(), nullable=False))
-    op.add_column("projects_nodes", sa.Column("version", sa.String(), nullable=False))
-    op.add_column("projects_nodes", sa.Column("label", sa.String(), nullable=False))
+    op.add_column("projects_nodes", sa.Column("key", sa.String(), nullable=True))
+    op.add_column("projects_nodes", sa.Column("version", sa.String(), nullable=True))
+    op.add_column("projects_nodes", sa.Column("label", sa.String(), nullable=True))
+
     op.add_column("projects_nodes", sa.Column("progress", sa.Numeric(), nullable=True))
     op.add_column("projects_nodes", sa.Column("thumbnail", sa.String(), nullable=True))
     op.add_column(
@@ -38,6 +39,30 @@ def upgrade():
     )
     # ### end Alembic commands ###
 
+    op.execute(
+        """
+UPDATE projects_nodes
+SET key = subquery.key,
+    version = subquery.version,
+    label = subquery.label
+FROM (
+    SELECT
+        projects.uuid AS project_id,
+        js.key AS node_id,
+        js.value::jsonb ->> 'key' AS key,
+        js.value::jsonb ->> 'label' AS label,
+        js.value::jsonb ->> 'version' AS version
+    FROM projects,
+    json_each(projects.workbench) AS js
+) AS subquery
+WHERE projects_nodes.project_uuid = subquery.project_id
+AND projects_nodes.node_id = subquery.node_id;
+"""
+    )
+    op.alter_column("projects_nodes", "key", nullable=False)
+    op.alter_column("projects_nodes", "version", nullable=False)
+    op.alter_column("projects_nodes", "label", nullable=False)
+
 
 def downgrade():
     # ### commands auto generated by Alembic - please adjust! ###