Advertisement
Guest User

Untitled

a guest
May 23rd, 2017
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 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. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement