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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package query
import (
"context"
"database/sql"
"fmt"
"strings"
)
// SelectConfig executes a query statement against a "config" table, which must
// have 'key' and 'value' columns. By default this query returns all keys, but
// additional WHERE filters can be specified.
//
// Returns a map of key names to their associated values.
func SelectConfig(ctx context.Context, tx *sql.Tx, table string, where string, args ...any) (map[string]string, error) {
query := fmt.Sprintf("SELECT key, value FROM %s", table)
if where != "" {
query += fmt.Sprintf(" WHERE %s", where)
}
rows, err := tx.QueryContext(ctx, query, args...)
if err != nil {
return nil, err
}
defer func() { _ = rows.Close() }()
values := map[string]string{}
for rows.Next() {
var key string
var value string
err := rows.Scan(&key, &value)
if err != nil {
return nil, err
}
values[key] = value
}
err = rows.Err()
if err != nil {
return nil, err
}
return values, nil
}
// UpdateConfig updates the given keys in the given table. Config keys set to
// empty values will be deleted.
func UpdateConfig(tx *sql.Tx, table string, values map[string]string) error {
changes := map[string]string{}
deletes := []string{}
for key, value := range values {
if value == "" {
deletes = append(deletes, key)
continue
}
changes[key] = value
}
err := upsertConfig(tx, table, changes)
if err != nil {
return fmt.Errorf("updating values failed: %w", err)
}
err = deleteConfig(tx, table, deletes)
if err != nil {
return fmt.Errorf("deleting values failed: %w", err)
}
return nil
}
// Insert or updates the key/value rows of the given config table.
func upsertConfig(tx *sql.Tx, table string, values map[string]string) error {
if len(values) == 0 {
return nil // Nothing to update
}
query := fmt.Sprintf("INSERT OR REPLACE INTO %s (key, value) VALUES", table)
exprs := []string{}
params := []any{}
for key, value := range values {
exprs = append(exprs, "(?, ?)")
params = append(params, key)
params = append(params, value)
}
query += strings.Join(exprs, ",")
_, err := tx.Exec(query, params...)
return err
}
// Delete the given key rows from the given config table.
func deleteConfig(tx *sql.Tx, table string, keys []string) error {
n := len(keys)
if n == 0 {
return nil // Nothing to delete.
}
query := fmt.Sprintf("DELETE FROM %s WHERE key IN %s", table, Params(n))
values := make([]any, n)
for i, key := range keys {
values[i] = key
}
_, err := tx.Exec(query, values...)
return err
}
|
