postgis

Documentation

Overview

Package postgis implements the database interfaces for PostGIS.

Index

• func New(conf database.Config, m *mapping.Mapping) (database.DB, error)
• type ColumnSpec
  • func (col *ColumnSpec) AsSQL() string
• type ColumnType
• type GeneralizedTableSpec
  • func NewGeneralizedTableSpec(pg *PostGIS, t *mapping.GeneralizedTable) *GeneralizedTableSpec
  • func (spec *GeneralizedTableSpec) DeleteSQL() string
  • func (spec *GeneralizedTableSpec) InsertSQL() string
• type PostGIS
  • func (pg *PostGIS) Abort() error
  • func (pg *PostGIS) Begin() error
  • func (pg *PostGIS) BeginBulk() error
  • func (pg *PostGIS) Close() error
  • func (pg *PostGIS) Delete(id int64, matches interface{}) error
  • func (pg *PostGIS) DeleteElem(elem element.OSMElem) error
  • func (pg *PostGIS) Deploy() error
  • func (pg *PostGIS) EnableGeneralizeUpdates()
  • func (pg *PostGIS) End() error
  • func (pg *PostGIS) Finish() error
  • func (pg *PostGIS) Generalize() error
  • func (pg *PostGIS) GeneralizeUpdates() error
  • func (pg *PostGIS) Init() error
  • func (pg *PostGIS) InsertLineString(elem element.OSMElem, geom geom.Geometry, matches []mapping.Match) error
  • func (pg *PostGIS) InsertPoint(elem element.OSMElem, geom geom.Geometry, matches []mapping.Match) error
  • func (pg *PostGIS) InsertPolygon(elem element.OSMElem, geom geom.Geometry, matches []mapping.Match) error
  • func (pg *PostGIS) Open() error
  • func (pg *PostGIS) Optimize() error
  • func (pg *PostGIS) RemoveBackup() error
  • func (pg *PostGIS) RevertDeploy() error
• type SQLError
  • func (e *SQLError) Error() string
• type SQLInsertError
  • func (e *SQLInsertError) Error() string
• type TableSpec
  • func NewTableSpec(pg *PostGIS, t *mapping.Table) *TableSpec
  • func (spec *TableSpec) CopySQL() string
  • func (spec *TableSpec) CreateTableSQL() string
  • func (spec *TableSpec) DeleteSQL() string
  • func (spec *TableSpec) InsertSQL() string
• type TableTx
  • func NewBulkTableTx(pg *PostGIS, spec *TableSpec) TableTx
  • func NewSynchronousTableTx(pg *PostGIS, tableName string, spec tableSpec) TableTx
• type TxRouter
  • func (txr *TxRouter) Abort() error
  • func (txr *TxRouter) Delete(table string, id int64) error
  • func (txr *TxRouter) End() error
  • func (txr *TxRouter) Insert(table string, row []interface{}) error

Functions

func New

func New(conf database.Config, m *mapping.Mapping) (database.DB, error)

Types

type ColumnSpec

type ColumnSpec struct {
	Name      string
	FieldType mapping.FieldType
	Type      ColumnType
}

func (*ColumnSpec) AsSQL

func (col *ColumnSpec) AsSQL() string

type ColumnType

type ColumnType interface {
	Name() string
	PrepareInsertSql(i int,
		spec *TableSpec) string
	GeneralizeSql(colSpec *ColumnSpec, spec *GeneralizedTableSpec) string
}

type GeneralizedTableSpec

type GeneralizedTableSpec struct {
	Name              string
	FullName          string
	Schema            string
	SourceName        string
	Source            *TableSpec
	SourceGeneralized *GeneralizedTableSpec
	Tolerance         float64
	Where             string

	Generalizations []*GeneralizedTableSpec
	// contains filtered or unexported fields
}

func NewGeneralizedTableSpec

func NewGeneralizedTableSpec(pg *PostGIS, t *mapping.GeneralizedTable) *GeneralizedTableSpec

func (*GeneralizedTableSpec) DeleteSQL

func (spec *GeneralizedTableSpec) DeleteSQL() string

func (*GeneralizedTableSpec) InsertSQL

func (spec *GeneralizedTableSpec) InsertSQL() string

type PostGIS

