<?php 
require_once 'config.php';

$sql = "SELECT name FROM sys.databases WHERE state_desc = 'ONLINE' AND database_id > 4 AND recovery_model_desc = 'FULL';";
$file_list_db = $temp_dir."\\list-db-log.csv";

unlink($file_list_db);

$cmd = 'bcp "'.$sql.'" queryout '.$file_list_db.' -S '.$db_host.','.$db_port.' -U '.$db_user.' -P '.$db_pass.' -c -t, -r\n -k';
//echo $cmd.PHP_EOL;
passthru($cmd);

$handle = fopen($file_list_db, 'r');

if ($handle === false) {
    die("Gagal membuka file list-db-log.");
}
//buat file per job
$list_file = array();
$list_database = array(); 
for($i=1;$i<=$max_job_full;$i++){
	$list_file[$i-1] = $temp_dir."\\job-diff-".$i;
}

while (($data = fgetcsv($handle)) !== false) {
	$data = trim($data[0]);
	$list_database[] = $data;
}
fclose($handle);

unlink($file_list_db);

// membagi file 

shuffle($list_database);

$length = count($list_database);
$part_size = ceil($length / $max_job_full);
$list_database = array_chunk($list_database, $part_size);

for($i=1;$i<=$max_job_full;$i++){
	unlink($list_file[$i-1]);
	
	if(isset($list_database[$i-1]) && count($list_database[$i-1]) > 0) {
	
		$isi_file = implode("\n",$list_database[$i-1]);
		file_put_contents($list_file[$i-1],$isi_file);
		
		$cmd = 'start "" cmd /c "php -f _log.php '.$list_file[$i-1].'"';
		pclose(popen($cmd,"r"));
		
	}
}