aboutsummaryrefslogtreecommitdiffstats
path: root/vendor/cloud.google.com/go/spanner/statement.go
diff options
context:
space:
mode:
authorDmitry Vyukov <dvyukov@google.com>2017-06-13 19:31:19 +0200
committerGitHub <noreply@github.com>2017-06-13 19:31:19 +0200
commit5b060131006494cbc077f08b9b2fbf172f3eb239 (patch)
tree04f8586899db96f7fd8e7bc6a010fc10f1e2bb3b /vendor/cloud.google.com/go/spanner/statement.go
parentcd8e13f826ff24f5f8e0b8de1b9d3373aaf93d2f (diff)
parent612b82714b3e6660bf702f801ab96aacb3432e1f (diff)
Merge pull request #226 from google/dvyukov-vendor
vendor: vendor dependencies
Diffstat (limited to 'vendor/cloud.google.com/go/spanner/statement.go')
-rw-r--r--vendor/cloud.google.com/go/spanner/statement.go78
1 files changed, 78 insertions, 0 deletions
diff --git a/vendor/cloud.google.com/go/spanner/statement.go b/vendor/cloud.google.com/go/spanner/statement.go
new file mode 100644
index 000000000..8e422b09c
--- /dev/null
+++ b/vendor/cloud.google.com/go/spanner/statement.go
@@ -0,0 +1,78 @@
+/*
+Copyright 2017 Google Inc. All Rights Reserved.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package spanner
+
+import (
+ "fmt"
+
+ proto3 "github.com/golang/protobuf/ptypes/struct"
+
+ sppb "google.golang.org/genproto/googleapis/spanner/v1"
+ "google.golang.org/grpc/codes"
+)
+
+// A Statement is a SQL query with named parameters.
+//
+// A parameter placeholder consists of '@' followed by the parameter name.
+// Parameter names consist of any combination of letters, numbers, and
+// underscores. Names may be entirely numeric (e.g., "WHERE m.id = @5").
+// Parameters may appear anywhere that a literal value is expected. The same
+// parameter name may be used more than once. It is an error to execute a
+// statement with unbound parameters. On the other hand, it is allowable to
+// bind parameter names that are not used.
+//
+// See the documentation of the Row type for how Go types are mapped to Cloud
+// Spanner types.
+type Statement struct {
+ SQL string
+ Params map[string]interface{}
+}
+
+// NewStatement returns a Statement with the given SQL and an empty Params map.
+func NewStatement(sql string) Statement {
+ return Statement{SQL: sql, Params: map[string]interface{}{}}
+}
+
+// errBindParam returns error for not being able to bind parameter to query request.
+func errBindParam(k string, v interface{}, err error) error {
+ if err == nil {
+ return nil
+ }
+ se, ok := toSpannerError(err).(*Error)
+ if !ok {
+ return spannerErrorf(codes.InvalidArgument, "failed to bind query parameter(name: %q, value: %q), error = <%v>", k, v, err)
+ }
+ se.decorate(fmt.Sprintf("failed to bind query parameter(name: %q, value: %q)", k, v))
+ return se
+}
+
+// bindParams binds parameters in a Statement to a sppb.ExecuteSqlRequest.
+func (s *Statement) bindParams(r *sppb.ExecuteSqlRequest) error {
+ r.Params = &proto3.Struct{
+ Fields: map[string]*proto3.Value{},
+ }
+ r.ParamTypes = map[string]*sppb.Type{}
+ for k, v := range s.Params {
+ val, t, err := encodeValue(v)
+ if err != nil {
+ return errBindParam(k, v, err)
+ }
+ r.Params.Fields[k] = val
+ r.ParamTypes[k] = t
+ }
+ return nil
+}