scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-06 19:07:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add table conversion to duration timing

Browse source
This commit is contained in:
Cody Soyland 2020-12-04 11:48:04 -06:00
parent c33eafc27e
commit fc3b64e500
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
server/grpc.go
View file

@ -165,20 +165,22 @@ func (h *GRPCHandler) QuerySQL(req *pb.QuerySQLRequest, stream pb.Pilosa_QuerySQ
func (h *GRPCHandler) QuerySQLUnary(ctx context.Context, req *pb.QuerySQLRequest) (*pb.TableResponse, error) {
start := time.Now()
results, err := h.execSQL(ctx, req.Sql)
duration := int64(time.Since(start))
if err != nil {
return nil, err
}
var table *pb.TableResponse
if results, ok := results.(pb.ToTabler); ok {
switch results := results.(type) {
case pb.ToTabler:
table, err = results.ToTable()
table.Duration = duration
return table, err
default:
table, err = pb.RowsToTable(results, 0)
}
table, err = pb.RowsToTable(results, 0)
table.Duration = duration
return table, err
if err != nil {
return nil, err
}
table.Duration = int64(time.Since(start))
return table, nil
}
// QueryPQL handles the PQL request and sends RowResponses to the stream.