SendQueryStatement is the pipeline version of *PgConn.ExecStatement.
(statementDescription *StatementDescription, paramValues [][]byte, paramFormats, resultFormats []int16)
| 2507 | |
| 2508 | // SendQueryStatement is the pipeline version of *PgConn.ExecStatement. |
| 2509 | func (p *Pipeline) SendQueryStatement(statementDescription *StatementDescription, paramValues [][]byte, paramFormats, resultFormats []int16) { |
| 2510 | if p.closed { |
| 2511 | return |
| 2512 | } |
| 2513 | |
| 2514 | p.conn.frontend.SendBind(&pgproto3.Bind{PreparedStatement: statementDescription.Name, ParameterFormatCodes: paramFormats, Parameters: paramValues, ResultFormatCodes: resultFormats}) |
| 2515 | p.conn.frontend.SendExecute(&pgproto3.Execute{}) |
| 2516 | p.state.PushBackRequestType(pipelineQueryStatement) |
| 2517 | p.state.PushBackStatementData(statementDescription, resultFormats) |
| 2518 | } |
| 2519 | |
| 2520 | // SendFlushRequest sends a request for the server to flush its output buffer. |
| 2521 | // |