feat: add dialect for spanner using pg adapter

README.md

@@ -41,6 +41,7 @@ go build -tags='no_postgres no_mysql no_sqlite3 no_ydb' -o goose ./cmd/goose
 # Available build tags:
 #   no_clickhouse  no_libsql   no_mssql    no_mysql
 #   no_postgres    no_sqlite3  no_vertica  no_ydb
+#   no_spannerpg
 ```
 
 For macOS users `goose` is available as a [Homebrew
@@ -97,6 +98,7 @@ Examples:
     goose vertica "vertica://user:password@localhost:5433/dbname?connection_load_balance=1" status
     goose ydb "grpcs://localhost:2135/local?go_query_mode=scripting&go_fake_tx=scripting&go_query_bind=declare,numeric" status
     goose starrocks "user:password@/dbname?parseTime=true&interpolateParams=true" status
+    goose spannerpg "user=postgres dbname=postgres sslmode=disable" status
 
     GOOSE_DRIVER=sqlite3 GOOSE_DBSTRING=./foo.db goose status
     GOOSE_DRIVER=sqlite3 GOOSE_DBSTRING=./foo.db goose create init sql

cmd/goose/driver_spannerpg.go

@@ -0,0 +1,9 @@
+//go:build !no_spannerpg
+// +build !no_spannerpg
+
+package main
+
+//Spanner using PG (postgres) adapter. Using pgx as a driver.
+import (
+	_ "github.com/jackc/pgx/v5/stdlib"
+)

database/dialect.go

@@ -24,6 +24,7 @@ const (
 	DialectVertica    Dialect = "vertica"
 	DialectYdB        Dialect = "ydb"
 	DialectStarrocks  Dialect = "starrocks"
+	DialectSpannerPG  Dialect = "spannerpg"
 )
 
 // NewStore returns a new [Store] implementation for the given dialect.
@@ -46,6 +47,7 @@ func NewStore(dialect Dialect, tablename string) (Store, error) {
 		DialectYdB:        &dialectquery.Ydb{},
 		DialectTurso:      &dialectquery.Turso{},
 		DialectStarrocks:  &dialectquery.Starrocks{},
+		DialectSpannerPG:  &dialectquery.SpannerPG{},
 	}
 	querier, ok := lookup[dialect]
 	if !ok {

dialect.go

@@ -21,6 +21,7 @@ const (
 	DialectVertica    Dialect = database.DialectVertica
 	DialectYdB        Dialect = database.DialectYdB
 	DialectStarrocks  Dialect = database.DialectStarrocks
+	DialectSpannerPG  Dialect = database.DialectSpannerPG
 )
 
 func init() {
@@ -55,6 +56,8 @@ func SetDialect(s string) error {
 		d = dialect.Turso
 	case "starrocks":
 		d = dialect.Starrocks
+	case "spannerpg":
+		d = dialect.SpannerPG
 	default:
 		return fmt.Errorf("%q: unknown dialect", s)
 	}

internal/dialect/dialectquery/spannerpg.go

@@ -0,0 +1,44 @@
+package dialectquery
+
+import (
+	"fmt"
+)
+
+type SpannerPG struct{}
+
+var _ Querier = (*SpannerPG)(nil)
+
+func (p *SpannerPG) CreateTable(tableName string) string {
+	q := `CREATE TABLE %s (
+		id bigint PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY (BIT_REVERSED_POSITIVE),
+		version_id bigint NOT NULL,
+		is_applied boolean NOT NULL,
+		tstamp timestamptz NOT NULL DEFAULT now()
+	)`
+	return fmt.Sprintf(q, tableName)
+}
+
+func (p *SpannerPG) InsertVersion(tableName string) string {
+	q := `INSERT INTO %s (version_id, is_applied) VALUES ($1, $2)`
+	return fmt.Sprintf(q, tableName)
+}
+
+func (p *SpannerPG) DeleteVersion(tableName string) string {
+	q := `DELETE FROM %s WHERE version_id=$1`
+	return fmt.Sprintf(q, tableName)
+}
+
+func (p *SpannerPG) GetMigrationByVersion(tableName string) string {
+	q := `SELECT tstamp, is_applied FROM %s WHERE version_id=$1 ORDER BY tstamp DESC LIMIT 1`
+	return fmt.Sprintf(q, tableName)
+}
+
+func (p *SpannerPG) ListMigrations(tableName string) string {
+	q := `SELECT version_id, is_applied from %s ORDER BY id DESC`
+	return fmt.Sprintf(q, tableName)
+}
+
+func (p *SpannerPG) GetLatestVersion(tableName string) string {
+	q := `SELECT max(version_id) FROM %s`
+	return fmt.Sprintf(q, tableName)
+}

internal/dialect/dialects.go

@@ -15,4 +15,5 @@ const (
 	Ydb        Dialect = "ydb"
 	Turso      Dialect = "turso"
 	Starrocks  Dialect = "starrocks"
+	SpannerPG  Dialect = "spannerpg"
 )

internal/dialect/store.go

@@ -71,6 +71,8 @@ func NewStore(d Dialect) (Store, error) {
 		querier = &dialectquery.Turso{}
 	case Starrocks:
 		querier = &dialectquery.Starrocks{}
+	case SpannerPG:
+		querier = &dialectquery.SpannerPG{}
 	default:
 		return nil, fmt.Errorf("unknown querier dialect: %v", d)
 	}