why ExceptionWhileProcessing didn't return err

[btyABC]

Company or project name

No response

Question

i am using go client "github.com/ClickHouse/clickhouse-go/v2",

this is the go code:

	deadlineCtx, cancel := context.WithDeadline(context.Background(), time.Now().Add(queryTimeout))
	defer cancel()
	rows, err := ch.Query(deadlineCtx, sql)
	if err != nil {
		return 0, err
	}
	defer rows.Close()

ch.Query didn't return err, but there are 0 rows in return.
I am sure query result of sql is not null.

this is the records in system.query_log

query_id	initial_query_id	event_time	type	query_duration_ms	read_rows	result_rows	exception	exception_code
298875b2-2a44-4425-b55d-a962168b5845	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:49+08:00	ExceptionWhileProcessing	177267	9173345491	0	Code: 210. DB::NetException: Connection reset by peer, while writing to socket (10.25.20.240:13289). (NETWORK_ERROR) (version 22.8.5.29 (official build))	210
861c532c-08f7-4bce-a100-4b4cf3ee5bb0	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:49+08:00	ExceptionWhileProcessing	177177	9061079725	0	Code: 210. DB::NetException: Connection reset by peer, while writing to socket (10.25.20.240:52361). (NETWORK_ERROR) (version 22.8.5.29 (official build))	210
8deca7f4-21f9-4d08-9b95-eb351f21ab0e	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:49+08:00	QueryFinish	177362	8087920455	0		0
8deca7f4-21f9-4d08-9b95-eb351f21ab0e	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:49+08:00	ExceptionWhileProcessing	177426	8087920455	0	Code: 210. DB::NetException: I/O error: Broken pipe, while writing to socket (10.25.20.240:24120). (NETWORK_ERROR) (version 22.8.5.29 (official build))	210
331421bc-de76-4fd4-bab5-ffaa2045333f	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:49+08:00	QueryFinish	177272	9734829182	0		0
331421bc-de76-4fd4-bab5-ffaa2045333f	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:49+08:00	ExceptionWhileProcessing	177286	9734829182	0	Code: 210. DB::NetException: I/O error: Broken pipe, while writing to socket (10.25.20.240:3304). (NETWORK_ERROR) (version 22.8.5.29 (official build))	210
5a3a40b7-a91b-4b2d-9039-fb4c38a8ea09	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:48+08:00	QueryFinish	176926	9066719102	0		0
1d8f7afa-aaa6-4adf-934c-3185fb0e8026	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:48:48+08:00	ExceptionWhileProcessing	177129	31762417821	0	Code: 210. DB::NetException: Connection reset by peer, while writing to socket (10.201.6.105:48232). (NETWORK_ERROR) (version 22.8.5.29 (official build))	210
298875b2-2a44-4425-b55d-a962168b5845	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:45:51+08:00	QueryStart	0	0	0		0
861c532c-08f7-4bce-a100-4b4cf3ee5bb0	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:45:51+08:00	QueryStart	0	0	0		0
8deca7f4-21f9-4d08-9b95-eb351f21ab0e	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:45:51+08:00	QueryStart	0	0	0		0
331421bc-de76-4fd4-bab5-ffaa2045333f	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:45:51+08:00	QueryStart	0	0	0		0
5a3a40b7-a91b-4b2d-9039-fb4c38a8ea09	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:45:51+08:00	QueryStart	0	0	0		0
1d8f7afa-aaa6-4adf-934c-3185fb0e8026	1d8f7afa-aaa6-4adf-934c-3185fb0e8026	2025-01-09T16:45:51+08:00	QueryStart	0	0	0		0

[mshustov]

@btyABC what interface do you use: HTTP or TCP? Could you provide a snippet with the client initialisation?

[btyABC]

I‘m using TCP interface

import  "github.com/ClickHouse/clickhouse-go/v2"
// init client
connect, err := clickhouse.Open(&clickhouse.Options{
		Addr: []string{fmt.Sprintf("%s:%d", conf.Host, conf.Port)},
		Auth: clickhouse.Auth{
			Database: conf.Database,
			Username: conf.User,
			Password: conf.Password,
		},
		Debug:        false,
		DialTimeout:  5 * time.Second,
		MaxOpenConns: connNum,
		MaxIdleConns: connNum,
		ReadTimeout:  5 * time.Second,
	})


// query
ctx := context.WithDeadLine(context.Background(),time.Now().Add(timeout))
connect.Query(ctx, query, args)

[Roma12344321]

We also have a problem with http interface, there is no db exception handling.
For example:
200 OK and ignoring db exception in response body on clickhouse server

func (h *httpConnect) executeRequest(req *http.Request) (*http.Response, error) {
	if h.client == nil {
		return nil, driver.ErrBadConn
	}
	resp, err := h.client.Do(req)
	if err != nil {
		return nil, err
	}
        // here is no resp body checking
	if resp.StatusCode != http.StatusOK {
		defer resp.Body.Close()
		msg, err := h.readRawResponse(resp)
		if err != nil {
			return nil, fmt.Errorf("clickhouse [execute]:: %d code: failed to read the response: %w", resp.StatusCode, err)
		}
		return nil, fmt.Errorf("clickhouse [execute]:: %d code: %s", resp.StatusCode, string(msg))
	}
	return resp, nil
}

[SpencerTorres]

There are some issues with error detection from the server, see this issue: ClickHouse/ClickHouse#75175

[Roma12344321]

Thank you!