postgreslegacy

May 9, 2023

Changes in this version

+ type Postgres struct

+ ConnectTimeout time.Duration

+ DB *sqlmiddleware.DB

+ EnableDeleteByJobs bool

+ EnableSQLStatementExecutionPlan bool

+ EnableSQLStatementExecutionPlanWorkspaceIDs []string

+ Namespace string

+ ObjectStorage string

+ SkipComputingUserLatestTraits bool

+ SkipComputingUserLatestTraitsWorkspaceIDs []string

+ SlowQueryThreshold time.Duration

+ TxnRollbackTimeout time.Duration

+ Uploader warehouseutils.Uploader

+ Warehouse model.Warehouse

+ func New() *Postgres

+ func (*Postgres) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)

+ func (*Postgres) DownloadIdentityRules(*misc.GZipWriter) (err error)

+ func (*Postgres) ErrorMappings() []model.JobError

+ func (*Postgres) IsEmpty(_ model.Warehouse) (empty bool, err error)

+ func (*Postgres) LoadIdentityMappingsTable() (err error)

+ func (*Postgres) LoadIdentityMergeRulesTable() (err error)

+ func (pg *Postgres) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)

+ func (pg *Postgres) Cleanup()

+ func (pg *Postgres) Connect(warehouse model.Warehouse) (client.Client, error)

+ func (pg *Postgres) CrashRecover()

+ func (pg *Postgres) CreateSchema() (err error)

+ func (pg *Postgres) CreateTable(tableName string, columnMap model.TableSchema) (err error)

+ func (pg *Postgres) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)

+ func (pg *Postgres) DownloadLoadFiles(ctx context.Context, tableName string) ([]string, error)

+ func (pg *Postgres) DropTable(tableName string) (err error)

+ func (pg *Postgres) FetchSchema(warehouse model.Warehouse) (schema, unrecognizedSchema model.Schema, err error)

+ func (pg *Postgres) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)

+ func (pg *Postgres) LoadTable(ctx context.Context, tableName string) error

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

+ func (pg *Postgres) LoadUserTables(ctx context.Context) map[string]error

+ func (pg *Postgres) SetConnectionTimeout(timeout time.Duration)

+ func (pg *Postgres) Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)

+ func (pg *Postgres) TestConnection(ctx context.Context, warehouse model.Warehouse) error

Mar 20, 2023

Changes in this version

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

+ func Connect(cred Credentials) (*sql.DB, error)

+ func Init()

+ func WithConfig(h *Handle, config *config.Config)

+ type Credentials struct

+ DBName string

+ Host string

+ Password string

+ Port string

+ SSLDir string

+ SSLMode string

+ TunnelInfo *tunnelling.TunnelInfo

+ User string

+ type Handle struct

+ ConnectTimeout time.Duration

+ DB *sql.DB

+ EnableDeleteByJobs bool

+ EnableSQLStatementExecutionPlan bool

+ EnableSQLStatementExecutionPlanWorkspaceIDs []string

+ Namespace string

+ ObjectStorage string

+ SkipComputingUserLatestTraits bool

+ SkipComputingUserLatestTraitsWorkspaceIDs []string

+ TxnRollbackTimeout time.Duration

+ Uploader warehouseutils.Uploader

+ Warehouse model.Warehouse

+ func NewHandle() *Handle

+ func (*Handle) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)

+ func (*Handle) DownloadIdentityRules(*misc.GZipWriter) (err error)

+ func (*Handle) IsEmpty(_ model.Warehouse) (empty bool, err error)

+ func (*Handle) LoadIdentityMappingsTable() (err error)

+ func (*Handle) LoadIdentityMergeRulesTable() (err error)

+ func (pg *Handle) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)

+ func (pg *Handle) Cleanup()

+ func (pg *Handle) Connect(warehouse model.Warehouse) (client.Client, error)

+ func (pg *Handle) CrashRecover(warehouse model.Warehouse) (err error)

+ func (pg *Handle) CreateSchema() (err error)

+ func (pg *Handle) CreateTable(tableName string, columnMap model.TableSchema) (err error)

+ func (pg *Handle) DeleteBy(tableNames []string, params warehouseutils.DeleteByParams) (err error)

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

+ func (pg *Handle) DropTable(tableName string) (err error)

+ func (pg *Handle) FetchSchema(warehouse model.Warehouse) (schema, unrecognizedSchema model.Schema, err error)

+ func (pg *Handle) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)

+ func (pg *Handle) LoadTable(tableName string) error

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

+ func (pg *Handle) LoadUserTables() map[string]error

+ func (pg *Handle) SetConnectionTimeout(timeout time.Duration)

+ func (pg *Handle) Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)

+ func (pg *Handle) TestConnection(warehouse model.Warehouse) (err error)

+ func (pq *Handle) ErrorMappings() []model.JobError

+ type QueryParams struct