type github.com/jackc/pgx/v5/pgconn.CommandTag
110 uses
github.com/jackc/pgx/v5/pgconn (current package)
pgconn.go#L851: type CommandTag struct {
pgconn.go#L856: func NewCommandTag(s string) CommandTag {
pgconn.go#L857: return CommandTag{s: s}
pgconn.go#L862: func (ct CommandTag) RowsAffected() int64 {
pgconn.go#L880: func (ct CommandTag) String() string {
pgconn.go#L885: func (ct CommandTag) Insert() bool {
pgconn.go#L890: func (ct CommandTag) Update() bool {
pgconn.go#L895: func (ct CommandTag) Delete() bool {
pgconn.go#L900: func (ct CommandTag) Select() bool {
pgconn.go#L1331: result.concludeCommand(CommandTag{}, err)
pgconn.go#L1337: result.concludeCommand(CommandTag{}, fmt.Errorf("extended protocol limited to %v parameters", math.MaxUint16))
pgconn.go#L1346: result.concludeCommand(CommandTag{}, newContextAlreadyDoneError(ctx))
pgconn.go#L1368: result.concludeCommand(CommandTag{}, err)
pgconn.go#L1379: func (pgConn *PgConn) CopyTo(ctx context.Context, w io.Writer, sql string) (CommandTag, error) {
pgconn.go#L1381: return CommandTag{}, err
pgconn.go#L1388: return CommandTag{}, newContextAlreadyDoneError(ctx)
pgconn.go#L1402: return CommandTag{}, err
pgconn.go#L1406: var commandTag CommandTag
pgconn.go#L1412: return CommandTag{}, normalizeTimeoutError(ctx, err)
pgconn.go#L1421: return CommandTag{}, err
pgconn.go#L1438: func (pgConn *PgConn) CopyFrom(ctx context.Context, r io.Reader, sql string) (CommandTag, error) {
pgconn.go#L1440: return CommandTag{}, err
pgconn.go#L1447: return CommandTag{}, newContextAlreadyDoneError(ctx)
pgconn.go#L1459: return CommandTag{}, err
pgconn.go#L1514: return CommandTag{}, normalizeTimeoutError(ctx, err)
pgconn.go#L1522: return CommandTag{}, serverError
pgconn.go#L1545: return CommandTag{}, err
pgconn.go#L1549: var commandTag CommandTag
pgconn.go#L1554: return CommandTag{}, normalizeTimeoutError(ctx, err)
pgconn.go#L1641: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1717: commandTag CommandTag
pgconn.go#L1728: CommandTag CommandTag
pgconn.go#L1800: func (rr *ResultReader) Close() (CommandTag, error) {
pgconn.go#L1809: return CommandTag{}, rr.err
pgconn.go#L1817: return CommandTag{}, rr.err
pgconn.go#L1851: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1862: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1879: rr.concludeCommand(CommandTag{}, err)
pgconn.go#L1896: rr.concludeCommand(CommandTag{}, nil)
pgconn.go#L1902: rr.concludeCommand(CommandTag{}, pgErr)
pgconn.go#L1908: func (rr *ResultReader) concludeCommand(commandTag CommandTag, err error) {
pgconn.go#L2101: func (pgConn *PgConn) makeCommandTag(buf []byte) CommandTag {
pgconn.go#L2102: 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#L92: Exec() (pgconn.CommandTag, error)
batch.go#L130: func (br *batchResults) Exec() (pgconn.CommandTag, error) {
batch.go#L132: return pgconn.CommandTag{}, br.err
batch.go#L135: return pgconn.CommandTag{}, fmt.Errorf("batch already closed")
batch.go#L152: return pgconn.CommandTag{}, err
batch.go#L292: func (br *pipelineBatchResults) Exec() (pgconn.CommandTag, error) {
batch.go#L294: return pgconn.CommandTag{}, br.err
batch.go#L297: return pgconn.CommandTag{}, fmt.Errorf("batch already closed")
batch.go#L301: return pgconn.CommandTag{}, br.err
batch.go#L306: return pgconn.CommandTag{}, err
batch.go#L312: return pgconn.CommandTag{}, br.err
batch.go#L314: var commandTag pgconn.CommandTag
batch.go#L319: return pgconn.CommandTag{}, fmt.Errorf("unexpected pipeline result: %T", results)
batch.go#L461: func (br *emptyBatchResults) Exec() (pgconn.CommandTag, error) {
batch.go#L463: return pgconn.CommandTag{}, fmt.Errorf("batch already closed")
batch.go#L465: 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#L85: func (c *Conn) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
pool.go#L727: func (p *Pool) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) {
pool.go#L730: 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