1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
| try
{
$this->refPPP = CSVImport::startPPP(); //connexion
CSVImport::startTransaction(); //on lance la transaction avant la boucle
$buffer= 4096;
while (($line_csv = fgetcsv(CSVParser::getHandle(), $buffer, CSVParser::getSeparator(),
CSVParser::getEnclosure(),"")) !== false) {
...
switch (CSVParser::getCSVType())
{
case "license":
// analyses
self::createLicensesObjects();
$this->errors = Record::analyze_license($this->refTableLicense);
//on effectue les analyses. Si une
// erreur est détectée, on renseigne la chaîne des erreurs ($this->errors)
if (Record::getLastError() == "no error")
{
CSVImport::putInDBLicense($this->refTableLicense,
$this->refPPP);
}
break;
...
} // fin du switch
} //fin de la boucle
CSVImport::commit(); //on fait le commit en fin de boucle
} // fin du try
catch (\Exception $e) {
} |