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
|
package cluster
import (
"context"
"database/sql"
"fmt"
"github.com/lxc/incus/v6/internal/server/db/query"
)
// Update the schema and api_extensions columns of the row in the nodes table
// that matches the given id.
//
// If not such row is found, an error is returned.
func updateNodeVersion(tx *sql.Tx, address string, apiExtensions int) error {
stmt := "UPDATE nodes SET schema=?, api_extensions=? WHERE address=?"
result, err := tx.Exec(stmt, len(updates), apiExtensions, address)
if err != nil {
return err
}
n, err := result.RowsAffected()
if err != nil {
return err
}
if n != 1 {
return fmt.Errorf("updated %d rows instead of 1", n)
}
return nil
}
// Return the number of rows in the nodes table that have their address column
// set to '0.0.0.0'.
func selectUnclusteredNodesCount(ctx context.Context, tx *sql.Tx) (int, error) {
return query.Count(ctx, tx, "nodes", "address='0.0.0.0'")
}
// Return a slice of binary integer tuples. Each tuple contains the schema
// version and number of api extensions of a node in the cluster.
func selectNodesVersions(ctx context.Context, tx *sql.Tx) ([][2]int, error) {
versions := [][2]int{}
stmt, err := tx.Prepare("SELECT schema, api_extensions FROM nodes WHERE state=0")
if err != nil {
// In order to make cluster updates work, let's check for "pending" as well as that's the column's previous name.
stmt, err = tx.Prepare("SELECT schema, api_extensions FROM nodes WHERE pending=0")
if err != nil {
return nil, err
}
}
defer func() { _ = stmt.Close() }()
err = query.SelectObjects(ctx, stmt, func(scan func(dest ...any) error) error {
version := [2]int{}
err := scan(&version[0], &version[1])
if err != nil {
return err
}
versions = append(versions, version)
return nil
})
if err != nil {
return nil, err
}
return versions, nil
}
|
