Do not input private or sensitive data. View Qlik Privacy & Cookie Policy.
Skip to main content

Announcements
Qlik Open Lakehouse is Now Generally Available! Discover the key highlights and partner resources here.
cancel
Showing results for 
Search instead for 
Did you mean: 
manzar000
Contributor
Contributor

how to replicate the queries in qlik view the same wriiten in php code..any leads.Thanks

Hi Everyone,

 

 

Kindly help me  replicate the queries in qlik view the same wriiten in php code..any leads.Thanks

 

<?php
 
require_once 'config.php';  
 
try {
$inputFile = $inputFolder."/data_integrity_inputfile.csv";
$currentTime = date("Y_m_d_H_i_s");
if(is_dir($outputFolder) == false)
{
    mkdir($outputFolder);
}
$outputCsv = fopen($outputFolder."/data_integrity_outputfile_".$currentTime.".csv","w");
$file = fopen($inputFile,"r");
$rowFlag = false;
$headers = [];
$result = [];
$sourceConditionDate = '';
$destinationConditionDays = '';
$sourceResult = 0;
$destinationResult = 0;
 
while(! feof($file))
{
  $fileRows = fgetcsv($file);
  if(!$rowFlag){
  fputcsv($outputCsv,$fileRows);
  $rowFlag = true;
  continue;
  }
  $daysToCheck = $fileRows[1];
  $sourceDbName = $fileRows[2];
  $sourceTableName = $fileRows[3];
  $sourceTableColomn = $fileRows[4];
  $sourceConditionColumn = $fileRows[5];
  $queryMethod = $fileRows[6];
  $destinationDbName = $fileRows[7];
  $destinationTableName = $fileRows[8];
  $destinationTableColomn = $fileRows[9];
  $destinationConditionColumn = $fileRows[10];
  $connectionSourceDb = connectDb($sourceDbName);
  $connectionDestinationDb = connectDb($destinationDbName);
  if($sourceConditionColumn == 'created_at' || $sourceConditionColumn == 'updated_at'){
  $sourceConditionDays = date("Y-m-d", strtotime("- $daysToCheck day"));
  }
  if($destinationConditionColumn == 'created_at' || $destinationConditionColumn == 'updated_at'){
  $destinationConditionDays = date("Y-m-d", strtotime("- $daysToCheck day"));
  }
  if($fileRows){
  if($connectionSourceDb){
  $sourceSql = "SELECT $queryMethod($sourceTableColomn) as $queryMethod FROM $sourceTableName WHERE $sourceConditionColumn <= $sourceConditionDays";
  $sourceResult = $connectionSourceDb->query($sourceSql);
  if($sourceResult){
$sourceData=$sourceResult->fetch_assoc();
$sourceResult = $sourceData[$queryMethod];
$fileRows[11] = $sourceResult;
  }
  }
  if($connectionDestinationDb){
  $destinationSql = "SELECT $queryMethod($destinationTableColomn) as $queryMethod FROM $destinationTableName WHERE $destinationConditionColumn <= $destinationConditionDays";
  $destinationResult = $connectionDestinationDb->query($destinationSql);
  if($destinationResult){
  $destinationData = $destinationResult->fetch_assoc();
$destinationResult = $destinationData[$queryMethod];
$fileRows[12] = $destinationResult;
  }
  }
 
  }
  if(is_array($fileRows)){
  $difference = $sourceResult - $destinationResult;
  $fileRows[13] = $difference;
  fputcsv($outputCsv, $fileRows);
  }
 
}
fclose($outputCsv);
fclose($file);
echo "Integrity check completed";
} catch (Exception $e) {
echo $e->getMessage();
}
Labels (1)
  • Other

0 Replies