MCPcopy Create free account
hub / github.com/datastax/cql-proxy / handleExecute

Method handleExecute

proxy/proxy.go:693–701  ·  view source on GitHub ↗
(raw *frame.RawFrame, msg *codecs.PartialExecute, body *frame.Body)

Source from the content-addressed store, hash-verified

691}
692
693func (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
703func (c *client) handleQuery(raw *frame.RawFrame, msg *codecs.PartialQuery, body *frame.Body) {
704 handled, stmt, err := parser.IsQueryHandled(parser.IdentifierFromString(c.keyspace), msg.Query)

Callers 1

ReceiveMethod · 0.95

Calls 5

interceptSystemQueryMethod · 0.95
executeMethod · 0.95
getDefaultIdempotencyMethod · 0.95
preparedIdKeyFunction · 0.85
isSelectMethod · 0.80

Tested by

no test coverage detected