Struct selectOneExecutor

server/query_source_test.go:101–104

selectOneExecutor answers any QueryContext with a single-row RowSet, so a SELECT in a batch alongside the query_source GUC actually executes.

// clientConn wrote to its buffer (type byte + 4-byte length incl. length).
func parseWireMsgs(t *testing.T, buf []byte) []wireMsg {
	t.Helper()
	var msgs []wireMsg
	for i := 0; i+5 <= len(buf); {
		typ := buf[i]
		length := int(buf[i+1])<<24 | int(buf[i+2])<<16 | int(buf[i+3])<<8 | int(buf[i+4])
		if length < 4 || i+1+length > len(buf) {
			t.Fatalf("malformed wire message at offset %d (length %d, remaining %d)", i, length, len(buf)-i)