diff --git a/store/adapters/rdbms/upgrade.go b/store/adapters/rdbms/upgrade.go index b9767b147..9ecd79a58 100644 --- a/store/adapters/rdbms/upgrade.go +++ b/store/adapters/rdbms/upgrade.go @@ -31,6 +31,7 @@ func (s *Store) Upgrade(ctx context.Context) (err error) { fix202209_extendComposeModuleFieldsForPrivacyAndDAL, fix202209_dropObsoleteComposeModuleFields, fix202209_composeRecordRevisions, + fix202209_extendDalConnectionsForMeta, } for _, fix := range fixes { diff --git a/store/adapters/rdbms/upgrade_fixes.go b/store/adapters/rdbms/upgrade_fixes.go index d5109a029..ff50fa03c 100644 --- a/store/adapters/rdbms/upgrade_fixes.go +++ b/store/adapters/rdbms/upgrade_fixes.go @@ -116,3 +116,12 @@ func fix202209_composeRecordRevisions(ctx context.Context, s *Store) (err error) //// make a copy of records to changes table //return s.Exec(ctx, copyAll) } + +func fix202209_extendDalConnectionsForMeta(ctx context.Context, s *Store) (err error) { + s.log(ctx).Info("extending dal_connections table with meta column") + return s.SchemaAPI.AddColumn( + ctx, s.DB, + &Table{Name: "dal_connections"}, + &Column{Type: ColumnType{Type: ColumnTypeJson}, DefaultValue: "'{}'", Name: "meta"}, + ) +}