Method getTargetDBMetadata

backend/api/v1/database_service.go:843–952

(ctx context.Context, request *v1pb.DiffSchemaRequest)

}

func (s *DatabaseService) getTargetDBMetadata(ctx context.Context, request *v1pb.DiffSchemaRequest) (*model.DatabaseMetadata, error) {
	changeHistoryID := request.GetChangelog()

	// If the change history id is set, use the schema of the change history as the target.
	if changeHistoryID != "" {
		instanceID, databaseName, changelogID, err := common.GetInstanceDatabaseChangelogID(changeHistoryID)
		if err != nil {
			return nil, err
		}

		changelog, err := s.store.GetChangelog(ctx, &store.FindChangelogMessage{
			InstanceID: instanceID,
			ResourceID: &changelogID,
		})
		if err != nil {
			return nil, err
		}
		if changelog == nil {
			return nil, errors.Errorf("changelog %q not found", changelogID)
		}

		// Use SyncHistory to get historical metadata
		if changelog.SyncHistory != nil {
			syncHistory, err := s.store.GetSyncHistory(ctx, *changelog.SyncHistory)
			if err != nil {
				return nil, err
			}
			if syncHistory == nil {
				return nil, errors.Errorf("sync history %s not found", *changelog.SyncHistory)
			}

			// Get instance to determine engine and case sensitivity
			instance, err := s.store.GetInstance(ctx, &store.FindInstanceMessage{
				Workspace:  common.GetWorkspaceIDFromContext(ctx),
				ResourceID: &instanceID,
			})
			if err != nil {
				return nil, err
			}
			if instance == nil {
				return nil, errors.Errorf("instance %s not found", instanceID)
			}

			return model.NewDatabaseMetadata(
				syncHistory.Metadata,
				[]byte(syncHistory.Schema),
				&storepb.DatabaseConfig{},
				instance.Metadata.GetEngine(),
				store.IsObjectCaseSensitive(instance),
			), nil
		}

		// Fallback to current database schema if no sync history
		dbMetadata, err := s.store.GetDBSchema(ctx, &store.FindDBSchemaMessage{
			Workspace:    common.GetWorkspaceIDFromContext(ctx),
			InstanceID:   instanceID,
			DatabaseName: databaseName,
		})