Symfony Database Connection (DBAL Module)

We can use Ecotone's Symfony integration to reuse Connections that are already defined in your Symfony Application.

Using existing Connections [Recommended]

Suppose we already defined connection in our "doctrine.yaml" file:

doctrine:
  dbal:
    connections:
      default:
        url: '%env(resolve:DATABASE_DSN)%'

Then to use it as our Default Connection, we can use Service Context config:

final readonly class EcotoneConfiguration
{
    #[ServiceContext]
    public function dbalConfiguration()
    {
        return SymfonyConnectionReference::defaultConnection('default');
    }
}

Reusing same connection as we use in Application, ensures database transactions will be rolled back correctly in case of any failure. It's all we need to configure. Ecotone will now know to use some_connection as default.

Using Manager Registry

Configuring Dbal Module with Manager Registry allows to make your Entities work as a Ecotone's Aggregates.

Suppose we already defined connection in our "doctrine.yaml" file:

doctrine:
  dbal:
    default_connection: tenant_a_connection
    connections:
      some_connection:
        url: '%env(resolve:DATABASE_DSN)%'
        charset: UTF8
  orm:
    auto_generate_proxy_classes: "%kernel.debug%"
    entity_managers:
      some_orm_connection:
        connection: some_connection
        mappings:
          App:
            is_bundle: false
            type: attribute
            dir: '%kernel.project_dir%/src'
            prefix: 'App'

Then to use it as our Default Connection, we can use Service Context config:

final readonly class EcotoneConfiguration
{
    #[ServiceContext]
    public function dbalConfiguration()
    {
        return SymfonyConnectionReference::defaultManagerRegistry('some_connection');
    }
}

If you use Manager Registry Connection, be aware that "doctrine/orm" package need to be installed. It's all we need to configure. Ecotone will now know to use some_orm_connection as default.

Using DSN

If we don't have existing connection defined, we can make use of DSN directly

Enqueue\Dbal\DbalConnectionFactory:
   class: Enqueue\Dbal\DbalConnectionFactory
   factory: ["Ecotone\Dbal\DbalConnection", "fromDsn"]
   arguments: ["pgsql://user:password@host:5432/db_name"]