Skip to content

Commit 05fdf9e

Browse files
committed
chore: add cockroachdb 26.1 to the matrix
1 parent ad1115b commit 05fdf9e

File tree

3 files changed

+9
-22
lines changed

3 files changed

+9
-22
lines changed

.github/workflows/build-test.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -262,7 +262,7 @@ jobs:
262262
fail-fast: false
263263
matrix:
264264
datastore: ["crdb"]
265-
crdbversion: ["25.2.0", "25.3.0"]
265+
crdbversion: ["25.3.0", "26.1.0"]
266266
steps:
267267
- uses: "actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8" # v4.2.2
268268
if: |
@@ -297,7 +297,7 @@ jobs:
297297
fail-fast: false
298298
matrix:
299299
datastore: ["crdb"]
300-
crdbversion: ["25.2.0", "25.3.0"]
300+
crdbversion: ["25.3.0", "26.1.0"]
301301
steps:
302302
- uses: "actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8" # v4.2.2
303303
if: |

internal/datastore/common/errors.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,6 +163,7 @@ func RedactAndLogSensitiveConnString(ctx context.Context, baseErr string, err er
163163
filtered = strings.ReplaceAll(filtered, pgURL, "(redacted)")
164164
filtered = portMatchRegex.ReplaceAllString(filtered, "(redacted)")
165165
filtered = parseMatchRegex.ReplaceAllString(filtered, "(redacted)")
166+
fmt.Println(baseErr + ": " + filtered)
166167
log.Ctx(ctx).Trace().Msg(baseErr + ": " + filtered)
167168
return fmt.Errorf("%s. To view details of this error (that may contain sensitive information), please run with --log-level=trace", baseErr)
168169
}

internal/datastore/crdb/version.go

Lines changed: 6 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -2,20 +2,17 @@ package crdb
22

33
import (
44
"context"
5-
"errors"
65
"fmt"
76
"regexp"
87
"strconv"
98

109
"github.com/jackc/pgx/v5"
11-
"github.com/jackc/pgx/v5/pgconn"
1210
"github.com/rs/zerolog"
1311

1412
pgxcommon "github.com/authzed/spicedb/internal/datastore/postgres/common"
1513
)
1614

1715
const (
18-
queryVersionJSON = "SELECT crdb_internal.active_version()::jsonb;"
1916
queryVersion = "SELECT version();"
2017

2118
errFunctionDoesNotExist = "42883"
@@ -24,26 +21,15 @@ const (
2421
var versionRegex = regexp.MustCompile(`v([0-9]+)\.([0-9]+)\.([0-9]+)(?:-([0-9A-Za-z-]+(?:\.[0-9A-Za-z-]+)*))?(?:\+[0-9A-Za-z-]+)?`)
2522

2623
func queryServerVersion(ctx context.Context, db pgxcommon.DBFuncQuerier, version *crdbVersion) error {
24+
// The crdb_internal.active_version() wasn't added until v22.1.X, try to parse the version
25+
var versionStr string
2726
if err := db.QueryRowFunc(ctx, func(ctx context.Context, row pgx.Row) error {
28-
return row.Scan(version)
29-
}, queryVersionJSON); err != nil {
30-
var pgerr *pgconn.PgError
31-
if !errors.As(err, &pgerr) || pgerr.Code != errFunctionDoesNotExist {
32-
return err
33-
}
34-
35-
// The crdb_internal.active_version() wasn't added until v22.1.X, try to parse the version
36-
var versionStr string
37-
if err := db.QueryRowFunc(ctx, func(ctx context.Context, row pgx.Row) error {
38-
return row.Scan(&versionStr)
39-
}, queryVersion); err != nil {
40-
return err
41-
}
42-
43-
return parseVersionStringInto(versionStr, version)
27+
return row.Scan(&versionStr)
28+
}, queryVersion); err != nil {
29+
return err
4430
}
4531

46-
return nil
32+
return parseVersionStringInto(versionStr, version)
4733
}
4834

4935
func parseVersionStringInto(versionStr string, version *crdbVersion) error {

0 commit comments

Comments
 (0)