@@ -264,8 +264,11 @@ function executeQuery ($SqlStatement, $DBConnectionUID = 'workflow', $aParameter
|
|||||||
$rs = $con->executeUpdate( $SqlStatement );
|
$rs = $con->executeUpdate( $SqlStatement );
|
||||||
$result = $con->getUpdateCount();
|
$result = $con->getUpdateCount();
|
||||||
$con->commit();
|
$con->commit();
|
||||||
//$result = $lastId->getId();
|
break;
|
||||||
// $result = 1;
|
case preg_match( "/^REPLACE\s/i", $statement ):
|
||||||
|
$rs = $con->executeUpdate( $SqlStatement );
|
||||||
|
$result = $con->getUpdateCount();
|
||||||
|
$con->commit();
|
||||||
break;
|
break;
|
||||||
case preg_match( "/^UPDATE\s/i", $statement ):
|
case preg_match( "/^UPDATE\s/i", $statement ):
|
||||||
$rs = $con->executeUpdate( $SqlStatement );
|
$rs = $con->executeUpdate( $SqlStatement );
|
||||||
|
|||||||
@@ -692,7 +692,7 @@ class pmTablesProxy extends HttpProxyController
|
|||||||
$sErrorMessages = '';
|
$sErrorMessages = '';
|
||||||
$i = 1;
|
$i = 1;
|
||||||
$conData = 0;
|
$conData = 0;
|
||||||
$insert = 'INSERT INTO ' . $aAdditionalTables['ADD_TAB_NAME'] . ' (';
|
$insert = 'REPLACE INTO ' . $aAdditionalTables['ADD_TAB_NAME'] . ' (';
|
||||||
$query = '';
|
$query = '';
|
||||||
$swHead = false;
|
$swHead = false;
|
||||||
while (($aAux = fgetcsv( $oFile, 4096, $_POST['form']['CSV_DELIMITER'] )) !== false) {
|
while (($aAux = fgetcsv( $oFile, 4096, $_POST['form']['CSV_DELIMITER'] )) !== false) {
|
||||||
|
|||||||
Reference in New Issue
Block a user