Symfony中如何通过onKernelRequest事件监听器检测对应数据表？

Your Listener Code: #

class BeforeRequestListener {
    /**
     * @var EntityManager
     */
    private $em;

    /**
     * @var SessionInterface
     */
    private $session;

    /**
     * BeforeRequestListener constructor.
     * @param EntityManager $em
     * @param SessionInterface $session
     */
    public function __construct(EntityManager $em, SessionInterface $session) {
        $this->em = $em;
        $this->session = $session;
    }

    /**
     * @param GetResponseEvent $event
     */
    public function onKernelRequest(GetResponseEvent $event) {
        //if() H...
    }
}

Question: #

How can I implement functionality to detect a corresponding database table within the onKernelRequest method of this listener?

Answer #

Great question! Since you already have the EntityManager injected into your listener, you can leverage Doctrine's built-in tools to handle table detection directly in your method. Below are common scenarios and step-by-step implementations:

1. Start with a Master Request Check #

First, it’s best practice to only run this logic for the main application request (skip sub-requests like embedded controllers). Add this check at the top of your method:

public function onKernelRequest(GetResponseEvent $event) {
    // Skip if this isn't the master request
    if (!$event->isMasterRequest()) {
        return;
    }

    // Your table detection logic goes here
}

2. Scenario 1: Verify if a Table Exists #

If you need to check whether a specific table exists in the database, use Doctrine’s SchemaManager:

Option A: Use an Entity Class (Recommended, Doctrine Best Practice)

This approach ties into your application’s entity mapping, avoiding hardcoded table names:

// Replace with your actual entity class (e.g., App\Entity\User)
$entityClass = App\Entity\YourEntity::class;
$metadata = $this->em->getClassMetadata($entityClass);
$tableName = $metadata->getTableName();

$schemaManager = $this->em->getConnection()->createSchemaManager();
$tableExists = $schemaManager->tablesExist([$tableName]);

if ($tableExists) {
    // Table exists - run your logic (e.g., set session flag)
    $this->session->set('target_table_status', 'exists');
} else {
    // Table is missing - handle accordingly
    $this->session->set('target_table_status', 'missing');
}

Option B: Use Raw Table Name (If No Entity Exists)

If you’re working with a table that doesn’t have a corresponding entity, use the raw table name directly:

$tableName = 'your_raw_table_name';
$schemaManager = $this->em->getConnection()->createSchemaManager();
$tableExists = $schemaManager->tablesExist([$tableName]);

// Handle existence status as needed

3. Scenario 2: Check for Data in the Table #

If you need to detect whether the table contains records (or specific entries), use Doctrine’s repository or DQL queries:

Example: Check if the Table Has Any Records

$entityRepository = $this->em->getRepository(App\Entity\YourEntity::class);
$hasRecords = $entityRepository->count([]) > 0;

if ($hasRecords) {
    // Table has data - execute your custom logic
} else {
    // Table is empty
}

Example: Check for a Specific Record

$targetRecord = $entityRepository->findOneBy([
    'your_field' => 'target_value' // Replace with your field and desired value
]);

if ($targetRecord) {
    // Specific record exists
} else {
    // Record not found
}

4. Key Notes for Production #

• Performance: Database calls on every request can add overhead. Consider caching the result (using Symfony’s Cache component) if this logic runs frequently.
• Error Handling: Wrap database operations in try/catch blocks to gracefully handle connection issues or schema errors.

内容的提问来源于stack exchange，提问作者Yamen Nassif