From 4d00bfca0b74f3776c2676313ab3bac7789a502e Mon Sep 17 00:00:00 2001
From: Daniel Badura <daniel.badura@patchlevel.de>
Date: Sat, 18 Jul 2026 16:23:57 +0200
Subject: [PATCH] Add `ProvideDbalConnection` interface for better access on
 the `connection` methods

---
 src/Store/Dbal/ProvideDbalConnection.php | 12 ++++++++++++
 src/Store/StreamDoctrineDbalStore.php    |  3 ++-
 src/Store/TaggableDoctrineDbalStore.php  |  3 ++-
 3 files changed, 16 insertions(+), 2 deletions(-)
 create mode 100644 src/Store/Dbal/ProvideDbalConnection.php

diff --git a/src/Store/Dbal/ProvideDbalConnection.php b/src/Store/Dbal/ProvideDbalConnection.php
new file mode 100644
index 00000000..5dbb8964
--- /dev/null
+++ b/src/Store/Dbal/ProvideDbalConnection.php
@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\EventSourcing\Store\Dbal;
+
+use Doctrine\DBAL\Connection;
+
+interface ProvideDbalConnection
+{
+    public function connection(): Connection;
+}
diff --git a/src/Store/StreamDoctrineDbalStore.php b/src/Store/StreamDoctrineDbalStore.php
index d5ca0324..2225935e 100644
--- a/src/Store/StreamDoctrineDbalStore.php
+++ b/src/Store/StreamDoctrineDbalStore.php
@@ -38,6 +38,7 @@
 use Patchlevel\EventSourcing\Store\Criteria\StreamCriterion;
 use Patchlevel\EventSourcing\Store\Criteria\ToIndexCriterion;
 use Patchlevel\EventSourcing\Store\Criteria\ToPlayheadCriterion;
+use Patchlevel\EventSourcing\Store\Dbal\ProvideDbalConnection;
 use Patchlevel\EventSourcing\Store\Header\EventIdHeader;
 use Patchlevel\EventSourcing\Store\Header\IndexHeader;
 use Patchlevel\EventSourcing\Store\Header\PlayheadHeader;
@@ -66,7 +67,7 @@
 
 use const PHP_VERSION_ID;
 
-final class StreamDoctrineDbalStore implements Store, SubscriptionStore, DoctrineSchemaConfigurator
+final class StreamDoctrineDbalStore implements Store, SubscriptionStore, DoctrineSchemaConfigurator, ProvideDbalConnection
 {
     /**
      * PostgreSQL has a limit of 65535 parameters in a single query.
diff --git a/src/Store/TaggableDoctrineDbalStore.php b/src/Store/TaggableDoctrineDbalStore.php
index 9a22040b..92de7c48 100644
--- a/src/Store/TaggableDoctrineDbalStore.php
+++ b/src/Store/TaggableDoctrineDbalStore.php
@@ -41,6 +41,7 @@
 use Patchlevel\EventSourcing\Store\Criteria\TagCriterion;
 use Patchlevel\EventSourcing\Store\Criteria\ToIndexCriterion;
 use Patchlevel\EventSourcing\Store\Criteria\ToPlayheadCriterion;
+use Patchlevel\EventSourcing\Store\Dbal\ProvideDbalConnection;
 use Patchlevel\EventSourcing\Store\Header\EventIdHeader;
 use Patchlevel\EventSourcing\Store\Header\IndexHeader;
 use Patchlevel\EventSourcing\Store\Header\PlayheadHeader;
@@ -76,7 +77,7 @@
 use const PHP_VERSION_ID;
 
 /** @experimental */
-final class TaggableDoctrineDbalStore implements Store, AppendStore, SubscriptionStore, DoctrineSchemaConfigurator
+final class TaggableDoctrineDbalStore implements Store, AppendStore, SubscriptionStore, DoctrineSchemaConfigurator, ProvideDbalConnection
 {
     /**
      * PostgreSQL has a limit of 65535 parameters in a single query.