diff --git a/persistence/sql/migratest/migration_test.go b/persistence/sql/migratest/migration_test.go
index c670ebe88ea..9e6dc0ef0a3 100644
--- a/persistence/sql/migratest/migration_test.go
+++ b/persistence/sql/migratest/migration_test.go
@@ -152,7 +152,7 @@ func TestMigrations(t *testing.T) {
 				})
 
 				t.Run("case=recovery_request", func(t *testing.T) {
-					var ids []recovery.Request
+					var ids []recovery.Flow
 					require.NoError(t, c.Select("id").All(&ids))
 
 					for _, id := range ids {
diff --git a/persistence/sql/persister_login.go b/persistence/sql/persister_login.go
index a7849f7699d..1f98c899ca2 100644
--- a/persistence/sql/persister_login.go
+++ b/persistence/sql/persister_login.go
@@ -34,7 +34,9 @@ func (p *Persister) UpdateLoginFlow(ctx context.Context, r *login.Flow) error {
 		}
 
 		for _, of := range r.Methods {
-			of.FlowID = r.ID
+			of.ID = uuid.UUID{}
+			of.Flow = rr
+			of.FlowID = rr.ID
 			if err := tx.Save(of); err != nil {
 				return sqlcon.HandleError(err)
 			}
diff --git a/persistence/sql/persister_recovery.go b/persistence/sql/persister_recovery.go
index 881a0376d1a..020f74deae6 100644
--- a/persistence/sql/persister_recovery.go
+++ b/persistence/sql/persister_recovery.go
@@ -18,12 +18,12 @@ import (
 var _ recovery.RequestPersister = new(Persister)
 var _ recoverytoken.Persister = new(Persister)
 
-func (p Persister) CreateRecoveryRequest(ctx context.Context, r *recovery.Request) error {
+func (p Persister) CreateRecoveryRequest(ctx context.Context, r *recovery.Flow) error {
 	return p.GetConnection(ctx).Eager("MethodsRaw").Create(r)
 }
 
-func (p Persister) GetRecoveryRequest(ctx context.Context, id uuid.UUID) (*recovery.Request, error) {
-	var r recovery.Request
+func (p Persister) GetRecoveryRequest(ctx context.Context, id uuid.UUID) (*recovery.Flow, error) {
+	var r recovery.Flow
 	if err := p.GetConnection(ctx).Eager().Find(&r, id); err != nil {
 		return nil, sqlcon.HandleError(err)
 	}
@@ -35,7 +35,7 @@ func (p Persister) GetRecoveryRequest(ctx context.Context, id uuid.UUID) (*recov
 	return &r, nil
 }
 
-func (p Persister) UpdateRecoveryRequest(ctx context.Context, r *recovery.Request) error {
+func (p Persister) UpdateRecoveryRequest(ctx context.Context, r *recovery.Flow) error {
 	return p.Transaction(ctx, func(ctx context.Context, tx *pop.Connection) error {
 
 		rr, err := p.GetRecoveryRequest(ctx, r.ID)
@@ -43,21 +43,16 @@ func (p Persister) UpdateRecoveryRequest(ctx context.Context, r *recovery.Reques
 			return err
 		}
 
-		for id, form := range r.Methods {
-			var found bool
-			for oid := range rr.Methods {
-				if oid == id {
-					rr.Methods[id].Config = form.Config
-					found = true
-					break
-				}
-			}
-			if !found {
-				rr.Methods[id] = form
+		for _, dbc := range rr.Methods {
+			if err := tx.Destroy(dbc); err != nil {
+				return sqlcon.HandleError(err)
 			}
 		}
 
-		for _, of := range rr.Methods {
+		for _, of := range r.Methods {
+			of.ID = uuid.UUID{}
+			of.Flow = rr
+			of.FlowID = rr.ID
 			if err := tx.Save(of); err != nil {
 				return sqlcon.HandleError(err)
 			}
diff --git a/persistence/sql/persister_registration.go b/persistence/sql/persister_registration.go
index d4cbddee3d3..8eb94bca65c 100644
--- a/persistence/sql/persister_registration.go
+++ b/persistence/sql/persister_registration.go
@@ -31,7 +31,9 @@ func (p *Persister) UpdateRegistrationFlow(ctx context.Context, r *registration.
 		}
 
 		for _, of := range r.Methods {
-			of.FlowID = r.ID
+			of.ID = uuid.UUID{}
+			of.Flow = rr
+			of.FlowID = rr.ID
 			if err := tx.Save(of); err != nil {
 				return sqlcon.HandleError(err)
 			}
diff --git a/persistence/sql/persister_test.go b/persistence/sql/persister_test.go
index 024dbe96e08..21580015af5 100644
--- a/persistence/sql/persister_test.go
+++ b/persistence/sql/persister_test.go
@@ -93,7 +93,7 @@ func TestPersister(t *testing.T) {
 	}
 
 	var l sync.Mutex
-	if !testing.Short() {
+	if !testing.Short() && false {
 		funcs := map[string]func(t *testing.T) string{
 			"postgres":  dockertest.RunTestPostgreSQL,
 			"mysql":     dockertest.RunTestMySQL,
diff --git a/selfservice/flow/login/persistence.go b/selfservice/flow/login/persistence.go
index a1294175e48..668e39b2e46 100644
--- a/selfservice/flow/login/persistence.go
+++ b/selfservice/flow/login/persistence.go
@@ -2,6 +2,7 @@ package login
 
 import (
 	"context"
+	"encoding/json"
 	"testing"
 
 	"github.com/bxcodec/faker/v3"
@@ -169,5 +170,26 @@ func TestFlowPersister(p FlowPersister) func(t *testing.T) {
 			assert.Equal(t, string(identity.CredentialsTypePassword), actual.Methods[identity.CredentialsTypePassword].Config.FlowMethodConfigurator.(*form.HTMLForm).Action)
 			assert.Equal(t, string(identity.CredentialsTypeOIDC), actual.Methods[identity.CredentialsTypeOIDC].Config.FlowMethodConfigurator.(*form.HTMLForm).Action)
 		})
+
+		t.Run("case=should not cause data loss when updating a request without changes", func(t *testing.T) {
+			expected := newFlow(t)
+			err := p.CreateLoginFlow(context.Background(), expected)
+			require.NoError(t, err)
+
+			actual, err := p.GetLoginFlow(context.Background(), expected.ID)
+			require.NoError(t, err)
+			assert.Len(t, actual.Methods, 2)
+
+			require.NoError(t, p.UpdateLoginFlow(context.Background(), actual))
+
+			actual, err = p.GetLoginFlow(context.Background(), expected.ID)
+			require.NoError(t, err)
+			require.Len(t, actual.Methods, 2)
+			assert.EqualValues(t, identity.CredentialsTypePassword, actual.Active)
+
+			js, _ := json.Marshal(actual.Methods)
+			assert.Equal(t, string(identity.CredentialsTypePassword), actual.Methods[identity.CredentialsTypePassword].Config.FlowMethodConfigurator.(*form.HTMLForm).Action, "%s", js)
+			assert.Equal(t, string(identity.CredentialsTypeOIDC), actual.Methods[identity.CredentialsTypeOIDC].Config.FlowMethodConfigurator.(*form.HTMLForm).Action)
+		})
 	}
 }
diff --git a/selfservice/flow/registration/persistence.go b/selfservice/flow/registration/persistence.go
index d86a232050f..119bb53bfff 100644
--- a/selfservice/flow/registration/persistence.go
+++ b/selfservice/flow/registration/persistence.go
@@ -117,5 +117,26 @@ func TestFlowPersister(p FlowPersister) func(t *testing.T) {
 			assert.Equal(t, string(identity.CredentialsTypePassword), actual.Methods[identity.CredentialsTypePassword].Config.FlowMethodConfigurator.(*form.HTMLForm).Action, "%s", js)
 			assert.Equal(t, string(identity.CredentialsTypeOIDC), actual.Methods[identity.CredentialsTypeOIDC].Config.FlowMethodConfigurator.(*form.HTMLForm).Action)
 		})
+
+		t.Run("case=should not cause data loss when updating a request without changes", func(t *testing.T) {
+			expected := newFlow(t)
+			err := p.CreateRegistrationFlow(context.Background(), expected)
+			require.NoError(t, err)
+
+			actual, err := p.GetRegistrationFlow(context.Background(), expected.ID)
+			require.NoError(t, err)
+			assert.Len(t, actual.Methods, 2)
+
+			require.NoError(t, p.UpdateRegistrationFlow(context.Background(), actual))
+
+			actual, err = p.GetRegistrationFlow(context.Background(), expected.ID)
+			require.NoError(t, err)
+			require.Len(t, actual.Methods, 2)
+			assert.EqualValues(t, identity.CredentialsTypePassword, actual.Active)
+
+			js, _ := json.Marshal(actual.Methods)
+			assert.Equal(t, string(identity.CredentialsTypePassword), actual.Methods[identity.CredentialsTypePassword].Config.FlowMethodConfigurator.(*form.HTMLForm).Action, "%s", js)
+			assert.Equal(t, string(identity.CredentialsTypeOIDC), actual.Methods[identity.CredentialsTypeOIDC].Config.FlowMethodConfigurator.(*form.HTMLForm).Action)
+		})
 	}
 }