(s scalar.Scalar)
| 565 | } |
| 566 | |
| 567 | func scalarToIFace(s scalar.Scalar) (interface{}, error) { |
| 568 | if !s.IsValid() { |
| 569 | return nil, nil |
| 570 | } |
| 571 | |
| 572 | switch val := s.(type) { |
| 573 | case *scalar.Int8: |
| 574 | return val.Value, nil |
| 575 | case *scalar.Uint8: |
| 576 | return val.Value, nil |
| 577 | case *scalar.Int32: |
| 578 | return val.Value, nil |
| 579 | case *scalar.Int64: |
| 580 | return val.Value, nil |
| 581 | case *scalar.Float32: |
| 582 | return val.Value, nil |
| 583 | case *scalar.Float64: |
| 584 | return val.Value, nil |
| 585 | case *scalar.String: |
| 586 | return string(val.Value.Bytes()), nil |
| 587 | case *scalar.Binary: |
| 588 | return val.Value.Bytes(), nil |
| 589 | case scalar.DateScalar: |
| 590 | return val.ToTime(), nil |
| 591 | case scalar.TimeScalar: |
| 592 | return val.ToTime(), nil |
| 593 | case *scalar.DenseUnion: |
| 594 | return scalarToIFace(val.Value) |
| 595 | default: |
| 596 | return nil, fmt.Errorf("unsupported type: %s", val) |
| 597 | } |
| 598 | } |
| 599 | |
| 600 | func getParamsForStatement(rdr flight.MessageReader) (params [][]interface{}, err error) { |
| 601 | params = make([][]interface{}, 0) |
no outgoing calls
no test coverage detected