postgres

Documentation

Index

• func TypeTag(dbType string) (string, error)
• type DB
  • func Open(option *types.PostgresOpt) (*DB, error)
  • func OpenWith(host, port, user, password, database string) (*DB, error)
  • func (db *DB) Export(ctx context.Context, opt offline.ExportOpt) (<-chan *types.RawFeatureValueRecord, error)
  • func (db *DB) Import(ctx context.Context, opt offline.ImportOpt) (int64, string, error)
  • func (db *DB) Join(ctx context.Context, opt offline.JoinOpt) (dataMap map[string]dbutil.RowMap, err error)
  • func (db *DB) LoadData(ctx context.Context, csvReader *csv.Reader, tableName string, header []string) error
  • func (db *DB) TypeTag(dbType string) (string, error)

Functions

func TypeTag

func TypeTag(dbType string) (string, error)

Types

type DB

type DB struct {
	*sqlx.DB
}

func Open

func Open(option *types.PostgresOpt) (*DB, error)

func OpenWith

func OpenWith(host, port, user, password, database string) (*DB, error)

func (*DB) Export

func (db *DB) Export(ctx context.Context, opt offline.ExportOpt) (<-chan *types.RawFeatureValueRecord, error)

func (*DB) Import

func (db *DB) Import(ctx context.Context, opt offline.ImportOpt) (int64, string, error)

func (*DB) Join

func (db *DB) Join(ctx context.Context, opt offline.JoinOpt) (dataMap map[string]dbutil.RowMap, err error)

func (*DB) LoadData

func (db *DB) LoadData(ctx context.Context, csvReader *csv.Reader, tableName string, header []string) error

func (*DB) TypeTag

func (db *DB) TypeTag(dbType string) (string, error)