Function TestExecuteSelectQueryReturnsErrorDetails

server/conn_test.go:1580–1611

(t *testing.T)

	}
}

func (e *abortedAlterViewRecoveryExecutor) ConnContext(context.Context) (RawConn, error) {
	return nil, errors.New("not implemented")
}

func (e *abortedAlterViewRecoveryExecutor) PingContext(context.Context) error {
	return errors.New("not implemented")
}

func (e *abortedAlterViewRecoveryExecutor) Close() error { return nil }

func TestExecuteSelectQueryReturnsErrorDetails(t *testing.T) {
	clientSide, serverSide := net.Pipe()
	defer func() { _ = clientSide.Close() }()
	defer func() { _ = serverSide.Close() }()

	var out bytes.Buffer
	c := &clientConn{
		server: &Server{activeQueries: make(map[BackendKey]context.CancelFunc)},
		conn:   clientSide,
		reader: bufio.NewReader(clientSide),
		writer: bufio.NewWriter(&out),
		ctx:    context.Background(),
		cancel: func() {},
		executor: &queryErrorExecutor{
			err: errors.New("Catalog Error: Table with name missing_table does not exist!"),
		},
	}

	rowCount, errCode, errMsg, err := c.executeSelectQuery("SELECT * FROM missing_table", "SELECT")
	if err != nil {
		t.Fatalf("expected nil connection error, got %v", err)
	}
	if rowCount != 0 {
		t.Fatalf("expected rowCount=0, got %d", rowCount)