Guest User

Untitled

a guest
May 23rd, 2017
26
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
PHP 1.07 KB | None | 0 0
  1.  public function getJournalRecordsForPeriod($dateStart, $dateEnd, Connection $logsDbConnection, Connection $dbConnection)
  2.   {
  3.  
  4.         $dbConnection->exec("
  5.            SELECT dblink_connect_u(
  6.                'journal_records_download_connection',
  7.                'host = {$logsDbConnection->getHost()}
  8.                 user={$logsDbConnection->getUsername()}
  9.                 password={$logsDbConnection->getPassword()}
  10.                 dbname={$logsDbConnection->getDatabase()}'
  11.            )
  12.        ");
  13.  
  14.         $sql = <<<SQL
  15. WITH child_journal_records AS (
  16.     SELECT cj.journal_record_id
  17.     FROM journal.child_journal_house_quality_control cj
  18.     WHERE cj.created_at >=$dateStart AND cj.created_at <=$dateEnd
  19. ) SELECT *
  20.   FROM (
  21.       journal_records_download_connection,
  22.       SELECT *
  23.       FROM journal.journal_record jr
  24.       WHERE jr.id IN child_journal_records
  25.       )        
  26. SQL;
  27.         $result = $dbConnection->fetchAll($sql);
  28.        
  29.         $dbConnection->exec("SELECT dblink_disconnect('journal_records_download_connection')");
  30.  
  31.  
  32.  
  33.     }
  34. }
Add Comment
Please, Sign In to add comment