type github.com/jackc/pgx/v5/pgconn.CommandTag
110 uses
github.com/jackc/pgx/v5/pgconn (current package)
pgconn.go#L801: type CommandTag struct {
pgconn.go#L806: func NewCommandTag(s string) CommandTag {
pgconn.go#L807: return CommandTag{s: s}
pgconn.go#L812: func (ct CommandTag) RowsAffected() int64 {
pgconn.go#L830: func (ct CommandTag) String() string {
pgconn.go#L835: func (ct CommandTag) Insert() bool {
pgconn.go#L840: func (ct CommandTag) Update() bool {
pgconn.go#L845: func (ct CommandTag) Delete() bool {
pgconn.go#L850: func (ct CommandTag) Select() bool {
pgconn.go#L1263: result.concludeCommand(CommandTag{}, err)
pgconn.go#L1269: result.concludeCommand(CommandTag{}, fmt.Errorf("extended protocol limited to %v parameters", math.MaxUint16))
pgconn.go#L1278: result.concludeCommand(CommandTag{}, newContextAlreadyDoneError(ctx))
pgconn.go#L1300: result.concludeCommand(CommandTag{}, err)
pgconn.go#L1311: func (pgConn *PgConn) CopyTo(ctx context.Context, w io.Writer, sql string) (CommandTag, error) {
pgconn.go#L1313: return CommandTag{}, err
pgconn.go#L1320: return CommandTag{}, newContextAlreadyDoneError(ctx)
pgconn.go#L1334: return CommandTag{}, err
pgconn.go#L1338: var commandTag CommandTag
pgconn.go#L1344: return CommandTag{}, normalizeTimeoutError(ctx, err)
pgconn.go#L1353: return CommandTag{}, err
pgconn.go#L1370: func (pgConn *PgConn) CopyFrom(ctx context.Context, r io.Reader, sql string) (CommandTag, error) {
pgconn.go#L1372: return CommandTag{}, err
pgconn.go#L1379: return CommandTag{}, newContextAlreadyDoneError(ctx)
pgconn.go#L1391: return CommandTag{}, err
pgconn.go#L1446: return CommandTag{}, normalizeTimeoutError(ctx, err)
pgconn.go#L1454: return CommandTag{}, serverError
pgconn.go#L1477: return CommandTag{}, err
pgconn.go#L1481: var commandTag CommandTag
pgconn.go#L1486: return CommandTag{}, normalizeTimeoutError(ctx, err)
pgconn.go#L1573: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1649: commandTag CommandTag
pgconn.go#L1660: CommandTag CommandTag
pgconn.go#L1733: func (rr *ResultReader) Close() (CommandTag, error) {
pgconn.go#L1742: return CommandTag{}, rr.err
pgconn.go#L1750: return CommandTag{}, rr.err
pgconn.go#L1784: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1795: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1812: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1829: rr.concludeCommand(CommandTag{}, nil)
pgconn.go#L1835: rr.concludeCommand(CommandTag{}, pgErr)
pgconn.go#L1841: func (rr *ResultReader) concludeCommand(commandTag CommandTag, err error) {
pgconn.go#L2034: func (pgConn *PgConn) makeCommandTag(buf []byte) CommandTag {
pgconn.go#L2035: return CommandTag{s: string(buf)}
github.com/jackc/pgx/v5
batch.go#L50: func (qq *QueuedQuery) Exec(fn func(ct pgconn.CommandTag) error) {
batch.go#L91: Exec() (pgconn.CommandTag, error)
batch.go#L129: func (br *batchResults) Exec() (pgconn.CommandTag, error) {
batch.go#L131: return pgconn.CommandTag{}, br.err
batch.go#L134: return pgconn.CommandTag{}, fmt.Errorf("batch already closed")
batch.go#L151: return pgconn.CommandTag{}, err
batch.go#L291: func (br *pipelineBatchResults) Exec() (pgconn.CommandTag, error) {
batch.go#L293: return pgconn.CommandTag{}, br.err
batch.go#L296: return pgconn.CommandTag{}, fmt.Errorf("batch already closed")
batch.go#L300: return pgconn.CommandTag{}, br.err
batch.go#L305: return pgconn.CommandTag{}, err
batch.go#L311: return pgconn.CommandTag{}, br.err
batch.go#L313: var commandTag pgconn.CommandTag
batch.go#L318: return pgconn.CommandTag{}, fmt.Errorf("unexpected pipeline result: %T", results)
batch.go#L460: func (br *emptyBatchResults) Exec() (pgconn.CommandTag, error) {
batch.go#L462: return pgconn.CommandTag{}, fmt.Errorf("batch already closed")
batch.go#L464: return pgconn.CommandTag{}, errors.New("no more results in batch")
conn.go#L472: func (c *Conn) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
conn.go#L478: return pgconn.CommandTag{}, err
conn.go#L490: func (c *Conn) exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error) {
conn.go#L511: return pgconn.CommandTag{}, fmt.Errorf("rewrite query failed: %w", err)
conn.go#L539: return pgconn.CommandTag{}, errDisabledStatementCache
conn.go#L545: return pgconn.CommandTag{}, err
conn.go#L553: return pgconn.CommandTag{}, errDisabledDescriptionCache
conn.go#L559: return pgconn.CommandTag{}, err
conn.go#L568: return pgconn.CommandTag{}, err
conn.go#L576: return pgconn.CommandTag{}, fmt.Errorf("unknown QueryExecMode: %v", mode)
conn.go#L580: func (c *Conn) execSimpleProtocol(ctx context.Context, sql string, arguments []any) (commandTag pgconn.CommandTag, err error) {
conn.go#L584: return pgconn.CommandTag{}, err
conn.go#L596: func (c *Conn) execParams(ctx context.Context, sd *pgconn.StatementDescription, arguments []any) (pgconn.CommandTag, error) {
conn.go#L599: return pgconn.CommandTag{}, err
conn.go#L607: func (c *Conn) execPrepared(ctx context.Context, sd *pgconn.StatementDescription, arguments []any) (pgconn.CommandTag, error) {
conn.go#L610: return pgconn.CommandTag{}, err
conn.go#L618: func (c *Conn) execSQLParams(ctx context.Context, sql string, args []any) (pgconn.CommandTag, error) {
conn.go#L621: return pgconn.CommandTag{}, err
rows.go#L38: CommandTag() pgconn.CommandTag
rows.go#L128: commandTag pgconn.CommandTag
rows.go#L201: func (rows *baseRows) CommandTag() pgconn.CommandTag {
rows.go#L401: func ForEachRow(rows Rows, scans []any, fn func() error) (pgconn.CommandTag, error) {
rows.go#L407: return pgconn.CommandTag{}, err
rows.go#L412: return pgconn.CommandTag{}, err
rows.go#L417: return pgconn.CommandTag{}, err
tracer.go#L24: CommandTag pgconn.CommandTag
tracer.go#L45: CommandTag pgconn.CommandTag
tracer.go#L68: CommandTag pgconn.CommandTag
tx.go#L145: Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error)
tx.go#L226: func (tx *dbTx) Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error) {
tx.go#L228: return pgconn.CommandTag{}, ErrTxClosed
tx.go#L328: func (sp *dbSimulatedNestedTx) Exec(ctx context.Context, sql string, arguments ...any) (commandTag pgconn.CommandTag, err error) {
tx.go#L330: return pgconn.CommandTag{}, ErrTxClosed
github.com/jackc/pgx/v5/pgxpool
batch_results.go#L12: func (br errBatchResults) Exec() (pgconn.CommandTag, error) {
batch_results.go#L13: return pgconn.CommandTag{}, br.err
batch_results.go#L33: func (br *poolBatchResults) Exec() (pgconn.CommandTag, error) {
conn.go#L86: func (c *Conn) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
pool.go#L719: func (p *Pool) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
pool.go#L722: return pgconn.CommandTag{}, err
rows.go#L14: func (errRows) CommandTag() pgconn.CommandTag { return pgconn.CommandTag{} }
rows.go#L49: func (rows *poolRows) CommandTag() pgconn.CommandTag {
tx.go#L69: func (tx *Tx) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
go.pact.im/x/pgxprocess
errors.go#L28: func (errRows) CommandTag() pgconn.CommandTag {
errors.go#L29: return pgconn.CommandTag{}
errors.go#L58: func (errBatchResults) Exec() (pgconn.CommandTag, error) {
errors.go#L59: return pgconn.CommandTag{}, ErrNotConnected
handle.go#L16: Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
handle.go#L59: func (h *handle[T, P]) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error) {
handle.go#L62: return pgconn.CommandTag{}, ErrNotConnected