<?

// NOTE : Pour des soucis de compatibilité PHP4/PHP5,
// on garde les noms de fonction OCI8 PHP4


/*
   Function: oracleConnection

   Connexion Oracle

   Paramètres:

      $sidBase - SID de la base
      $user    - Utilisateur Oracle
      $pwd     - Mot de passe Oracle
      $erreur  - Erreur Oracle ou false

   Retour:

      La connexion créée ou false et remplissage des erreurs

*/
function oracleConnection($sidBase, $user, $pwd, &$erreurCode, &$erreurMsg, &$erreurLocalisation) {

  $curConnection = false;

	// Etablissement de la connexion
	
	if (($GLOBALS['USERBD_DDC'] != "") && ($GLOBALS['PWDBD_DDC'] != "")) {
		$user = $GLOBALS['USERBD_DDC'];
		$pwd = $GLOBALS['PWDBD_DDC'];
	}
	$numTest = 0;
	if($GLOBALS['USE_PERSISTENT']){
    //$curConnection = @ociplogon($user, $pwd, $sidBase);
    while($numTest < 3 && ! $curConnection){
		 		$curConnection = @ociplogon($user, $pwd, $sidBase);
		 		$numTest++;
		 		if($curConnection){
		 			continue;
		 		}
		 		usleep(rand( 100  , 500));
		}
  } else {
    //$curConnection = @ocilogon($user, $pwd, $sidBase);
    while($numTest < 3 && ! $curConnection){
		 		$curConnection = @ocilogon($user, $pwd, $sidBase);
		 		$numTest++;
		 		if($curConnection){
		 			continue;
		 		}
		 		usleep(rand( 500  , 1000));
		}
  }
  
  // En cas d'erreur
	if (!$curConnection) {
    $erreurMsg = ocierror();
    error_log(print_r(array($user, $pwd, $sidBase), true));
  	if ($erreurMsg) {
      $erreurMsg = $erreurMsg['message'];
      $erreurLocalisation = __FILE__.':'.__LINE__;
    	$erreurCode         = "Erreur Oracle : ".$sidBase;
    	error_log($erreurMsg);
    }
	}
	return $curConnection;
}

/*
   Function: oracleDeconnection

   Connexion Oracle

   Paramètres:

      $connexion - L'objet de la connexion Oracle 

   Retour:

      Vrai ou Faux selon que la connexion s'est bien passée ou pas

*/
function oracleDeconnection($connexion) {

  if (ocilogoff($connexion)) {
		return true;
	} else {
		return false;
	}
  
}

/*
   Function: createTempCLOB

   Création d'un CLOB temporaire

   Paramètres:

      $connexion - L'objet de la connexion Oracle 
      $clobvide  - Clob à initialiser
      $idclob    - Identifiant du clob créé

*/
function createTempCLOB($connexion, &$clobvide, &$idclob) {

  $coderr = 0;
  $liberr = 0;

  // Exécution de la procédure stockée
  $res = OCIParse($connexion, "begin pk_majclob.CLOB_Init(:clobVide, :idclob, :coderr, :liberr); end;");

  OCIBindByName($res, ":clobVide", $clobvide, -1, OCI_B_CLOB);
  OCIBindByName($res, ":idclob", $idclob, 32767);
  OCIBindByName($res, ":coderr", $coderr, -1);
  OCIBindByName($res, ":liberr", $liberr, 32767); 

  if(!OCIExecute($res, OCI_DEFAULT)) {
    $err        = ocierror($res);
    error_log(print_r($err,true));
  }

}

/*
   Function: createTempCLOB

   Suppression d'un CLOB temporaire

   Paramètres:

      $connexion - L'objet de la connexion Oracle 
      $clob      - Clob à supprimer
      $idclob    - Identifiant du clob 

*/
function dropTempCLOB($connexion, $clob, $idclob) {

  // Exécution de la procédure stockée
  $res = OCIParse($connexion, "begin pk_majclob.CLOB_RAZ(:clob, :idclob, :coderr, :liberr); end;");

  OCIBindByName($res, ":clob",   $clob,   -1, OCI_B_CLOB);
  OCIBindByName($res, ":idclob", $idclob, 32767);
  OCIBindByName($res, ":coderr", $coderr, -1);
  OCIBindByName($res, ":liberr", $liberr, 32767); 

  if(!OCIExecute($res, OCI_DEFAULT)) {
    $err        = ocierror($res);
    error_log(print_r($err,true));
  }

}

