README

The bundle executes raw SQL queries with the flexibility to embed Twig extensions, enabling the dynamic creation of queries using Twig syntax.

About the bundle

You can use Twig syntax when creating queries.
You place queries in separate files. (Ex: all_media.sql.twig).
Execute your queries using Zjk\SqlTwig\Contract\SqlTwigInterface service.
Result of execution Zjk\SqlTwig\Contract\SqlTwigInterface->executeQuery(..) is instance of Doctrine\DBAL\Driver\Result, use their methods to get results.
Query execution via transaction Zjk\SqlTwig\Contract\SqlTwigInterface->transaction(..)
Create Zjk\SqlTwig\Contract\SqlTwigInterface->registerTempTable(..) and execute Zjk\SqlTwig\Contract\SqlTwigInterface->executeQueryWithTempTable(..) queries with temporary table.

Installation

Add "zjkiza/sql-twig-bundle" to your composer.json file:

composer require zjkiza/sql-twig-bundle

Symfony integration

Bundle wires up all classes together and provides method to easily setup.

<?php

declare(strict_types=1);

return [
    // other bundles
    Zjk\SqlTwig\ZJKizaSqlTwigBundle::class =>  ['all' => true],
];

Working with the bundle

It is necessary to define which directory/directories will be used for storing files with sql queries.

    twig:
      paths:
        '%kernel.project_dir%/src/sql/media': 'media'
        '%kernel.project_dir%/src/sql/expert': 'expert'

Create a sql query. Example (all_media.sql.twig):

   SELECT
       m.id
   {% if true == user  %}
       , u.name as user_name
   {% endif %}
   
   FROM media as m
   
       {% if true == user  %}
           INNER JOIN user as u ON m.user_id = u.id
       {% endif %}
   
   WHERE m.id in (:ids)
   
   ORDER BY m.id

Example (create_temp_table.sql.twig)

CREATE TEMPORARY TABLE IF NOT EXISTS tmp_table
select id from user
where id not in ('787e9568-0ebf-4cd1-825f-063ded2a6588');

Example (execute_with_tmp_table.sql.twig)

SELECT * FROM tmp_table
ORDER BY id ;

Working in php, Example:

namespace App\Example;

use Zjk\SqlTwig\Contract\SqlTwigInterface;

class MyRepository {
    
    private SqlTwigInterface $sqlTwig;
    
    public function __construct(SqlTwigInterface $sqlTwig) 
    {
        $this->sqlTwig = $sqlTwig;
    }
    
    public function allMedia(): array
    {
        return $this->sqlTwig->executeQuery('@media/all_media.sql.twig', [
                'user' => true,
                'ids' => ['60b16643-d5e0-468a-8823-499fcf07684a', '60b16643-d5e0-468a-8823-499fcf07684b'],
               ],[
                 'ids' => ArrayParameterType::STRING,
              ])->fetchAllAssociative()
    }
    
    public function withTransaction(): array
    {
        $result = $this->manager->transaction(
            static fn (SqlTwigInterface $manager): Result => $manager->executeQuery('@query/media_id_title.sql.twig'),
            TransactionIsolationLevel::READ_UNCOMMITTED
        );
        
        return $result->fetchAllAssociative();
    }    
    
    public function withTempTable(): void
    {
        $this->manager->registerTempTable('@query/create_temp_table.sql.twig');

        $response = $this->manager->executeQueryWithTempTable(
            '@query/execute_with_tmp_table.sql.twig'
        )
        
        return $result->fetchAllAssociative();
    }
}

Additional Notes

The $args parameter is passed directly to the Twig template and can be used as dynamic variables inside the SQL query.
The $types parameter defines Doctrine parameter types, compatible with ParameterType and ArrayParameterType.
The $queryPath argument follows the Twig namespace notation (e.g. @media/all_media.sql.twig).
The transaction() method allows query execution within a transaction context, supporting different isolation levels such as READ_COMMITTED, READ_UNCOMMITTED, etc.
When working with temporary tables, you must call registerTempTable() before executing executeQueryWithTempTable().
Each query execution returns a Doctrine\DBAL\Result instance, which provides methods like fetchAllAssociative(), fetchAssociative(), and others for result handling.

zjkiza / sql-twig-bundle

Package info

Security

Statistics