Function NewSQLOfflineStore

provider/sql.go:80–96

NewPostgresOfflineStore creates a connection to a postgres database and initializes a table to track currently active Resource tables.

(config SQLOfflineStoreConfig)

// NewPostgresOfflineStore creates a connection to a postgres database
// and initializes a table to track currently active Resource tables.
func NewSQLOfflineStore(config SQLOfflineStoreConfig) (*sqlOfflineStore, error) {
	url := config.ConnectionURL
	db, err := sql.Open(config.Driver, url)
	if err != nil {
		return nil, NewProviderError(Connection, config.ProviderType, ClientInitialization, err.Error())
	}

	return &sqlOfflineStore{
		db:     db,
		parent: config,
		query:  config.QueryImpl,
		BaseProvider: BaseProvider{
			ProviderType:   config.ProviderType,
			ProviderConfig: config.Config,
		},
	}, nil
}

func checkName(id ResourceID) error {
	if strings.Contains(id.Name, "__") || strings.Contains(id.Variant, "__") {