type github.com/jackc/pgx/v4.Conn
57 uses
github.com/jackc/pgx/v4 (current package)
batch.go#L52: conn *Conn
conn.go#L60: type Conn struct {
conn.go#L102: func Connect(ctx context.Context, connString string) (*Conn, error) {
conn.go#L112: func ConnectConfig(ctx context.Context, connConfig *ConnConfig) (*Conn, error) {
conn.go#L188: func connect(ctx context.Context, config *ConnConfig) (c *Conn, err error) {
conn.go#L203: c = &Conn{
conn.go#L250: func (c *Conn) Close(ctx context.Context) error {
conn.go#L268: func (c *Conn) Prepare(ctx context.Context, name, sql string) (sd *pgconn.StatementDescription, err error) {
conn.go#L297: func (c *Conn) Deallocate(ctx context.Context, name string) error {
conn.go#L303: func (c *Conn) bufferNotifications(_ *pgconn.PgConn, n *pgconn.Notification) {
conn.go#L309: func (c *Conn) WaitForNotification(ctx context.Context) (*pgconn.Notification, error) {
conn.go#L327: func (c *Conn) IsClosed() bool {
conn.go#L331: func (c *Conn) die(err error) {
conn.go#L341: func (c *Conn) shouldLog(lvl LogLevel) bool {
conn.go#L345: func (c *Conn) log(ctx context.Context, lvl LogLevel, msg string, data map[string]interface{}) {
conn.go#L360: func (c *Conn) Ping(ctx context.Context) error {
conn.go#L394: func (c *Conn) PgConn() *pgconn.PgConn { return c.pgConn }
conn.go#L397: func (c *Conn) StatementCache() stmtcache.Cache { return c.stmtcache }
conn.go#L400: func (c *Conn) ConnInfo() *pgtype.ConnInfo { return c.connInfo }
conn.go#L403: func (c *Conn) Config() *ConnConfig { return c.config.Copy() }
conn.go#L407: func (c *Conn) Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error) {
conn.go#L426: func (c *Conn) exec(ctx context.Context, sql string, arguments ...interface{}) (commandTag pgconn.CommandTag, err error) {
conn.go#L471: func (c *Conn) execSimpleProtocol(ctx context.Context, sql string, arguments []interface{}) (commandTag pgconn.CommandTag, err error) {
conn.go#L487: func (c *Conn) execParamsAndPreparedPrefix(sd *pgconn.StatementDescription, arguments []interface{}) error {
conn.go#L513: func (c *Conn) execParams(ctx context.Context, sd *pgconn.StatementDescription, arguments []interface{}) (pgconn.CommandTag, error) {
conn.go#L523: func (c *Conn) execPrepared(ctx context.Context, sd *pgconn.StatementDescription, arguments []interface{}) (pgconn.CommandTag, error) {
conn.go#L533: func (c *Conn) getRows(ctx context.Context, sql string, args []interface{}) *connRows {
conn.go#L567: func (c *Conn) Query(ctx context.Context, sql string, args ...interface{}) (Rows, error) {
conn.go#L679: func (c *Conn) QueryRow(ctx context.Context, sql string, args ...interface{}) Row {
conn.go#L700: func (c *Conn) QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(QueryFuncRow) error) (pgconn.CommandTag, error) {
conn.go#L729: func (c *Conn) SendBatch(ctx context.Context, b *Batch) BatchResults {
conn.go#L831: func (c *Conn) sanitizeForSimpleQuery(sql string, args ...interface{}) (string, error) {
copy_from.go#L84: conn *Conn
copy_from.go#L201: func (c *Conn) CopyFrom(ctx context.Context, tableName Identifier, columnNames []string, rowSrc CopyFromSource) (int64, error) {
rows.go#L108: conn *Conn
tx.go#L70: func (c *Conn) Begin(ctx context.Context) (Tx, error) {
tx.go#L76: func (c *Conn) BeginTx(ctx context.Context, txOptions TxOptions) (Tx, error) {
tx.go#L91: func (c *Conn) BeginFunc(ctx context.Context, f func(Tx) error) (err error) {
tx.go#L99: func (c *Conn) BeginTxFunc(ctx context.Context, txOptions TxOptions, f func(Tx) error) (err error) {
tx.go#L160: Conn() *Conn
tx.go#L168: conn *Conn
tx.go#L319: func (tx *dbTx) Conn() *Conn {
tx.go#L437: func (sp *dbSavepoint) Conn() *Conn {
github.com/jackc/pgx/v4/stdlib
sql.go#L85: fakeTxConns = make(map[*pgx.Conn]*sql.Tx)
sql.go#L107: fakeTxConns map[*pgx.Conn]*sql.Tx
sql.go#L114: func OptionAfterConnect(ac func(context.Context, *pgx.Conn) error) OptionOpenDB {
sql.go#L123: AfterConnect: func(context.Context, *pgx.Conn) error { return nil }, // noop after connect by default
sql.go#L136: AfterConnect func(context.Context, *pgx.Conn) error // function to call on every new connection
sql.go#L144: conn *pgx.Conn
sql.go#L247: conn *pgx.Conn
sql.go#L254: func (c *Conn) Conn() *pgx.Conn {
sql.go#L293: if pconn, ok := ctx.Value(ctxKeyFakeTx).(**pgx.Conn); ok {
sql.go#L751: func AcquireConn(db *sql.DB) (*pgx.Conn, error) {
sql.go#L752: var conn *pgx.Conn
sql.go#L771: func ReleaseConn(db *sql.DB, conn *pgx.Conn) error {
golang.org/x/pkgsite/internal/database
copy.go#L39: return db.WithPGXConn(func(conn *pgx.Conn) error {
copy.go#L76: func (db *DB) WithPGXConn(f func(conn *pgx.Conn) error) error {
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |