Method getResults

pgconn/pgconn.go:2597–2626

()

}

func (p *Pipeline) getResults() (results any, err error) {
	if !p.conn.resultReader.closed {
		_, err := p.conn.resultReader.Close()
		if err != nil {
			return nil, err
		}
	}

	currentRequestType := p.state.ExtractFrontRequestType()
	switch currentRequestType {
	case pipelineNil:
		return nil, nil
	case pipelinePrepare:
		return p.getResultsPrepare()
	case pipelineQueryParams:
		return p.getResultsQueryParams()
	case pipelineQueryPrepared:
		return p.getResultsQueryPrepared()
	case pipelineQueryStatement:
		return p.getResultsQueryStatement()
	case pipelineDeallocate:
		return p.getResultsDeallocate()
	case pipelineSyncRequest:
		return p.getResultsSync()
	case pipelineFlushRequest:
		return nil, errors.New("BUG: pipelineFlushRequest should not be in request queue")
	default:
		return nil, errors.New("BUG: unknown pipeline request type")
	}
}

func (p *Pipeline) getResultsPrepare() (*StatementDescription, error) {
	err := p.receiveParseComplete("Prepare")