postgres

Documentation

Index

• func ColumnsWithDataTypes(columns map[string]string, prefix string) string
• func Connect(cred CredentialsT) (*sql.DB, error)
• func Init()
• type CredentialsT
• type HandleT
  • func (pg *HandleT) AddColumn(tableName, columnName, columnType string) (err error)
  • func (*HandleT) AlterColumn(_, _, _ string) (err error)
  • func (pg *HandleT) Cleanup()
  • func (pg *HandleT) Connect(warehouse warehouseutils.Warehouse) (client.Client, error)
  • func (pg *HandleT) CrashRecover(warehouse warehouseutils.Warehouse) (err error)
  • func (pg *HandleT) CreateSchema() (err error)
  • func (pg *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)
  • func (pq *HandleT) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)
  • func (*HandleT) DownloadIdentityRules(*misc.GZipWriter) (err error)
  • func (pg *HandleT) DownloadLoadFiles(tableName string) ([]string, error)
  • func (as *HandleT) DropTable(tableName string) (err error)
  • func (pg *HandleT) FetchSchema(warehouse warehouseutils.Warehouse) (schema warehouseutils.SchemaT, err error)
  • func (pg *HandleT) GetTotalCountInTable(ctx context.Context, tableName string) (total int64, err error)
  • func (*HandleT) IsEmpty(_ warehouseutils.Warehouse) (empty bool, err error)
  • func (*HandleT) LoadIdentityMappingsTable() (err error)
  • func (*HandleT) LoadIdentityMergeRulesTable() (err error)
  • func (pg *HandleT) LoadTable(tableName string) error
  • func (pg *HandleT) LoadTestTable(_, tableName string, payloadMap map[string]interface{}, _ string) (err error)
  • func (pg *HandleT) LoadUserTables() map[string]error
  • func (pg *HandleT) SetConnectionTimeout(timeout time.Duration)
  • func (pg *HandleT) Setup(warehouse warehouseutils.Warehouse, uploader warehouseutils.UploaderI) (err error)
  • func (pg *HandleT) TestConnection(warehouse warehouseutils.Warehouse) (err error)
• type QueryParams

Functions

func ColumnsWithDataTypes

func ColumnsWithDataTypes(columns map[string]string, prefix string) string

func Connect

func Connect(cred CredentialsT) (*sql.DB, error)

func Init

func Init()

Types

type CredentialsT

type CredentialsT struct {
	Host     string
	DBName   string
	User     string
	Password string
	Port     string
	SSLMode  string
	SSLDir   string
	// contains filtered or unexported fields
}

type HandleT

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

func (*HandleT) AddColumn

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

func (*HandleT) AlterColumn

func (*HandleT) AlterColumn(_, _, _ string) (err error)

func (*HandleT) Cleanup

func (pg *HandleT) Cleanup()

func (*HandleT) Connect

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

func (*HandleT) CrashRecover

func (pg *HandleT) CrashRecover(warehouse warehouseutils.Warehouse) (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) DeleteBy

func (pq *HandleT) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)

Need to create a structure with delete parameters instead of simply adding a long list of params

func (*HandleT) DownloadIdentityRules

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

func (*HandleT) DownloadLoadFiles

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

func (*HandleT) DropTable

func (as *HandleT) DropTable(tableName string) (err error)

func (*HandleT) FetchSchema

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

FetchSchema queries postgres and returns the schema associated with provided namespace

func (*HandleT) GetTotalCountInTable

func (pg *HandleT) GetTotalCountInTable(ctx context.Context, tableName string) (total int64, err error)

func (*HandleT) IsEmpty

func (*HandleT) IsEmpty(_ warehouseutils.Warehouse) (empty bool, err error)

func (*HandleT) LoadIdentityMappingsTable

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

func (*HandleT) LoadIdentityMergeRulesTable

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

func (*HandleT) LoadTable

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

func (*HandleT) LoadTestTable

func (pg *HandleT) LoadTestTable(_, tableName string, payloadMap map[string]interface{}, _ string) (err error)

func (*HandleT) LoadUserTables

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

func (*HandleT) SetConnectionTimeout

func (pg *HandleT) SetConnectionTimeout(timeout time.Duration)

func (*HandleT) Setup

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

func (*HandleT) TestConnection

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

type QueryParams

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