/*
   Function: executePLSQL

   Exécution d'une chaine PLSQL avec les bindings donnés

   Paramètres:

      $connection    - Handle de connexion à la BD
      $requete       - Chaine PL/SQL à lancer
      $tabParams     - Tableau des paramètres (format ':nomParametre')
      $tabValeurs    - Tableau des valeurs modifié avec les paramètres out (&)
      $erreurCode    - Code erreur le cas échéant
      $erreur        - Message d'erreur le cas échéant

   Retour:

      true si OK, false en cas d'erreur

*/
function executePLSQL($connection, $requete, $tabParams, &$tabValeurs, &$erreurCode, &$erreur) {

    // Parse la requête
		$res = OCIParse($connection, $requete);

		if (!$res) { // Cas d'une erreur pendant l'exécution de la requête
			$err        = ocierror($connection);
			$erreurCode = 'ORACLE_PARSE';
			$erreur     = texteErreur('ORACLE_PARSE').' '.$err['message'];
			error_log($erreur);
			return false;
		}
    // Bindings
    for ($i=0; $i < count($tabParams); $i++) {
      OCIBindByName($res, $tabParams[$i], $tabValeurs[$i], 32767);
    }
    //error_log($requete);
    //error_log(print_r($tabValeurs,true));
		//error_log(print_r($tabParams,true));
		// Exécution
		if(!OCIExecute($res)) {
			$err        = ocierror($res);
			$erreurCode = 'ORACLE_PARSE';
			$erreur     = texteErreur('ORACLE_PARSE').' '.$err['message'];
			error_log($erreur);
			return false;
		}
		ocifreestatement($res); // Libération du résultat
		//error_log("OCI:true");
		$commit = ocicommit($connection);
		//error_log("OCIcommit:".$commit);
    return true;
}

function executePLSQLClob($connection, $requete, $tabParams, &$tabValeurs, $tabClob, &$erreurCode, &$erreur) {
//error_log(print_r($tabValeurs,true));
    // Parse la requête
		$res = OCIParse($connection, $requete);

		if (!$res) { // Cas d'une erreur pendant l'exécution de la requête
			$err        = ocierror($connection);
			$erreurCode = 'ORACLE_PARSE';
			$erreur     = texteErreur('ORACLE_PARSE').' '.$err['message'];
			error_log($erreur);
			return false;
		}
		$clobs = array();
		$clobs_id = array();
		// Bindings
    for ($i=0; $i < count($tabParams); $i++) {
    	if(isset($tabClob[$i]) && $tabClob[$i] == true){
    		$clobs[$i]= ocinewdescriptor($connection, OCI_D_LOB);
    		createTempCLOB($connection, $clobs[$i], $clobs_id[$i]);
//    		if($tabValeurs[$i] == ""){// || !(isset($tabValeurs[$i])){
//    			$tabValeurs[$i] = " ";
//    		}
/*    		if($tabValeurs[$i] == ""){
    			$tabValeurs[$i] = str_pad("", 300000, " ");
    		}*/
    		if($tabValeurs[$i] != ""){
    			$clobs[$i]->WriteTemporary($tabValeurs[$i], /*OCI_B_CLOB*/OCI_TEMP_CLOB);
//    			error_log("tv[".$i."]:".$tabValeurs[$i]);
    		}
    		OCIBindByName($res, $tabParams[$i], $clobs[$i], -1, OCI_B_CLOB/*SQLT_CLOB*/);
    	}else{
      	OCIBindByName($res, $tabParams[$i], $tabValeurs[$i], 32767);
      }
    }
  
    //error_log($requete);
    //error_log(print_r($tabValeurs,true));
		//error_log(print_r($tabParams,true));
		// Exécution
		if(!OCIExecute($res, OCI_DEFAULT)) {
			$err        = ocierror($res);
			$erreurCode = 'ORACLE_PARSE';
			$erreur     = texteErreur('ORACLE_PARSE').' '.$err['message'];
			error_log($erreur);
			$ret = false;
		}else{
			$ret = true;
		}
		for ($i=0; $i < count($tabParams); $i++) {
			if(isset($tabClob[$i]) && $tabClob[$i] == true){
				/*while($buf = $clobs[$i]->read(4096)){
					$tabValeurs[$i] .= $buf;
					//error_log($buf);
				}*/
				$tabValeurs[$i] = $clobs[$i]->load();
				$tabValeurs[$i] = trim($tabValeurs[$i]);
				error_log("$i:".$tabValeurs[$i]);
				dropTempCLOB($connexion, $clobs[$i], $clobs_id[$i]);
    		$clobs[$i]->close();
 				$clobs[$i]->free();
 			}
 		}
		ocifreestatement($res); // Libération du résultat
		//error_log("OCI:true");
		$commit = ocicommit($connection);
		if (!$commit) {
        $error = ocierror($connection);
        error_log('Validation échouée. ' . $error['message']);
    }
		//error_log("OCIcommit:".$commit);
    return $ret;
}
?>