1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
// Copyright 2019 Google LLC
//
// 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
//
// https://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 testutil
import (
"fmt"
"net"
"strconv"
"testing"
structpb "github.com/golang/protobuf/ptypes/struct"
"google.golang.org/api/option"
instancepb "google.golang.org/genproto/googleapis/spanner/admin/instance/v1"
spannerpb "google.golang.org/genproto/googleapis/spanner/v1"
"google.golang.org/grpc"
)
// SelectFooFromBar is a SELECT statement that is added to the mocked test
// server and will return a one-col-two-rows result set containing the INT64
// values 1 and 2.
const SelectFooFromBar = "SELECT FOO FROM BAR"
const selectFooFromBarRowCount int64 = 2
const selectFooFromBarColCount int = 1
var selectFooFromBarResults = [...]int64{1, 2}
// SelectSingerIDAlbumIDAlbumTitleFromAlbums i a SELECT statement that is added
// to the mocked test server and will return a 3-cols-3-rows result set.
const SelectSingerIDAlbumIDAlbumTitleFromAlbums = "SELECT SingerId, AlbumId, AlbumTitle FROM Albums"
// SelectSingerIDAlbumIDAlbumTitleFromAlbumsRowCount is the number of rows
// returned by the SelectSingerIDAlbumIDAlbumTitleFromAlbums statement.
const SelectSingerIDAlbumIDAlbumTitleFromAlbumsRowCount int64 = 3
// SelectSingerIDAlbumIDAlbumTitleFromAlbumsColCount is the number of cols
// returned by the SelectSingerIDAlbumIDAlbumTitleFromAlbums statement.
const SelectSingerIDAlbumIDAlbumTitleFromAlbumsColCount int = 3
// UpdateBarSetFoo is an UPDATE statement that is added to the mocked test
// server that will return an update count of 5.
const UpdateBarSetFoo = "UPDATE FOO SET BAR=1 WHERE BAZ=2"
// UpdateBarSetFooRowCount is the constant update count value returned by the
// statement defined in UpdateBarSetFoo.
const UpdateBarSetFooRowCount = 5
// MockedSpannerInMemTestServer is an InMemSpannerServer with results for a
// number of SQL statements readily mocked.
type MockedSpannerInMemTestServer struct {
TestSpanner InMemSpannerServer
TestInstanceAdmin InMemInstanceAdminServer
server *grpc.Server
}
// NewMockedSpannerInMemTestServer creates a MockedSpannerInMemTestServer at
// localhost with a random port and returns client options that can be used
// to connect to it.
func NewMockedSpannerInMemTestServer(t *testing.T) (mockedServer *MockedSpannerInMemTestServer, opts []option.ClientOption, teardown func()) {
return NewMockedSpannerInMemTestServerWithAddr(t, "localhost:0")
}
// NewMockedSpannerInMemTestServerWithAddr creates a MockedSpannerInMemTestServer
// at a given listening address and returns client options that can be used
// to connect to it.
func NewMockedSpannerInMemTestServerWithAddr(t *testing.T, addr string) (mockedServer *MockedSpannerInMemTestServer, opts []option.ClientOption, teardown func()) {
mockedServer = &MockedSpannerInMemTestServer{}
opts = mockedServer.setupMockedServerWithAddr(t, addr)
return mockedServer, opts, func() {
mockedServer.TestSpanner.Stop()
mockedServer.TestInstanceAdmin.Stop()
mockedServer.server.Stop()
}
}
func (s *MockedSpannerInMemTestServer) setupMockedServerWithAddr(t *testing.T, addr string) []option.ClientOption {
s.TestSpanner = NewInMemSpannerServer()
s.TestInstanceAdmin = NewInMemInstanceAdminServer()
s.setupFooResults()
s.setupSingersResults()
s.server = grpc.NewServer()
spannerpb.RegisterSpannerServer(s.server, s.TestSpanner)
instancepb.RegisterInstanceAdminServer(s.server, s.TestInstanceAdmin)
lis, err := net.Listen("tcp", addr)
if err != nil {
t.Fatal(err)
}
go s.server.Serve(lis)
serverAddress := lis.Addr().String()
opts := []option.ClientOption{
option.WithEndpoint(serverAddress),
option.WithGRPCDialOption(grpc.WithInsecure()),
option.WithoutAuthentication(),
}
return opts
}
func (s *MockedSpannerInMemTestServer) setupFooResults() {
fields := make([]*spannerpb.StructType_Field, selectFooFromBarColCount)
fields[0] = &spannerpb.StructType_Field{
Name: "FOO",
Type: &spannerpb.Type{Code: spannerpb.TypeCode_INT64},
}
rowType := &spannerpb.StructType{
Fields: fields,
}
metadata := &spannerpb.ResultSetMetadata{
RowType: rowType,
}
rows := make([]*structpb.ListValue, selectFooFromBarRowCount)
for idx, value := range selectFooFromBarResults {
rowValue := make([]*structpb.Value, selectFooFromBarColCount)
rowValue[0] = &structpb.Value{
Kind: &structpb.Value_StringValue{StringValue: strconv.FormatInt(value, 10)},
}
rows[idx] = &structpb.ListValue{
Values: rowValue,
}
}
resultSet := &spannerpb.ResultSet{
Metadata: metadata,
Rows: rows,
}
result := &StatementResult{Type: StatementResultResultSet, ResultSet: resultSet}
s.TestSpanner.PutStatementResult(SelectFooFromBar, result)
s.TestSpanner.PutStatementResult(UpdateBarSetFoo, &StatementResult{
Type: StatementResultUpdateCount,
UpdateCount: UpdateBarSetFooRowCount,
})
}
func (s *MockedSpannerInMemTestServer) setupSingersResults() {
fields := make([]*spannerpb.StructType_Field, SelectSingerIDAlbumIDAlbumTitleFromAlbumsColCount)
fields[0] = &spannerpb.StructType_Field{
Name: "SingerId",
Type: &spannerpb.Type{Code: spannerpb.TypeCode_INT64},
}
fields[1] = &spannerpb.StructType_Field{
Name: "AlbumId",
Type: &spannerpb.Type{Code: spannerpb.TypeCode_INT64},
}
fields[2] = &spannerpb.StructType_Field{
Name: "AlbumTitle",
Type: &spannerpb.Type{Code: spannerpb.TypeCode_STRING},
}
rowType := &spannerpb.StructType{
Fields: fields,
}
metadata := &spannerpb.ResultSetMetadata{
RowType: rowType,
}
rows := make([]*structpb.ListValue, SelectSingerIDAlbumIDAlbumTitleFromAlbumsRowCount)
var idx int64
for idx = 0; idx < SelectSingerIDAlbumIDAlbumTitleFromAlbumsRowCount; idx++ {
rowValue := make([]*structpb.Value, SelectSingerIDAlbumIDAlbumTitleFromAlbumsColCount)
rowValue[0] = &structpb.Value{
Kind: &structpb.Value_StringValue{StringValue: strconv.FormatInt(idx+1, 10)},
}
rowValue[1] = &structpb.Value{
Kind: &structpb.Value_StringValue{StringValue: strconv.FormatInt(idx*10+idx, 10)},
}
rowValue[2] = &structpb.Value{
Kind: &structpb.Value_StringValue{StringValue: fmt.Sprintf("Album title %d", idx)},
}
rows[idx] = &structpb.ListValue{
Values: rowValue,
}
}
resultSet := &spannerpb.ResultSet{
Metadata: metadata,
Rows: rows,
}
result := &StatementResult{Type: StatementResultResultSet, ResultSet: resultSet}
s.TestSpanner.PutStatementResult(SelectSingerIDAlbumIDAlbumTitleFromAlbums, result)
}
|
