(ctx context.Context, sql string, arguments []any)
| 578 | } |
| 579 | |
| 580 | func (c *Conn) execSimpleProtocol(ctx context.Context, sql string, arguments []any) (commandTag pgconn.CommandTag, err error) { |
| 581 | if len(arguments) > 0 { |
| 582 | sql, err = c.sanitizeForSimpleQuery(sql, arguments...) |
| 583 | if err != nil { |
| 584 | return pgconn.CommandTag{}, err |
| 585 | } |
| 586 | } |
| 587 | |
| 588 | mrr := c.pgConn.Exec(ctx, sql) |
| 589 | for mrr.NextResult() { |
| 590 | commandTag, _ = mrr.ResultReader().Close() |
| 591 | } |
| 592 | err = mrr.Close() |
| 593 | return commandTag, err |
| 594 | } |
| 595 | |
| 596 | func (c *Conn) execParams(ctx context.Context, sd *pgconn.StatementDescription, arguments []any) (pgconn.CommandTag, error) { |
| 597 | err := c.eqb.Build(c.typeMap, sd, arguments) |
no test coverage detected