(t *testing.T)
| 12 | ) |
| 13 | |
| 14 | func TestPartialQueryCodec_Decode(t *testing.T) { |
| 15 | localSerialConsistency := primitive.ConsistencyLevelLocalSerial |
| 16 | codec := &partialQueryCodec{} |
| 17 | |
| 18 | msg := &message.Query{ |
| 19 | Query: "SELECT * FROM table WHERE id = ?", |
| 20 | Options: &message.QueryOptions{ |
| 21 | Consistency: primitive.ConsistencyLevelOne, |
| 22 | SerialConsistency: &localSerialConsistency, |
| 23 | }, |
| 24 | } |
| 25 | |
| 26 | var buf bytes.Buffer |
| 27 | err := builtinQueryCodec.Encode(msg, &buf, primitive.ProtocolVersion4) |
| 28 | require.NoError(t, err) |
| 29 | |
| 30 | query, err := codec.Decode(NewFrameBodyReader(buf.Bytes()), primitive.ProtocolVersion4) |
| 31 | require.NoError(t, err) |
| 32 | |
| 33 | assert.False(t, query.IsResponse()) |
| 34 | assert.Equal(t, primitive.OpCodeQuery, query.GetOpCode()) |
| 35 | assert.Equal(t, fmt.Sprintf("QUERY \"%s\"", msg.Query), query.(*PartialQuery).String()) |
| 36 | |
| 37 | assert.Equal(t, msg.Query, query.(*PartialQuery).Query) |
| 38 | assert.Equal(t, primitive.ConsistencyLevelOne, query.(*PartialQuery).Consistency) |
| 39 | assert.Equal(t, []byte{0x10, 0x00, 0x9}, query.(*PartialQuery).Parameters) |
| 40 | } |
| 41 | |
| 42 | func TestPartialQueryCodec_Decode_Invalid(t *testing.T) { |
| 43 | tests := []struct { |
nothing calls this directly
no test coverage detected