(raw *frame.RawFrame, msg *codecs.PartialExecute, body *frame.Body)
| 691 | } |
| 692 | |
| 693 | func (c *client) handleExecute(raw *frame.RawFrame, msg *codecs.PartialExecute, body *frame.Body) { |
| 694 | id := preparedIdKey(msg.QueryId) |
| 695 | if stmt, ok := c.preparedSystemQuery[id]; ok { |
| 696 | c.interceptSystemQuery(raw.Header, stmt) |
| 697 | } else { |
| 698 | isSelect := c.proxy.isSelect(id) |
| 699 | c.execute(raw, c.getDefaultIdempotency(body.CustomPayload), isSelect, "", body) |
| 700 | } |
| 701 | } |
| 702 | |
| 703 | func (c *client) handleQuery(raw *frame.RawFrame, msg *codecs.PartialQuery, body *frame.Body) { |
| 704 | handled, stmt, err := parser.IsQueryHandled(parser.IdentifierFromString(c.keyspace), msg.Query) |
no test coverage detected