Function New

internal/storage/provider.go:180–229

New creates a new database provider based on the configuration

(config *config.Config, deps *Dependencies)

// New creates a new database provider based on the configuration
func New(config *config.Config, deps *Dependencies) (Provider, error) {
	var provider Provider
	var err error
	if config.DatabaseType == "" {
		return nil, fmt.Errorf("database type is required")
	}

	switch config.DatabaseType {
	case constants.DbTypePostgres,
		constants.DbTypeSqlite,
		constants.DbTypeLibSQL,
		constants.DbTypeMysql,
		constants.DbTypeSqlserver,
		constants.DbTypeYugabyte,
		constants.DbTypeMariaDB,
		constants.DbTypeCockroachDB,
		constants.DbTypePlanetScaleDB:
		provider, err = sql.NewProvider(config, &sql.Dependencies{
			Log: deps.Log,
		})
	case constants.DbTypeMongoDB:
		provider, err = mongodb.NewProvider(config, &mongodb.Dependencies{
			Log: deps.Log,
		})
	case constants.DbTypeArangoDB:
		provider, err = arangodb.NewProvider(config, &arangodb.Dependencies{
			Log: deps.Log,
		})
	case constants.DbTypeCassandraDB,
		constants.DbTypeScyllaDB:
		provider, err = cassandradb.NewProvider(config, &cassandradb.Dependencies{
			Log: deps.Log,
		})
	case constants.DbTypeCouchbaseDB:
		provider, err = couchbase.NewProvider(config, &couchbase.Dependencies{
			Log: deps.Log,
		})
	case constants.DbTypeDynamoDB:
		provider, err = dynamodb.NewProvider(config, &dynamodb.Dependencies{
			Log: deps.Log,
		})
	default:
		err = fmt.Errorf("unsupported database type: %s", config.DatabaseType)

	}
	if err != nil {
		return nil, err
	}
	return provider, nil
}