Method runExtendedQueryMessage

server/conn_extended_query.go:910–919

runExtendedQueryMessage dispatches an extended-query protocol message (Parse/Bind/Describe/Execute/Close), implementing the protocol's error recovery rule: after an error while processing any extended-query message the server must discard subsequent extended-protocol messages until Sync arrives. Wit

(handler func([]byte), body []byte)

			if err != nil {
				result, err, _ = recoverAbortedTransaction(
					err,
					c.txStatus == txStatusIdle,
					func() error {
						_, rollbackErr := c.executor.ExecContext(context.Background(), "ROLLBACK")
						return rollbackErr
					},
					runExec,
				)
			}
			if err != nil {
				queryFinalErr = err
				errCode := classifyErrorCode(err)
				errMsg := err.Error()