pg

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, option ClientOption) (*Client, error)
  • func (obj *Client) Close()
  • func (obj *Client) Exec(ctx context.Context, query string, args ...any) (*Result, error)
  • func (obj *Client) Finds(ctx context.Context, query string, args ...any) (*Rows, error)
  • func (obj *Client) Insert(ctx context.Context, table string, datas ...any) error
• type ClientOption
• type Result
  • func (obj *Result) RowsAffected() int64
  • func (obj *Result) String() string
• type Rows
  • func (obj *Rows) Close()
  • func (obj *Rows) Data() (map[string]any, error)
  • func (obj *Rows) Json() (gjson.Result, error)
  • func (obj *Rows) Next() bool

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, option ClientOption) (*Client, error)

func (*Client) Close

func (obj *Client) Close()

func (*Client) Exec

func (obj *Client) Exec(ctx context.Context, query string, args ...any) (*Result, error)

$1 is args 执行

func (*Client) Finds

func (obj *Client) Finds(ctx context.Context, query string, args ...any) (*Rows, error)

finds $1 is args

func (*Client) Insert

func (obj *Client) Insert(ctx context.Context, table string, datas ...any) error

insert $1 is args

type ClientOption

type ClientOption struct {
	Host string
	Port int
	Usr  string //用户名
	Pwd  string //密码
	Db   string //数据库名称
}

type Result

type Result struct {
	// contains filtered or unexported fields
}

func (*Result) RowsAffected

func (obj *Result) RowsAffected() int64

受影响的行数

func (*Result) String

func (obj *Result) String() string

结果

type Rows

type Rows struct {
	// contains filtered or unexported fields
}

func (*Rows) Close

func (obj *Rows) Close()

关闭游标

func (*Rows) Data

func (obj *Rows) Data() (map[string]any, error)

返回游标的数据

func (*Rows) Json

func (obj *Rows) Json() (gjson.Result, error)

返回游标的数据

func (*Rows) Next

func (obj *Rows) Next() bool

是否有下一个数据