src/PaaBundle/Component/Connection/ConnectionWrapper.php line 59

Open in your IDE?
  1. <?php
  3. /*
  4.  * To change this license header, choose License Headers in Project Properties.
  5.  * To change this template file, choose Tools | Templates
  6.  * and open the template in the editor.
  7.  */
  9. namespace App\PaaBundle\Component\Connection;
  11. use PDO;
  12. use App\Limoog\PartageBundle\Component\cParametresBDD;
  14. class ConnectionWrapper extends \Doctrine\DBAL\Connection {
  15.     /**
  16.      * {@inheritDoc}
  17.      */
  18.     private $bConnectedToPAA = 0;
  20.     // Les paramètres transmis par Symfony au constructeur, début
  21.     private $params ;
  22.     private $driver ;
  23.     private $config ;
  24.     private $eventManager ;
  25.     // Les paramètres transmis par Symfony au constructeur, fin
  27.     private $container ;
  28.     private $DBName ;
  29.     
  30.     /**
  31.      * Initializes a new instance of the Connection class.
  32.      *
  33.      * @param array                              $params       The connection parameters.
  34.      * @param \Doctrine\DBAL\Driver              $driver       The driver to use.
  35.      * @param \Doctrine\DBAL\Configuration|null  $config       The configuration, optional.
  36.      * @param \Doctrine\Common\EventManager|null $eventManager The event manager, optional.
  37.      *
  38.      * @throws \Doctrine\DBAL\DBALException
  39.      */
  40.     public function __construct(array $params, \Doctrine\DBAL\Driver $driver, \Doctrine\DBAL\Configuration $config = null, \Doctrine\Common\EventManager $eventManager = null) {
  41.         // LG 20200630 : rien n'est fait ici, mais dans le Initialise, qui est appellé après le setContainer, lequel est nécessaire pour connaitre sur quelle BDD travailler
  42.         // (appel préparé dans \applicationPAA_S4\src\Kernel.php, méthode process)
  43.         $this->params = $params ;
  44.         $this->driver = $driver ;
  45.         $this->config = $config ;
  46.         $this->eventManager = $eventManager ;
  48.         parent::__construct($this->params, $this->driver, $this->config, $this->eventManager);        
  49.         
  50.     }
  51.     
  52.     /**
  53.      * Méthode appellée par \applicationPAA_S4\src\Kernel.php, méthode process
  54.      * @param Container $container
  55.      */
  56.     public function setContainer(\Symfony\Component\DependencyInjection\Container $container)
  57.     {
  58.         $this->container = $container;
  59.         $this->DBName = $container->get('session')->get('DBName', "default") ;
  60.         return ;
  61.     }
  62.     
  63.     /**
  64.      * Effectue l'initialisation, une fois qu'on a reçu le container et qu'on connait la BDD sur laquelle travailler
  65.      * Méthode appellée par \applicationPAA_S4\src\Kernel.php, méthode process
  66.      *
  67.      * @param array                              $params       The connection parameters.
  68.      * @param \Doctrine\DBAL\Driver              $driver       The driver to use.
  69.      * @param \Doctrine\DBAL\Configuration|null  $config       The configuration, optional.
  70.      * @param \Doctrine\Common\EventManager|null $eventManager The event manager, optional.
  71.      *
  72.      * @throws \Doctrine\DBAL\DBALException
  73.      */
  74.     public function initialise() {
  75. if ($this->params['dbname'] === "ORT_50") {
  76.     $toto = "toto" ;
  77. }
  78.             
  79. //        $URL = $this->params['host'];
  80. //// $URL = "51.15.181.176" ;
  81. //        $port = $this->params['port'] ;
  82. //        $dbname = $this->params['dbname'] ;
  83. //        $user = $this->params['user'] ;
  84. //        $pwd = $this->params['password'] ;
  85. //        $driver = str_replace('pdo_', '', $this->params['driver']) ;
  86.         $suffixe = ($this->DBName=="default") ? "" : "_" . $this->DBName ;
  88.         // $driver = str_replace('pdo_', '', getenv('doctrine_database_driver' . $suffixe)) ; OLD JM 20220425 
  89.         $driver = str_replace('pdo_', '', lg_getenv('doctrine_database_driver' . $suffixe)) ;
  90.         // $URL = getenv('doctrine_database_host' . $suffixe)    ; OLD JM 20220425 
  91.         $URL = lg_getenv('doctrine_database_host' . $suffixe)    ;
  92.         // $port = getenv('doctrine_database_port' . $suffixe) ; OLD JM 20220425 
  93.         $port = lg_getenv('doctrine_database_port' . $suffixe) ;
  94.         // $dbname = getenv('doctrine_database_name' . $suffixe) ; OLD JM 20220425 
  95.         $dbname = lg_getenv('doctrine_database_name' . $suffixe) ;
  96.         // $user = getenv('doctrine_database_user' . $suffixe) ; OLD JM 20220425 
  97.         $user = lg_getenv('doctrine_database_user' . $suffixe) ;
  98.         // $pwd = getenv('doctrine_database_password' . $suffixe) ; OLD JM 20220425 
  99.         $pwd = lg_getenv('doctrine_database_password' . $suffixe) ;
  100.         
  101.         $this->params['host'] = $URL ;
  102.         $this->params['port'] = $port ;
  103.         $this->params['dbname'] = $dbname ;
  104.         $this->params['user'] = $user ;
  105.         $this->params['password'] = $pwd ;
  106.         
  107.         // Ouvrir une connexion persistante
  108.         $lsCnxnString = $driver . ":"
  109.                 . "host=" . $URL . ";"
  110.                 . "port=" . $port . ";"
  111.                 . "dbname=" . $dbname . ";" ;
  112.         
  113. // Ces fichiers de log seront créés dans le dossier web (sur le serveur : "/ort-sup/web")
  114. // file_put_contents('cnxnString.txt', $lsCnxnString, FILE_APPEND);
  115. // error_log($lsCnxnString, 3, 'cnxnString2.txt');
  116. // throw new \Exception("cnxnString = " . $lsCnxnString . "|user=".$params['user']."|password=".$params['password'] . "|path=".getcwd()) ;
  118. // LG 20200807 début : host, port, dbname sont vides ?
  119. if (!$driver) {
  120. // MG Modification 20200831 Début
  121. // Le echo pose problème avec les réponses en JSON
  122. //    echo "Erreur d'accès aux variables d'environnement lors de l'initialisation de la base de données<br>" ;
  123. // MG Modification 20200831 Fin
  124. //    echo "lsCnxnString = " . $lsCnxnString . "|<br>" ;
  125. //    echo "driver = " . $driver . "|<br>" ;
  126. //    echo "this->DBName = " . $this->DBName . "|<br>" ;
  127. //    echo "suffixe = " . $suffixe . "|<br>" ;
  128. //    echo "getenv('doctrine_database_driver') = " . getenv('doctrine_database_driver') . "|<br>" ;
  129. //    echo "getenv('doctrine_database_driver' . suffixe) = " . getenv('doctrine_database_driver' . $suffixe) . "|<br>" ;
  131.     $logger = new \App\PaaBundle\Component\MyLogger('onNotifieAction');
  132.     $idLog = $logger->Log("Erreur d'accès aux variables d'environnement lors de l'initialisation de la base de données", "info", array(), true);
  133.     
  134. //     throw new \Exception("le driver n'a pas été retrouvé !") ;
  136.     // Cela semble se produire dans des contextes où la connexion n'est pas utilisée
  137.     // Donc, faire un simple return semble suffire à résoudre le problème
  138.     return ;
  139. }
  140. // LG 20221108 old : PERSISTENT fait que des connexions restent ouvetes à totr sur pgAdmin        $loPDO = new PDO($lsCnxnString, $user, $pwd, array(PDO::ATTR_PERSISTENT => true));
  141.         $loPDO = new PDO($lsCnxnString, $user, $pwd, array());
  142.         $params['pdo'] = $loPDO;
  143.         $params['pdo']->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
  144.         $params['driver'] = 'pdo_' . $params['pdo']->getAttribute(\PDO::ATTR_DRIVER_NAME);
  146.         parent::__construct($this->params, $this->driver, $this->config, $this->eventManager);
  147.         return ;
  148.     }    
  150.     public function connect() {
  151.         // Appel à la procédure parente
  152.         $lvConnected = parent::connect();
  154.         // Effectuer l'identification sous Postgres dès l'ouverture de la connexion
  155.         // Rend obsolète D:\Luc\Dev\DevWeb\Symfony\applicationPAA\src\PaaBundle\Component\EventListener\AVirer_PostConnectionListener.php ?
  156.         if ($this->isConnected() && !$this->bConnectedToPAA) {
  157.             // 1ere connexion : initialiser les éléments PAA
  158. //            $lsVersionPAA = "test" ;
  159. //            $liUser = "Null" ;
  160. //            $liMachine = "Null" ;
  161. //            $sql = "Select Paa.InitConnexionPaa('$lsVersionPAA', $liUser, $liMachine) As lOK" ;
  162. //            $this->_conn->query($sql) ;
  163.             $this->InitConnexionPaa(/* $this->_conn */);
  164.         }
  165.         return $lvConnected;
  166.     }
  168.     public function InitConnexionPaa($psVersionPAA = null, $piUser = null, $piMachine = null) {
  169.         // 1ere connexion : initialiser les éléments PAA
  170.         // $user = $security->getUser();
  171.         // $poPDOConnexion = $poPDOConnexion?$poPDOConnexion:$this->_conn ;
  172.         $lsVersionPAA = $psVersionPAA ? $psVersionPAA : (isset($_SESSION["gsVersionPAA"]) ? $_SESSION["gsVersionPAA"] : "Anonyme");
  174.         $liUser = $piUser ? $piUser : (isset($_SESSION["giUser"]) ? $_SESSION["giUser"] : "Null");
  175.         if ($piMachine) {
  176.             
  177.         } else if (isset($_SESSION["giMachine"])) {
  178.             $liMachine = $_SESSION["giMachine"];
  179.         } else {
  180.             // L'Id de machine n'est pas encore défini : il faut e rechercher maintenent
  181.             $loParamètresBDD = new cParametresBDD($this);
  182.             $liMachine = $loParamètresBDD->rtvIdMachineByName(strtoupper(gethostname()));
  183.             $_SESSION["giMachine"] = $liMachine;
  184.         }
  185.         $liMachine = $piMachine ? $piMachine : (isset($_SESSION["giMachine"]) ? $_SESSION["giMachine"] : "Null");
  187.         // Indiquer à Postgres le nom de l'application qui est connectée (selon code VFP)
  188. // LG 20221108 début
  189. // Textmerge("set application_name to '<<m._appli>>';"))
  190.         $sql = "set application_name to 'PAA$lsVersionPAA'";
  191.         $this->_conn->query($sql);        
  192. // LG 20221108 fin
  194.         $sql = "Select Paa.InitConnexionPaa('$lsVersionPAA', $liUser, $liMachine) As lOK";
  195.         $this->_conn->query($sql);
  196.         $this->bConnectedToPAA = 1;
  197.     }
  199.     // $psSQL : requête SQL
  200.     public function rtvSQLResult($psSQL, $psFld = "", $pvDftValue = null, &$pbFound = true) {
  201.         $loCur = $this->_conn->query(utf8_encode($psSQL), PDO::FETCH_ASSOC);
  202.         $loRec = $loCur->fetch(PDO::FETCH_ASSOC);
  203.         if ($loCur->rowCount() < 1) {
  204.             $pbFound = false;
  205.             $lvResultat = $pvDftValue;
  206.         } else {
  207.             if ($psFld) {
  208.                 // On a fourni le nom du champ
  209.                 $lvResultat = $loRec[$psFld];
  210.             } else {
  211.                 // On prend la 1ere colonne
  212.                 $loRec = array_values($loRec);
  213.                 $lvResultat = $loRec[0];
  214.             }
  215.         }
  216.         return $lvResultat;
  217.     }
  219. }