Method ComExecuteBound

pgserver/duck_handler.go:123–130

ComExecuteBound implements the Handler interface.

(ctx context.Context, conn *mysql.Conn, portal PortalData, callback func(*Result) error)

// ComExecuteBound implements the Handler interface.
func (h *DuckHandler) ComExecuteBound(ctx context.Context, conn *mysql.Conn, portal PortalData, callback func(*Result) error) error {
	if err := h.rejectReadOnly(portal.Statement); err != nil {
		return err
	}
	err := h.doQuery(ctx, conn, portal.Statement.String, portal.Statement.QueryForAudit(), portal.Statement.AST, portal.Stmt, portal.Vars, portal.ResultFormatCodes, ExtendedQueryMode, h.executeBoundPlan, callback)
	if err != nil {
		err = sql.CastSQLError(err)
	}

	return err
}