type PostGIS struct {
	Db                *sql.DB
	Params            string
	Config            database.Config
	Tables            map[string]*TableSpec
	GeneralizedTables map[string]*GeneralizedTableSpec
	Prefix            string
	// contains filtered or unexported fields
}

func (*PostGIS) Abort

func (pg *PostGIS) Abort() error

func (*PostGIS) Begin

func (pg *PostGIS) Begin() error

func (*PostGIS) BeginBulk

func (pg *PostGIS) BeginBulk() error

func (*PostGIS) Close

func (pg *PostGIS) Close() error

func (*PostGIS) Delete

func (pg *PostGIS) Delete(id int64, matches interface{}) error

func (*PostGIS) DeleteElem

func (pg *PostGIS) DeleteElem(elem element.OSMElem) error

func (*PostGIS) Deploy

func (pg *PostGIS) Deploy() error

func (*PostGIS) EnableGeneralizeUpdates

func (pg *PostGIS) EnableGeneralizeUpdates()

func (*PostGIS) End

func (pg *PostGIS) End() error

func (*PostGIS) Finish

func (pg *PostGIS) Finish() error

Finish creates spatial indices on all tables.

func (*PostGIS) Generalize

func (pg *PostGIS) Generalize() error

func (*PostGIS) GeneralizeUpdates

func (pg *PostGIS) GeneralizeUpdates() error

func (*PostGIS) Init

func (pg *PostGIS) Init() error

Init creates schema and tables, drops existing data.

func (*PostGIS) InsertLineString

func (pg *PostGIS) InsertLineString(elem element.OSMElem, geom geom.Geometry, matches []mapping.Match) error

func (*PostGIS) InsertPoint

func (pg *PostGIS) InsertPoint(elem element.OSMElem, geom geom.Geometry, matches []mapping.Match) error

func (*PostGIS) InsertPolygon

func (pg *PostGIS) InsertPolygon(elem element.OSMElem, geom geom.Geometry, matches []mapping.Match) error

func (*PostGIS) Open

func (pg *PostGIS) Open() error

func (*PostGIS) Optimize

func (pg *PostGIS) Optimize() error

Optimize clusters tables on new GeoHash index.

func (*PostGIS) RemoveBackup

func (pg *PostGIS) RemoveBackup() error

func (*PostGIS) RevertDeploy

func (pg *PostGIS) RevertDeploy() error

type SQLError

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

func (*SQLError) Error

func (e *SQLError) Error() string

type SQLInsertError

type SQLInsertError struct {
	SQLError
	// contains filtered or unexported fields
}

func (*SQLInsertError) Error

func (e *SQLInsertError) Error() string

type TableSpec

type TableSpec struct {
	Name            string
	FullName        string
	Schema          string
	Columns         []ColumnSpec
	GeometryType    string
	Srid            int
	Generalizations []*GeneralizedTableSpec
}

func NewTableSpec

func NewTableSpec(pg *PostGIS, t *mapping.Table) *TableSpec

func (*TableSpec) CopySQL

func (spec *TableSpec) CopySQL() string

func (*TableSpec) CreateTableSQL

func (spec *TableSpec) CreateTableSQL() string

func (*TableSpec) DeleteSQL

func (spec *TableSpec) DeleteSQL() string

func (*TableSpec) InsertSQL

func (spec *TableSpec) InsertSQL() string

type TableTx

type TableTx interface {
	Begin(*sql.Tx) error
	Insert(row []interface{}) error
	Delete(id int64) error
	End()
	Commit() error
	Rollback()
}

func NewBulkTableTx

func NewBulkTableTx(pg *PostGIS, spec *TableSpec) TableTx

func NewSynchronousTableTx

func NewSynchronousTableTx(pg *PostGIS, tableName string, spec tableSpec) TableTx

type TxRouter

type TxRouter struct {
	Tables map[string]TableTx
	// contains filtered or unexported fields
}

TxRouter routes inserts/deletes to TableTx

func (*TxRouter) Abort

func (txr *TxRouter) Abort() error

func (*TxRouter) Delete

func (txr *TxRouter) Delete(table string, id int64) error

func (*TxRouter) End

func (txr *TxRouter) End() error

func (*TxRouter) Insert

func (txr *TxRouter) Insert(table string, row []interface{}) error