postgres

Documentation

Index

• Constants
• type HandleT
  • func (pg *HandleT) AddColumn(tableName string, columnName string, columnType string) (err error)
  • func (pg *HandleT) AlterColumn(tableName string, columnName string, columnType string) (err error)
  • func (pg *HandleT) Cleanup()
  • func (pg *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)
  • func (pg *HandleT) CrashRecover(warehouse warehouseutils.WarehouseT) (err error)
  • func (pg *HandleT) CreateSchema() (err error)
  • func (pg *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)
  • func (pg *HandleT) DownloadIdentityRules(*misc.GZipWriter) (err error)
  • func (pg *HandleT) DownloadLoadFiles(tableName string) ([]string, error)
  • func (pg *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (schema warehouseutils.SchemaT, err error)
  • func (pg *HandleT) GetTotalCountInTable(tableName string) (total int64, err error)
  • func (bq *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (empty bool, err error)
  • func (pg *HandleT) LoadIdentityMappingsTable() (err error)
  • func (pg *HandleT) LoadIdentityMergeRulesTable() (err error)
  • func (pg *HandleT) LoadTable(tableName string) error
  • func (pg *HandleT) LoadUserTables() map[string]error
  • func (pg *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)
  • func (pg *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) (err error)

Constants

const PROVIDER = "POSTGRES"

Types

type HandleT

type HandleT struct {
	Db            *sql.DB
	Namespace     string
	ObjectStorage string
	Warehouse     warehouseutils.WarehouseT
	Uploader      warehouseutils.UploaderI
}

func (*HandleT) AddColumn

func (pg *HandleT) AddColumn(tableName string, columnName string, columnType string) (err error)

func (*HandleT) AlterColumn

func (pg *HandleT) AlterColumn(tableName string, columnName string, columnType string) (err error)

func (*HandleT) Cleanup

func (pg *HandleT) Cleanup()

func (*HandleT) Connect

func (pg *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)

func (*HandleT) CrashRecover

func (pg *HandleT) CrashRecover(warehouse warehouseutils.WarehouseT) (err error)

func (*HandleT) CreateSchema

func (pg *HandleT) CreateSchema() (err error)

func (*HandleT) CreateTable

func (pg *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)

func (*HandleT) DownloadIdentityRules

func (pg *HandleT) DownloadIdentityRules(*misc.GZipWriter) (err error)

func (*HandleT) DownloadLoadFiles

func (pg *HandleT) DownloadLoadFiles(tableName string) ([]string, error)

func (*HandleT) FetchSchema

func (pg *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (schema warehouseutils.SchemaT, err error)

FetchSchema queries postgres and returns the schema associated with provided namespace

func (*HandleT) GetTotalCountInTable

func (pg *HandleT) GetTotalCountInTable(tableName string) (total int64, err error)

func (*HandleT) IsEmpty

func (bq *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (empty bool, err error)

func (*HandleT) LoadIdentityMappingsTable

func (pg *HandleT) LoadIdentityMappingsTable() (err error)

func (*HandleT) LoadIdentityMergeRulesTable

func (pg *HandleT) LoadIdentityMergeRulesTable() (err error)

func (*HandleT) LoadTable

func (pg *HandleT) LoadTable(tableName string) error

func (*HandleT) LoadUserTables

func (pg *HandleT) LoadUserTables() map[string]error

func (*HandleT) Setup

func (pg *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)

func (*HandleT) TestConnection

func (pg *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) (err error)