materialize-databricks: rebase on main, pull in gazette/core#352

estuary · Nov 14, 2023 · 76c7f5d · 76c7f5d
1 parent dffd8ca
commit 76c7f5d
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 6 deletions.
diff --git a/go.mod b/go.mod
@@ -54,7 +54,7 @@ require (
 	github.com/tidwall/gjson v1.16.0
 	github.com/xitongsys/parquet-go v1.6.2
 	github.com/xitongsys/parquet-go-source v0.0.0-20220527110425-ba4adb87a31b
-	go.gazette.dev/core v0.89.1-0.20231012132739-dfed675b7fd1
+	go.gazette.dev/core v0.89.1-0.20231026212052-d34c1d3ba509
 	go.mongodb.org/mongo-driver v1.12.1
 	golang.org/x/crypto v0.14.0
 	golang.org/x/oauth2 v0.13.0

diff --git a/go.sum b/go.sum
@@ -937,8 +937,8 @@ go.etcd.io/etcd/client/pkg/v3 v3.5.7 h1:y3kf5Gbp4e4q7egZdn5T7W9TSHUvkClN6u+Rq9mE
 go.etcd.io/etcd/client/pkg/v3 v3.5.7/go.mod h1:o0Abi1MK86iad3YrWhgUsbGx1pmTS+hrORWc2CamuhY=
 go.etcd.io/etcd/client/v3 v3.5.4 h1:p83BUL3tAYS0OT/r0qglgc3M1JjhM0diV8DSWAhVXv4=
 go.etcd.io/etcd/client/v3 v3.5.4/go.mod h1:ZaRkVgBZC+L+dLCjTcF1hRXpgZXQPOvnA/Ak/gq3kiY=
-go.gazette.dev/core v0.89.1-0.20231012132739-dfed675b7fd1 h1:oRtrsDKboiCGeG0B6kJvaJ9KVAn7U797oGMGTqdHnwo=
-go.gazette.dev/core v0.89.1-0.20231012132739-dfed675b7fd1/go.mod h1:/fdxqReMWKS26yROKEKDY8JlXjwz8TqeEZggpNwb5I0=
+go.gazette.dev/core v0.89.1-0.20231026212052-d34c1d3ba509 h1:5XDQdsqVe03xY7B2JXx02RzLy+xE8VB8UDFNiYy1gDw=
+go.gazette.dev/core v0.89.1-0.20231026212052-d34c1d3ba509/go.mod h1:pdChQZd77Kv4hkkZzB7nRUrTCJuug2GXv+ngfXjPK1k=
 go.mongodb.org/mongo-driver v1.12.1 h1:nLkghSU8fQNaK7oUmDhQFsnrtcoNy7Z6LVFKsEecqgE=
 go.mongodb.org/mongo-driver v1.12.1/go.mod h1:/rGBTebI3XYboVmgz+Wv3Bcbl3aD0QF9zl6kDDw18rQ=
 go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=

diff --git a/materialize-databricks/sqlgen.go b/materialize-databricks/sqlgen.go
@@ -36,7 +36,7 @@ var databricksDialect = func() sql.Dialect {
 				},
 				"number": sql.PrimaryKeyMapper{
 					PrimaryKey: sql.NewStaticMapper("STRING"),
-					Delegate:   sql.NewStaticMapper("DOUBLE", sql.WithElementConverter(sql.StdStrToFloat())),
+					Delegate:   sql.NewStaticMapper("DOUBLE", sql.WithElementConverter(sql.StdStrToFloat("NaN", "Inf", "-Inf"))),
 				},
 				"date":      sql.NewStaticMapper("DATE"),
 				"date-time": sql.NewStaticMapper("TIMESTAMP"),

diff --git a/materialize-mysql/driver.go b/materialize-mysql/driver.go
@@ -544,7 +544,7 @@ type transactor struct {
 func prepareNewTransactor(
 	dialect sql.Dialect,
 	templates map[string]*template.Template,
-) func(context.Context, *sql.Endpoint, sql.Fence, []sql.Table) (pm.Transactor, error) {
+) func(context.Context, *sql.Endpoint, sql.Fence, []sql.Table, pm.Request_Open) (pm.Transactor, error) {
 	return func(
 		ctx context.Context,
 		ep *sql.Endpoint,

diff --git a/materialize-sqlserver/driver.go b/materialize-sqlserver/driver.go
@@ -348,7 +348,7 @@ type transactor struct {
 
 func prepareNewTransactor(
 	templates map[string]*template.Template,
-) func(context.Context, *sql.Endpoint, sql.Fence, []sql.Table) (pm.Transactor, error) {
+) func(context.Context, *sql.Endpoint, sql.Fence, []sql.Table, pm.Request_Open) (pm.Transactor, error) {
 	return func(
 		ctx context.Context,
 		ep *sql.Endpoint,