summaryrefslogtreecommitdiff
path: root/pkg/database/states.go
diff options
context:
space:
mode:
authorJulien Dessaux2024-10-16 00:17:12 +0200
committerJulien Dessaux2024-10-16 00:17:12 +0200
commit0e58781daa70300e22ea4abdc0c36be7fba08d7c (patch)
tree4f7d5f3b8bf225067b332b12149164298e883b64 /pkg/database/states.go
parentchore(tfstated): simplify some code (diff)
downloadtfstated-main.tar.gz
tfstated-main.tar.bz2
tfstated-main.zip
feat(tfstated): preserve lock information in states versionsHEADmain
Diffstat (limited to '')
-rw-r--r--pkg/database/states.go8
1 files changed, 7 insertions, 1 deletions
diff --git a/pkg/database/states.go b/pkg/database/states.go
index 9c35212..36011ab 100644
--- a/pkg/database/states.go
+++ b/pkg/database/states.go
@@ -74,7 +74,13 @@ func (db *DB) SetState(name string, data []byte, lockID string) (bool, error) {
err = fmt.Errorf("failed to update state, lock ID does not match")
return true, err
}
- _, err = tx.ExecContext(db.ctx, `INSERT INTO versions(state_id, data) VALUES (?, ?);`, stateID, encryptedData)
+ _, err = tx.ExecContext(db.ctx,
+ `INSERT INTO versions(state_id, data, lock)
+ SELECT :stateID, :data, lock
+ FROM states
+ WHERE states.id = :stateID;`,
+ sql.Named("stateID", stateID),
+ sql.Named("data", encryptedData))
if err != nil {
return false, err
}