1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
//go:build linux && cgo && !agent
package cluster
import (
"context"
"database/sql"
"fmt"
)
// Code generation directives.
//
//generate-database:mapper target instance_profiles.mapper.go
//generate-database:mapper reset -i -b "//go:build linux && cgo && !agent"
//
//generate-database:mapper stmt -e instance_profile objects
//generate-database:mapper stmt -e instance_profile objects-by-ProfileID
//generate-database:mapper stmt -e instance_profile objects-by-InstanceID
//generate-database:mapper stmt -e instance_profile create
//generate-database:mapper stmt -e instance_profile delete-by-InstanceID
//
//generate-database:mapper method -i -e instance_profile GetMany struct=Profile
//generate-database:mapper method -i -e instance_profile GetMany struct=Instance
//generate-database:mapper method -i -e instance_profile Create struct=Instance
//generate-database:mapper method -i -e instance_profile DeleteMany struct=Instance
// InstanceProfile is an association table struct that associates Instances
// to Profiles.
type InstanceProfile struct {
InstanceID int `db:"primary=yes&order=yes"`
ProfileID int
ApplyOrder int `db:"order=yes"`
}
// InstanceProfileFilter specifies potential query parameter fields.
type InstanceProfileFilter struct {
InstanceID *int
ProfileID *int
}
// UpdateInstanceProfiles updates the profiles of an instance in the order they are given.
func UpdateInstanceProfiles(ctx context.Context, tx *sql.Tx, instanceID int, projectName string, profiles []string) error {
err := DeleteInstanceProfiles(ctx, tx, instanceID)
if err != nil {
return err
}
project := projectName
enabled, err := ProjectHasProfiles(ctx, tx, project)
if err != nil {
return fmt.Errorf("Check if project has profiles: %w", err)
}
if !enabled {
project = "default"
}
applyOrder := 1
stmt, err := Stmt(tx, instanceProfileCreate)
if err != nil {
return fmt.Errorf("Failed to get \"instanceProfileCreate\" prepared statement: %w", err)
}
for _, name := range profiles {
profileID, err := GetProfileID(ctx, tx, project, name)
if err != nil {
return err
}
_, err = stmt.Exec(instanceID, profileID, applyOrder)
if err != nil {
return err
}
applyOrder = applyOrder + 1
}
return nil
}
|
