adapters

Documentation

Index

• func FormatMysqlDsn(dsn sqb.Dsn) string
• type PgxAdapter
• type PgxConn
  • func (c PgxConn) Adapter() sqb.Adapter
  • func (c PgxConn) Close() error
  • func (c PgxConn) Query(qry sqb.Query) (sqb.Rows, error)
• type PgxDb
  • func NewPgxDb(d *pgxpool.Pool) PgxDb
  • func (d PgxDb) Adapter() sqb.Adapter
  • func (d PgxDb) Close() error
  • func (d PgxDb) Connect(ctx context.Context) (sqb.Conn, error)
  • func (d PgxDb) Query(qry sqb.Query) (sqb.Rows, error)
• type PgxRows
  • func (r PgxRows) Close() error
  • func (r *PgxRows) Columns() (*sqb.Columns, error)
  • func (r PgxRows) Err() error
  • func (r PgxRows) Next() bool
  • func (r PgxRows) Scan(dest ...any) error
• type StdAdapter
• type StdConn
  • func (c StdConn) Adapter() sqb.Adapter
  • func (c StdConn) Close() error
  • func (c StdConn) Query(qry sqb.Query) (sqb.Rows, error)
• type StdDb
  • func NewStdDb(d *sql.DB) StdDb
  • func (d StdDb) Adapter() sqb.Adapter
  • func (d StdDb) Close() error
  • func (d StdDb) Connect(ctx context.Context) (sqb.Conn, error)
  • func (d StdDb) Query(qry sqb.Query) (sqb.Rows, error)
• type StdRows
  • func (r StdRows) Close() error
  • func (r *StdRows) Columns() (*sqb.Columns, error)
  • func (r StdRows) Err() error
  • func (r StdRows) Next() bool
  • func (r StdRows) Scan(dest ...any) error

Functions

func FormatMysqlDsn

func FormatMysqlDsn(dsn sqb.Dsn) string

Types

type PgxAdapter

type PgxAdapter struct {
	sqb.BaseAdapter
}

type PgxConn

type PgxConn struct {
	sqb.BaseConn
	// contains filtered or unexported fields
}

func (PgxConn) Adapter

func (c PgxConn) Adapter() sqb.Adapter

func (PgxConn) Close

func (c PgxConn) Close() error

func (PgxConn) Query

func (c PgxConn) Query(qry sqb.Query) (sqb.Rows, error)

type PgxDb

type PgxDb struct {
	sqb.BaseDb
	// contains filtered or unexported fields
}

func NewPgxDb

func NewPgxDb(d *pgxpool.Pool) PgxDb

func (PgxDb) Adapter

func (d PgxDb) Adapter() sqb.Adapter

func (PgxDb) Close

func (d PgxDb) Close() error

func (PgxDb) Connect

func (d PgxDb) Connect(ctx context.Context) (sqb.Conn, error)

func (PgxDb) Query

func (d PgxDb) Query(qry sqb.Query) (sqb.Rows, error)

type PgxRows

type PgxRows struct {
	sqb.BaseRows
	// contains filtered or unexported fields
}

func (PgxRows) Close

func (r PgxRows) Close() error

func (*PgxRows) Columns

func (r *PgxRows) Columns() (*sqb.Columns, error)

func (PgxRows) Err

func (r PgxRows) Err() error

func (PgxRows) Next

func (r PgxRows) Next() bool

func (PgxRows) Scan

func (r PgxRows) Scan(dest ...any) error

type StdAdapter

type StdAdapter struct {
	sqb.BaseAdapter
}

type StdConn

type StdConn struct {
	sqb.BaseConn
	// contains filtered or unexported fields
}

func (StdConn) Adapter

func (c StdConn) Adapter() sqb.Adapter

func (StdConn) Close

func (c StdConn) Close() error

func (StdConn) Query

func (c StdConn) Query(qry sqb.Query) (sqb.Rows, error)

type StdDb

type StdDb struct {
	sqb.BaseDb
	// contains filtered or unexported fields
}

func NewStdDb

func NewStdDb(d *sql.DB) StdDb

func (StdDb) Adapter

func (d StdDb) Adapter() sqb.Adapter

func (StdDb) Close

func (d StdDb) Close() error

func (StdDb) Connect

func (d StdDb) Connect(ctx context.Context) (sqb.Conn, error)

func (StdDb) Query

func (d StdDb) Query(qry sqb.Query) (sqb.Rows, error)

type StdRows

type StdRows struct {
	sqb.BaseRows
	// contains filtered or unexported fields
}

func (StdRows) Close

func (r StdRows) Close() error

func (*StdRows) Columns

func (r *StdRows) Columns() (*sqb.Columns, error)

func (StdRows) Err

func (r StdRows) Err() error

func (StdRows) Next

func (r StdRows) Next() bool

func (StdRows) Scan

func (r StdRows) Scan(dest ...any) error