Method execute

proxy/proxy.go:620–639

(raw *frame.RawFrame, state idempotentState, isSelect bool, keyspace string, body *frame.Body)

}

func (c *client) execute(raw *frame.RawFrame, state idempotentState, isSelect bool, keyspace string, body *frame.Body) {
	if sess, err := c.proxy.findSession(raw.Header.Version, c.keyspace, c.compression); err == nil {
		req := &request{
			client:   c,
			session:  sess,
			state:    state,
			msg:      body.Message,
			keyspace: keyspace,
			done:     false,
			stream:   raw.Header.StreamId,
			version:  raw.Header.Version,
			qp:       c.proxy.newQueryPlan(),
			frm:      c.maybeOverrideUnsupportedWriteConsistency(isSelect, raw, body),
			isSelect: isSelect,
		}
		req.Execute(true)
	} else {
		c.send(raw.Header, &message.ServerError{ErrorMessage: "Attempted to use invalid keyspace"})
	}
}

func (c *client) handlePrepare(raw *frame.RawFrame, msg *message.Prepare, body *frame.Body) {
	c.proxy.logger.Debug("handling prepare", zap.String("query", msg.Query), zap.Int16("stream", raw.Header.StreamId))