fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

PMCORE-1841

Browse Source
This commit is contained in:
Paula Quispe
2020-07-13 12:15:54 -04:00
parent 7869e8b9d5
commit 3544274ed9
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
workflow/engine/classes/Processes.php
View File

@@ -3417,24 +3417,26 @@ class Processes
/** /**
* Get DB Connections Rows for a Process * Get DB Connections Rows for a Process
* *
* @param array $sProUid * @param string $proUid
* @return array $aConnections * @return array $connections
*/ */
public function getDBConnectionsRows($sProUid) public function getDBConnectionsRows($proUid)
{ {
try { try {
$aConnections = array(); $connections = [];
$oCriteria = new Criteria('workflow'); $criteria = new Criteria('workflow');
$oCriteria->add(DbSourcePeer::PRO_UID, $sProUid); $criteria->add(DbSourcePeer::PRO_UID, $proUid);
$oDataset = DbSourcePeer::doSelectRS($oCriteria); $dataset = DbSourcePeer::doSelectRS($criteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC); $dataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next(); $dataset->next();
while ($aRow = $oDataset->getRow()) { while ($row = $dataset->getRow()) {
$oConnection = new DbSource(); $connection = new DbSource();
$aConnections[] = $oConnection->Load($aRow['DBS_UID'], $aRow['PRO_UID']); $infoConnection = $connection->Load($row['DBS_UID'], $row['PRO_UID']);
$oDataset->next(); unset($infoConnection['DBS_ID']);
$connections[] = $infoConnection;
$dataset->next();
} }
return $aConnections; return $connections;
} catch (Exception $oError) { } catch (Exception $oError) {
throw $oError; throw $oError;
} }