From b1eefbde0b08397e6cd53b3dec4331c039229274 Mon Sep 17 00:00:00 2001 From: Yuki Ito Date: Tue, 28 May 2019 11:54:30 +0900 Subject: [PATCH] spanner: make PartitionedUpdate treat query parameters Fixes #1472 Change-Id: I609fdd0897c91e9a4e77a38251316113a1a9e3d3 Reviewed-on: https://code-review.googlesource.com/c/gocloud/+/41450 Reviewed-by: Jean de Klerk --- spanner/pdml.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/spanner/pdml.go b/spanner/pdml.go index 56445d8aa18c..168c46a9ff1e 100644 --- a/spanner/pdml.go +++ b/spanner/pdml.go @@ -69,12 +69,20 @@ func (c *Client) PartitionedUpdate(ctx context.Context, statement Statement) (co if err != nil { return 0, toSpannerError(err) } + + params, paramTypes, err := statement.convertParams() + if err != nil { + return 0, toSpannerError(err) + } + req := &sppb.ExecuteSqlRequest{ Session: sh.getID(), Transaction: &sppb.TransactionSelector{ Selector: &sppb.TransactionSelector_Id{Id: tx}, }, - Sql: statement.SQL, + Sql: statement.SQL, + Params: params, + ParamTypes: paramTypes, } rpc := func(ctx context.Context, resumeToken []byte) (streamingReceiver, error) { req.ResumeToken = resumeToken