Function postgresOfflineStoreFactory

provider/postgres.go:25–54

(config pc.SerializedConfig)

)

func postgresOfflineStoreFactory(config pc.SerializedConfig) (Provider, error) {
	sc := pc.PostgresConfig{}
	if err := sc.Deserialize(config); err != nil {
		return nil, NewProviderError(Runtime, pt.PostgresOffline, ConfigDeserialize, err.Error())
	}

	// We are doing this to support older versions of
	// featureform that did not have the sslmode field
	// on the client side.
	sslMode := sc.SSLMode
	if sslMode == "" {
		sslMode = "disable"
	}

	queries := postgresSQLQueries{}
	queries.setVariableBinding(PostgresBindingStyle)
	sgConfig := SQLOfflineStoreConfig{
		Config:        config,
		ConnectionURL: fmt.Sprintf("postgres://%s:%s@%s:%s/%s?sslmode=%s", sc.Username, sc.Password, sc.Host, sc.Port, sc.Database, sslMode),
		Driver:        "postgres",
		ProviderType:  pt.PostgresOffline,
		QueryImpl:     &queries,
	}

	store, err := NewSQLOfflineStore(sgConfig)
	if err != nil {
		return nil, err
	}
	return store, nil
}

type postgresSQLQueries struct {
	defaultOfflineSQLQueries