Method createBackupTableAndMigrate

internal/commands/migrate.go:349–403

createBackupTableAndMigrate performs migration using temporary table

()

// createBackupTableAndMigrate performs migration using temporary table
func (cmd *MigrateKeysCommand) createBackupTableAndMigrate() error {
	logrus.Info("Starting key migration using temporary table...")

	// 1. Create temporary table
	if err := cmd.createTempTable(); err != nil {
		return fmt.Errorf("failed to create temporary table: %w", err)
	}

	// 2. Create old and new encryption services
	oldService, newService, err := cmd.createMigrationServices()
	if err != nil {
		return err
	}

	// 3. Get total count to migrate
	var totalCount int64
	if err := cmd.db.Model(&models.APIKey{}).Count(&totalCount).Error; err != nil {
		return fmt.Errorf("failed to get key count: %w", err)
	}

	if totalCount == 0 {
		logrus.Info("No keys to migrate")
		return nil
	}

	logrus.Infof("Starting migration of %d keys...", totalCount)

	// 4. Process migration in batches
	processedCount := 0
	lastID := uint(0)

	for {
		var keys []models.APIKey
		// Use ID-based pagination for stable results
		if err := cmd.db.Where("id > ?", lastID).Order("id").Limit(migrationBatchSize).Find(&keys).Error; err != nil {
			return fmt.Errorf("failed to get key data: %w", err)
		}

		if len(keys) == 0 {
			break
		}

		// Process current batch to temp table
		if err := cmd.processBatchToTempTable(keys, oldService, newService); err != nil {
			return fmt.Errorf("failed to process batch data: %w", err)
		}

		processedCount += len(keys)
		lastID = keys[len(keys)-1].ID
		logrus.Infof("Processed %d/%d keys", processedCount, totalCount)
	}

	logrus.Info("Data migration to temporary table completed")
	return nil
}

// createTempTable creates a temporary table for migration
func (cmd *MigrateKeysCommand) createTempTable() error {