pgsqlgo

README

pgsqlgo

pgsqlgo is a Go Client for PostgreSQL.

Usage

todo ...

Licensing

Licensed under the Apache License, Version 2.0

Documentation

Index

• func NewConnector(cfg connect.ConnOptions) (rdb.Connector, error)
• func NewFilter() rdb.Filter
• func NewQueryer() rdb.Queryer
• type Dialect
  • func (dc *Dialect) Close()
  • func (dc *Dialect) DBName() string
  • func (dc *Dialect) Modeler() (modeler.Modeler, error)
  • func (dc *Dialect) NewFilter() rdb.Filter
  • func (dc *Dialect) NewQueryer() rdb.Queryer
  • func (dc *Dialect) QuoteStr(str string) string
• type DialectModeler
  • func (dc *DialectModeler) ColumnDel(tableName string, col *modeler.Column) error
  • func (dc *DialectModeler) ColumnDump(tableName string) ([]*modeler.Column, error)
  • func (dc *DialectModeler) ColumnSet(tableName string, col *modeler.Column) error
  • func (dc *DialectModeler) ColumnSync(tableName string, col *modeler.Column) error
  • func (dc *DialectModeler) ColumnTypeSql(table_name string, col *modeler.Column) string
  • func (dc *DialectModeler) IndexDel(tableName string, index *modeler.Index) error
  • func (dc *DialectModeler) IndexDump(tableName string) ([]*modeler.Index, error)
  • func (dc *DialectModeler) IndexSet(tableName string, index *modeler.Index) error
  • func (dc *DialectModeler) IndexSync(tableName string, index *modeler.Index) error
  • func (dc *DialectModeler) QuoteStr(str string) string
  • func (dc *DialectModeler) SchemaDump() (*modeler.Schema, error)
  • func (dc *DialectModeler) SchemaSync(newds *modeler.Schema) error
  • func (dc *DialectModeler) SchemaSyncByJson(js string) error
  • func (dc *DialectModeler) SchemaSyncByJsonFile(js_path string) error
  • func (dc *DialectModeler) TableDump() ([]*modeler.Table, error)
  • func (dc *DialectModeler) TableExist(tableName string) bool
  • func (dc *DialectModeler) TableSync(table *modeler.Table) error
• type Filter
  • func (fr *Filter) And(expr string, args ...interface{}) rdb.Filter
  • func (fr *Filter) Or(expr string, args ...interface{}) rdb.Filter
  • func (fr *Filter) Parse() (where string, params []interface{})
  • func (fr *Filter) Reset() rdb.Filter
• type Queryer
  • func (q *Queryer) From(s string) rdb.Queryer
  • func (q *Queryer) Group(s string) rdb.Queryer
  • func (q *Queryer) Limit(num int64) rdb.Queryer
  • func (q *Queryer) Offset(num int64) rdb.Queryer
  • func (q *Queryer) Order(s string) rdb.Queryer
  • func (q *Queryer) Parse() (sql string, params []interface{})
  • func (q *Queryer) Select(s string) rdb.Queryer
  • func (q *Queryer) SetFilter(fr rdb.Filter)
  • func (q *Queryer) Where() rdb.Filter

Functions

func NewConnector

func NewConnector(cfg connect.ConnOptions) (rdb.Connector, error)

func NewFilter

func NewFilter() rdb.Filter

func NewQueryer

func NewQueryer() rdb.Queryer

Types

type Dialect

type Dialect struct {
	rdb.Base
	// contains filtered or unexported fields
}

func (*Dialect) Close

func (dc *Dialect) Close()

func (*Dialect) DBName

func (dc *Dialect) DBName() string

func (*Dialect) Modeler

func (dc *Dialect) Modeler() (modeler.Modeler, error)

func (*Dialect) NewFilter

func (dc *Dialect) NewFilter() rdb.Filter

func (*Dialect) NewQueryer

func (dc *Dialect) NewQueryer() rdb.Queryer

func (*Dialect) QuoteStr

func (dc *Dialect) QuoteStr(str string) string

type DialectModeler

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

func (*DialectModeler) ColumnDel

func (dc *DialectModeler) ColumnDel(tableName string, col *modeler.Column) error

func (*DialectModeler) ColumnDump

func (dc *DialectModeler) ColumnDump(tableName string) ([]*modeler.Column, error)

func (*DialectModeler) ColumnSet

func (dc *DialectModeler) ColumnSet(tableName string, col *modeler.Column) error

func (*DialectModeler) ColumnSync

func (dc *DialectModeler) ColumnSync(tableName string, col *modeler.Column) error

func (*DialectModeler) ColumnTypeSql

func (dc *DialectModeler) ColumnTypeSql(table_name string, col *modeler.Column) string

func (*DialectModeler) IndexDel

func (dc *DialectModeler) IndexDel(tableName string, index *modeler.Index) error

func (*DialectModeler) IndexDump

func (dc *DialectModeler) IndexDump(tableName string) ([]*modeler.Index, error)

func (*DialectModeler) IndexSet

func (dc *DialectModeler) IndexSet(tableName string, index *modeler.Index) error

func (*DialectModeler) IndexSync

func (dc *DialectModeler) IndexSync(tableName string, index *modeler.Index) error

func (*DialectModeler) QuoteStr

func (dc *DialectModeler) QuoteStr(str string) string

func (*DialectModeler) SchemaDump

func (dc *DialectModeler) SchemaDump() (*modeler.Schema, error)

func (*DialectModeler) SchemaSync

func (dc *DialectModeler) SchemaSync(newds *modeler.Schema) error

func (*DialectModeler) SchemaSyncByJson

func (dc *DialectModeler) SchemaSyncByJson(js string) error

func (*DialectModeler) SchemaSyncByJsonFile

func (dc *DialectModeler) SchemaSyncByJsonFile(js_path string) error

func (*DialectModeler) TableDump

func (dc *DialectModeler) TableDump() ([]*modeler.Table, error)

func (*DialectModeler) TableExist

func (dc *DialectModeler) TableExist(tableName string) bool

func (*DialectModeler) TableSync

func (dc *DialectModeler) TableSync(table *modeler.Table) error

type Filter

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

func (*Filter) And

func (fr *Filter) And(expr string, args ...interface{}) rdb.Filter

func (*Filter) Or

func (fr *Filter) Or(expr string, args ...interface{}) rdb.Filter

func (*Filter) Parse

func (fr *Filter) Parse() (where string, params []interface{})

func (*Filter) Reset

func (fr *Filter) Reset() rdb.Filter

type Queryer

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

func (*Queryer) From

func (q *Queryer) From(s string) rdb.Queryer

func (*Queryer) Group

func (q *Queryer) Group(s string) rdb.Queryer

func (*Queryer) Limit

func (q *Queryer) Limit(num int64) rdb.Queryer

func (*Queryer) Offset

func (q *Queryer) Offset(num int64) rdb.Queryer

func (*Queryer) Order

func (q *Queryer) Order(s string) rdb.Queryer

func (*Queryer) Parse

func (q *Queryer) Parse() (sql string, params []interface{})

func (*Queryer) Select

func (q *Queryer) Select(s string) rdb.Queryer

func (*Queryer) SetFilter

func (q *Queryer) SetFilter(fr rdb.Filter)

func (*Queryer) Where

func (q *Queryer) Where() rdb.Filter