Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public function getJournalRecordsForPeriod($dateStart, $dateEnd, Connection $logsDbConnection, Connection $dbConnection)
- {
- $dbConnection->exec("
- SELECT dblink_connect_u(
- 'journal_records_download_connection',
- 'host = {$logsDbConnection->getHost()}
- user={$logsDbConnection->getUsername()}
- password={$logsDbConnection->getPassword()}
- dbname={$logsDbConnection->getDatabase()}'
- )
- ");
- $sql = <<<SQL
- WITH child_journal_records AS (
- SELECT cj.journal_record_id
- FROM journal.child_journal_house_quality_control cj
- WHERE cj.created_at >=$dateStart AND cj.created_at <=$dateEnd
- ) SELECT *
- FROM (
- journal_records_download_connection,
- SELECT *
- FROM journal.journal_record jr
- WHERE jr.id IN child_journal_records
- )
- SQL;
- $result = $dbConnection->fetchAll($sql);
- $dbConnection->exec("SELECT dblink_disconnect('journal_records_download_connection')");
- }
- }
Add Comment
Please, Sign In to add comment