diff --git a/workflow/engine/methods/dbConnections/dbConnections.php b/workflow/engine/methods/dbConnections/dbConnections.php index 64fa19c55..daddea165 100755 --- a/workflow/engine/methods/dbConnections/dbConnections.php +++ b/workflow/engine/methods/dbConnections/dbConnections.php @@ -1,4 +1,5 @@ . + * along with this program. If not, see . * * For more information, contact Colosa Inc, 2566 Le Jeune Rd., * Coral Gables, FL, 33134, USA, or email info@colosa.com. - * */ /* global $RBAC; @@ -44,34 +44,35 @@ $G_ID_MENU_SELECTED = 'PROCESSES'; $G_ID_SUB_MENU_SELECTED = 'DB_CONNECTIONS'; */ -$G_PUBLISH = new Publisher; +$G_PUBLISH = new Publisher(); -G::LoadClass('processMap'); +G::LoadClass( 'processMap' ); $oProcess = new processMap(); $oCriteria = $oProcess->getConditionProcessList(); -if (ProcessPeer::doCount($oCriteria) > 0) { - $aProcesses = array(); - $aProcesses[] = array('PRO_UID' => 'char', 'PRO_TITLE' => 'char'); - $oDataset = StepPeer::doSelectRS($oCriteria); - $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC); +if (ProcessPeer::doCount( $oCriteria ) > 0) { + $aProcesses = array (); + $aProcesses[] = array ('PRO_UID' => 'char','PRO_TITLE' => 'char' ); + $oDataset = StepPeer::doSelectRS( $oCriteria ); + $oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC ); $oDataset->next(); $sProcessUID = ''; while ($aRow = $oDataset->getRow()) { if ($sProcessUID == '') { $sProcessUID = $aRow['PRO_UID']; } - $aProcesses[] = array('PRO_UID' => $aRow['PRO_UID'], 'PRO_TITLE' => $aRow['PRO_TITLE']); + $aProcesses[] = array ('PRO_UID' => $aRow['PRO_UID'],'PRO_TITLE' => $aRow['PRO_TITLE'] ); $oDataset->next(); } global $_DBArray; $_DBArray['PROCESSES'] = $aProcesses; $_SESSION['_DBArray'] = $_DBArray; - $G_PUBLISH->AddContent('xmlform', 'xmlform', 'dbConnections/dbConnections_Events'); + $G_PUBLISH->AddContent( 'xmlform', 'xmlform', 'dbConnections/dbConnections_Events' ); require_once 'classes/model/DbSource.php'; $oDBSource = new DbSource(); - $oCriteria = $oDBSource->getCriteriaDBSList($sProcessUID); - $G_PUBLISH->AddContent('propeltable', 'paged-table', 'dbConnections/dbConnections', $oCriteria); + $oCriteria = $oDBSource->getCriteriaDBSList( $sProcessUID ); + $G_PUBLISH->AddContent( 'propeltable', 'paged-table', 'dbConnections/dbConnections', $oCriteria ); } else { - $G_PUBLISH->AddContent('xmlform', 'xmlform', 'setup/noProcesses'); + $G_PUBLISH->AddContent( 'xmlform', 'xmlform', 'setup/noProcesses' ); } -G::RenderPage('publish'); +G::RenderPage( 'publish' ); + diff --git a/workflow/engine/methods/dbConnections/dbConnectionsAjax.php b/workflow/engine/methods/dbConnections/dbConnectionsAjax.php index dfb1cb664..861193d88 100755 --- a/workflow/engine/methods/dbConnections/dbConnectionsAjax.php +++ b/workflow/engine/methods/dbConnections/dbConnectionsAjax.php @@ -1,4 +1,5 @@ . + * along with this program. If not, see . * * For more information, contact Colosa Inc, 2566 Le Jeune Rd., * Coral Gables, FL, 33134, USA, or email info@colosa.com. - * */ /* @@ -30,285 +30,260 @@ * @Param var action from POST request */ -if( isset($_POST['action']) || isset($_POST['function']) ){ - $action = (isset($_POST['action']))?$_POST['action']:$_POST['function']; +if (isset( $_POST['action'] ) || isset( $_POST['function'] )) { + $action = (isset( $_POST['action'] )) ? $_POST['action'] : $_POST['function']; } else { - throw new Exception('dbconnections Fatal error, No action defined!...'); + throw new Exception( 'dbconnections Fatal error, No action defined!...' ); } -if(isset($_POST['PROCESS'])) +if (isset( $_POST['PROCESS'] )) { $_SESSION['PROCESS'] = $_POST['PROCESS']; +} -#Global Definitions + #Global Definitions require_once 'classes/model/DbSource.php'; require_once 'classes/model/Content.php'; - -$G_PUBLISH = new Publisher; -G::LoadClass('processMap'); -G::LoadClass('ArrayPeer'); -G::LoadClass ('dbConnections'); + +$G_PUBLISH = new Publisher(); +G::LoadClass( 'processMap' ); +G::LoadClass( 'ArrayPeer' ); +G::LoadClass( 'dbConnections' ); global $_DBArray; -switch ( $action ){ - - case 'loadInfoAssigConnecctionDB': - $oStep = new Step(); - return print ($oStep->loadInfoAssigConnecctionDB($_POST['PRO_UID'],$_POST['DBS_UID'])); - break; - - case 'showDbConnectionsList': +switch ($action) { + case 'loadInfoAssigConnecctionDB': + $oStep = new Step(); + return print ($oStep->loadInfoAssigConnecctionDB( $_POST['PRO_UID'], $_POST['DBS_UID'] )) ; + break; + case 'showDbConnectionsList': + $oProcess = new processMap(); + $oCriteria = $oProcess->getConditionProcessList(); + if (ProcessPeer::doCount( $oCriteria ) > 0) { + $aProcesses = array (); + $aProcesses[] = array ('PRO_UID' => 'char','PRO_TITLE' => 'char' + ); + $oDataset = ArrayBasePeer::doSelectRS( $oCriteria ); + $oDataset->setFetchmode( ResultSet::FETCHMODE_ASSOC ); + $oDataset->next(); + $sProcessUID = ''; + while ($aRow = $oDataset->getRow()) { + if ($sProcessUID == '') { + $sProcessUID = $aRow['PRO_UID']; + } + $aProcesses[] = array ('PRO_UID' => (isset( $aRow['PRO_UID'] ) ? $aRow['PRO_UID'] : ''),'PRO_TITLE' => (isset( $aRow['PRO_TITLE'] ) ? $aRow['PRO_TITLE'] : '') + ); + $oDataset->next(); + } - $oProcess = new processMap(); - $oCriteria = $oProcess->getConditionProcessList(); - if( ProcessPeer::doCount($oCriteria) > 0 ){ - $aProcesses = array(); - $aProcesses[] = array('PRO_UID' => 'char', 'PRO_TITLE' => 'char'); - $oDataset = ArrayBasePeer::doSelectRS($oCriteria); - $oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC); - $oDataset->next(); - $sProcessUID = ''; - while( $aRow = $oDataset->getRow() ){ - if( $sProcessUID == '' ){ - $sProcessUID = $aRow['PRO_UID']; - } - $aProcesses[] = array('PRO_UID' => (isset($aRow['PRO_UID']) ? $aRow['PRO_UID'] : ''), 'PRO_TITLE' => (isset($aRow['PRO_TITLE']) ? $aRow['PRO_TITLE'] : '')); - $oDataset->next(); - } - - $_DBArray['PROCESSES'] = $aProcesses; - $_SESSION['_DBArray'] = $_DBArray; - $_SESSION['PROCESS'] = (isset($_POST['PRO_UID']) ? $_POST['PRO_UID'] : ''); - - $oDBSource = new DbSource(); - $oCriteria = $oDBSource->getCriteriaDBSList($_SESSION['PROCESS']); - $G_PUBLISH->AddContent('propeltable', 'paged-table', 'dbConnections/dbConnections', $oCriteria); - } - G::RenderPage('publish', 'raw'); - break; + $_DBArray['PROCESSES'] = $aProcesses; + $_SESSION['_DBArray'] = $_DBArray; + $_SESSION['PROCESS'] = (isset( $_POST['PRO_UID'] ) ? $_POST['PRO_UID'] : ''); - case 'showConnections': - - $oDBSource = new DbSource(); - $oCriteria = $oDBSource->getCriteriaDBSList($_SESSION['PROCESS']); - $G_PUBLISH = new Publisher(); - $G_PUBLISH->AddContent('propeltable', 'paged-table', 'dbConnections/dbConnections', $oCriteria); - G::RenderPage('publish', 'raw'); - break; + $oDBSource = new DbSource(); + $oCriteria = $oDBSource->getCriteriaDBSList( $_SESSION['PROCESS'] ); + $G_PUBLISH->AddContent( 'propeltable', 'paged-table', 'dbConnections/dbConnections', $oCriteria ); + } + G::RenderPage( 'publish', 'raw' ); + break; + case 'showConnections': + $oDBSource = new DbSource(); + $oCriteria = $oDBSource->getCriteriaDBSList( $_SESSION['PROCESS'] ); + $G_PUBLISH = new Publisher(); + $G_PUBLISH->AddContent( 'propeltable', 'paged-table', 'dbConnections/dbConnections', $oCriteria ); + G::RenderPage( 'publish', 'raw' ); + break; + case 'newDdConnection': + $dbs = new dbConnections( $_SESSION['PROCESS'] ); + $dbServices = $dbs->getDbServicesAvailables(); + $dbService = $dbs->getEncondeList(); - case 'newDdConnection': + //we are updating the passwords with encrupt info + $dbs->encryptThepassw( $_SESSION['PROCESS'] ); + //end updating - - $dbs = new dbConnections($_SESSION['PROCESS']); - $dbServices = $dbs->getDbServicesAvailables(); - $dbService = $dbs->getEncondeList(); - - //we are updating the passwords with encrupt info - $dbs->encryptThepassw($_SESSION['PROCESS']); - //end updating - - $rows[] = array('uid' => 'char', 'name' => 'char'); + $rows[] = array ('uid' => 'char','name' => 'char' + ); - foreach($dbServices as $srv) { - $rows[] = array('uid' => $srv['id'], 'name' => $srv['name']); - } + foreach ($dbServices as $srv) { + $rows[] = array ('uid' => $srv['id'],'name' => $srv['name'] + ); + } - $_DBArray['BDCONNECTIONS'] = $rows; - + $_DBArray['BDCONNECTIONS'] = $rows; - $G_PUBLISH->AddContent('xmlform', 'xmlform', 'dbConnections/dbConnections_New', '', ''); - G::RenderPage('publish', 'raw'); - break; + $G_PUBLISH->AddContent( 'xmlform', 'xmlform', 'dbConnections/dbConnections_New', '', '' ); + G::RenderPage( 'publish', 'raw' ); + break; + case 'editDdConnection': + $dbs = new dbConnections( $_SESSION['PROCESS'] ); + $dbServices = $dbs->getDbServicesAvailables(); - case 'editDdConnection': - - $dbs = new dbConnections($_SESSION['PROCESS']); - $dbServices = $dbs->getDbServicesAvailables(); + $rows[] = array ('uid' => 'char','name' => 'char' + ); + foreach ($dbServices as $srv) { + $rows[] = array ('uid' => $srv['id'],'name' => $srv['name'] + ); + } - $rows[] = array('uid' => 'char', 'name' => 'char'); - foreach($dbServices as $srv) { - $rows[] = array('uid' => $srv['id'], 'name' => $srv['name']); - } + $_DBArray['BDCONNECTIONS'] = $rows; + $_SESSION['_DBArray'] = $_DBArray; - $_DBArray['BDCONNECTIONS'] = $rows; - $_SESSION['_DBArray'] = $_DBArray; + $o = new DbSource(); + $aFields = $o->load( $_POST['DBS_UID'], $_SESSION['PROCESS'] ); + if ($aFields['DBS_PORT'] == '0') { + $aFields['DBS_PORT'] = ''; + } + $aFields['DBS_PASSWORD'] = $dbs->getPassWithoutEncrypt( $aFields ); + $aFields['DBS_PASSWORD'] = ($aFields['DBS_PASSWORD'] == 'none') ? "" : $aFields['DBS_PASSWORD']; + $G_PUBLISH->AddContent( 'xmlform', 'xmlform', 'dbConnections/dbConnections_Edit', '', $aFields ); + G::RenderPage( 'publish', 'raw' ); + break; + case 'saveEditConnection': + $oDBSource = new DbSource(); + $oContent = new Content(); + if (strpos( $_POST['server'], "\\" )) { + $_POST['port'] = 'none'; + } + $aData = Array ('DBS_UID' => $_POST['dbs_uid'],'PRO_UID' => $_SESSION['PROCESS'],'DBS_TYPE' => $_POST['type'],'DBS_SERVER' => $_POST['server'],'DBS_DATABASE_NAME' => $_POST['db_name'],'DBS_USERNAME' => $_POST['user'],'DBS_PASSWORD' => (($_POST['passwd'] == 'none') ? "" : G::encrypt( $_POST['passwd'], $_POST['db_name'] )) . "_2NnV3ujj3w",'DBS_PORT' => (($_POST['port'] == 'none') ? "" : $_POST['port']),'DBS_ENCODE' => $_POST['enc'] + ); - $o = new DbSource(); - $aFields = $o->load($_POST['DBS_UID'], $_SESSION['PROCESS']); - if ($aFields['DBS_PORT'] == '0') { - $aFields['DBS_PORT'] = ''; - } - $aFields['DBS_PASSWORD']=$dbs->getPassWithoutEncrypt($aFields); - $aFields['DBS_PASSWORD']=($aFields['DBS_PASSWORD'] == 'none') ? "": $aFields['DBS_PASSWORD']; - $G_PUBLISH->AddContent('xmlform', 'xmlform', 'dbConnections/dbConnections_Edit', '', $aFields); - G::RenderPage('publish', 'raw'); - break; + $oDBSource->update( $aData ); + $oContent->addContent( 'DBS_DESCRIPTION', '', $_POST['dbs_uid'], SYS_LANG, $_POST['desc'] ); + break; + case 'saveConnection': + $oDBSource = new DbSource(); + $oContent = new Content(); + if (strpos( $_POST['server'], "\\" )) { + $_POST['port'] = 'none'; + } + $aData = Array ('PRO_UID' => $_SESSION['PROCESS'],'DBS_TYPE' => $_POST['type'],'DBS_SERVER' => $_POST['server'],'DBS_DATABASE_NAME' => $_POST['db_name'],'DBS_USERNAME' => $_POST['user'],'DBS_PASSWORD' => (($_POST['passwd'] == 'none') ? "" : G::encrypt( $_POST['passwd'], $_POST['db_name'] )) . "_2NnV3ujj3w",'DBS_PORT' => (($_POST['port'] == 'none') ? "" : $_POST['port']),'DBS_ENCODE' => $_POST['enc'] + ); + $newid = $oDBSource->create( $aData ); + $sDelimiter = DBAdapter::getStringDelimiter(); + $oContent->addContent( 'DBS_DESCRIPTION', '', $newid, SYS_LANG, $_POST['desc'] ); + break; + case 'deleteDbConnection': + try { + $oDBSource = new DbSource(); + $oContent = new Content(); - case 'saveEditConnection': + $DBS_UID = $_POST['dbs_uid']; + $PRO_UID = $_SESSION['PROCESS']; + $oDBSource->remove( $DBS_UID, $PRO_UID ); + $oContent->removeContent( 'DBS_DESCRIPTION', "", $DBS_UID ); + $result->success = true; + $result->msg = G::LoadTranslation( 'ID_DBCONNECTION_REMOVED' ); + } catch (Exception $e) { + $result->success = false; + $result->msg = $e->getMessage(); + } + print G::json_encode( $result ); + break; + case 'showTestConnection': + $G_PUBLISH = new Publisher(); + $G_PUBLISH->AddContent( 'view', 'dbConnections/dbConnections' ); + G::RenderPage( 'publish', 'raw' ); + break; + case 'testConnection': + sleep( 0 ); + $step = $_POST['step']; + $type = $_POST['type']; + $server = $_POST['server']; + $db_name = $_POST['db_name']; + $user = $_POST['user']; + $passwd = ($_POST['passwd'] == 'none') ? "" : $_POST['passwd']; + $port = $_POST['port']; - $oDBSource = new DbSource(); - $oContent = new Content(); - if(strpos($_POST['server'], "\\")) - $_POST['port'] = 'none'; - $aData = Array( - 'DBS_UID' => $_POST['dbs_uid'], - 'PRO_UID' => $_SESSION['PROCESS'], - 'DBS_TYPE' => $_POST['type'], - 'DBS_SERVER' => $_POST['server'], - 'DBS_DATABASE_NAME' => $_POST['db_name'], - 'DBS_USERNAME' => $_POST['user'], - 'DBS_PASSWORD' => (($_POST['passwd'] == 'none') ? "": G::encrypt($_POST['passwd'], $_POST['db_name']))."_2NnV3ujj3w", - 'DBS_PORT' => (($_POST['port'] == 'none') ? "": $_POST['port']), - 'DBS_ENCODE' => $_POST['enc'] - ); + if (($port == 'none') || ($port == 0)) { + //setting defaults ports + switch ($type) { + case 'mysql': + $port = 3306; + break; + case 'pgsql': + $port = 5432; + break; + case 'mssql': + $port = 1433; + break; + case 'oracle': + $port = 1521; + break; + } + } - $oDBSource->update($aData); - $oContent->addContent('DBS_DESCRIPTION', '', $_POST['dbs_uid'], SYS_LANG, $_POST['desc']); + G::LoadClass( 'net' ); + $Server = new NET( $server ); - break; + define( "SUCCESSFULL", 'SUCCESSFULL' ); + define( "FAILED", 'FAILED' ); - case 'saveConnection': + switch ($step) { + case 1: + if ($Server->getErrno() == 0) { + print (SUCCESSFULL . ',') ; + } else { + print (FAILED . ',' . $Server->error) ; + } + break; + case 2: + $Server->scannPort( $port ); + if ($Server->getErrno() == 0) { + print (SUCCESSFULL . ',') ; + } else { + print (FAILED . ',' . $Server->error) ; + } + break; + case 3: + $Server->loginDbServer( $user, $passwd ); + $Server->setDataBase( $db_name, $port ); - $oDBSource = new DbSource(); - $oContent = new Content(); - if(strpos($_POST['server'], "\\")) - $_POST['port'] = 'none'; - $aData = Array( - 'PRO_UID' => $_SESSION['PROCESS'], - 'DBS_TYPE' => $_POST['type'], - 'DBS_SERVER' => $_POST['server'], - 'DBS_DATABASE_NAME' => $_POST['db_name'], - 'DBS_USERNAME' => $_POST['user'], - 'DBS_PASSWORD' => (($_POST['passwd'] == 'none') ? "": G::encrypt($_POST['passwd'], $_POST['db_name']))."_2NnV3ujj3w", - 'DBS_PORT' => (($_POST['port'] == 'none') ? "": $_POST['port']), - 'DBS_ENCODE' => $_POST['enc'] - ); - $newid = $oDBSource->create($aData); - $sDelimiter = DBAdapter::getStringDelimiter(); - $oContent->addContent('DBS_DESCRIPTION', '', $newid, SYS_LANG, $_POST['desc']); + if ($Server->errno == 0) { + $response = $Server->tryConnectServer( $type ); + if ($response->status == 'SUCCESS') { + print (SUCCESSFULL . ',') ; + } else { + print (FAILED . ',' . $Server->error) ; + } + } else { + print (FAILED . ',' . $Server->error) ; + } + break; + case 4: + $Server->loginDbServer( $user, $passwd ); + $Server->setDataBase( $db_name, $port ); + if ($Server->errno == 0) { + $response = $Server->tryConnectServer( $type ); + if ($response->status == 'SUCCESS') { + $response = $Server->tryOpenDataBase( $type ); + if ($response->status == 'SUCCESS') { + print (SUCCESSFULL . ',' . $Server->error) ; + } else { + print (FAILED . ',' . $Server->error) ; + } + } else { + print (FAILED . ',' . $Server->error) ; + } + } else { + print (FAILED . ',' . $Server->error) ; + } + break; + default: + print ('finished') ; + } + break; + case 'showEncodes': + G::LoadThirdParty( 'pear/json', 'class.json' ); + $oJSON = new Services_JSON(); + $engine = $_POST['engine']; - break; + if ($engine != "0") { + $dbs = new dbConnections(); + echo $oJSON->encode( $dbs->getEncondeList( $engine ) ); - case 'deleteDbConnection': - try{ - $oDBSource = new DbSource(); - $oContent = new Content(); - - $DBS_UID = $_POST['dbs_uid']; - $PRO_UID = $_SESSION['PROCESS']; - $oDBSource->remove($DBS_UID, $PRO_UID); - $oContent->removeContent('DBS_DESCRIPTION', "", $DBS_UID); - $result->success = true; - $result->msg = G::LoadTranslation('ID_DBCONNECTION_REMOVED'); - }catch (Exception $e) { - $result->success = false; - $result->msg = $e->getMessage(); - } - print G::json_encode($result); - break; - - case 'showTestConnection': - - $G_PUBLISH = new Publisher; - $G_PUBLISH->AddContent('view', 'dbConnections/dbConnections'); - G::RenderPage('publish', 'raw'); - break; - - case 'testConnection': - sleep(0); - $step = $_POST['step']; - $type = $_POST['type']; - $server = $_POST['server']; - $db_name = $_POST['db_name']; - $user = $_POST['user']; - $passwd = ($_POST['passwd'] == 'none') ? "": $_POST['passwd']; - $port = $_POST['port']; - - if( ($port == 'none') || ($port == 0) ){ - //setting defaults ports - switch ($type){ - case 'mysql': $port = 3306; break; - case 'pgsql': $port = 5432; break; - case 'mssql': $port = 1433; break; - case 'oracle': $port = 1521; break; - } - } - - G::LoadClass('net'); - $Server = new NET($server); - - define("SUCCESSFULL", 'SUCCESSFULL'); - define("FAILED", 'FAILED'); - - switch ($step) { - case 1: - if ($Server->getErrno() == 0) { - print (SUCCESSFULL.','); - } else { - print (FAILED.','.$Server->error); - } - break; - - case 2: - $Server->scannPort($port); - if ($Server->getErrno() == 0) { - print (SUCCESSFULL.','); - } else { - print (FAILED.','.$Server->error); - } - break; - - case 3: - $Server->loginDbServer($user, $passwd); - $Server->setDataBase($db_name, $port); - - if($Server->errno == 0){ - $response = $Server->tryConnectServer($type); - if($response->status == 'SUCCESS') { - print (SUCCESSFULL.','); - } else { - print (FAILED.','.$Server->error); - } - } else { - print (FAILED.','.$Server->error); - } - break; - - case 4: - $Server->loginDbServer($user, $passwd); - $Server->setDataBase($db_name, $port); - if($Server->errno == 0){ - $response = $Server->tryConnectServer($type); - if($response->status == 'SUCCESS') { - $response = $Server->tryOpenDataBase($type); - if($response->status == 'SUCCESS') { - print (SUCCESSFULL.','.$Server->error); - } else { - print (FAILED.','.$Server->error); - } - } else { - print (FAILED.','.$Server->error); - } - } else { - print (FAILED.','.$Server->error); - } - break; - - default: - print('finished'); - } - break; - - case 'showEncodes': - G::LoadThirdParty('pear/json','class.json'); - $oJSON = new Services_JSON(); - $engine = $_POST['engine']; - - if($engine != "0"){ - $dbs = new dbConnections(); - echo $oJSON->encode($dbs->getEncondeList($engine)); - - } else { - echo '[["0","..."]]'; - } - break; + } else { + echo '[["0","..."]]'; + } + break; } + diff --git a/workflow/engine/methods/dbConnections/genericDbConnections.php b/workflow/engine/methods/dbConnections/genericDbConnections.php index 125e08f7e..38332f7cb 100755 --- a/workflow/engine/methods/dbConnections/genericDbConnections.php +++ b/workflow/engine/methods/dbConnections/genericDbConnections.php @@ -1,26 +1,27 @@ - * @Description:This is a additional configuration for load all connections; if exist in a particular proccess - * @Date: 15-05-2008 - */ -if( isset($_SESSION['PROCESS']) ){ - $pro = include (PATH_CORE . "config/databases.php"); - G::LoadClass('dbConnections'); - $oDbConnections = new dbConnections($_SESSION['PROCESS']); - foreach( $oDbConnections->connections as $db ) { - $db['DBS_PASSWORD'] = $oDbConnections->getPassWithoutEncrypt($db); - $dbsPort = ($db['DBS_PORT'] == '') ? ('') : (':'.$db['DBS_PORT']); - $ENCODE = (trim($db['DBS_ENCODE']) == '')? '': '?encoding=' . $db['DBS_ENCODE']; - if(strpos($db['DBS_SERVER'], "\\") && $db['DBS_TYPE'] == 'mssql'){ - $pro['datasources'][$db['DBS_UID']]['connection'] = $db['DBS_TYPE'] . '://' . $db['DBS_USERNAME'] . ':' . $db['DBS_PASSWORD'] . '@' . $db['DBS_SERVER'] . '/' . $db['DBS_DATABASE_NAME'] . $ENCODE; +/** + * Description: This is a additional configuration for load all connections; if exist in a particular proccess + * @Date: 15-05-2008 + * + * @author : Erik Amaru Ortiz + */ +if (isset( $_SESSION['PROCESS'] )) { + $pro = include (PATH_CORE . "config/databases.php"); + G::LoadClass( 'dbConnections' ); + + $oDbConnections = new dbConnections( $_SESSION['PROCESS'] ); + foreach ($oDbConnections->connections as $db) { + $db['DBS_PASSWORD'] = $oDbConnections->getPassWithoutEncrypt( $db ); + $dbsPort = ($db['DBS_PORT'] == '') ? ('') : (':' . $db['DBS_PORT']); + $ENCODE = (trim( $db['DBS_ENCODE'] ) == '') ? '' : '?encoding=' . $db['DBS_ENCODE']; + if (strpos( $db['DBS_SERVER'], "\\" ) && $db['DBS_TYPE'] == 'mssql') { + $pro['datasources'][$db['DBS_UID']]['connection'] = $db['DBS_TYPE'] . '://' . $db['DBS_USERNAME'] . ':' . $db['DBS_PASSWORD'] . '@' . $db['DBS_SERVER'] . '/' . $db['DBS_DATABASE_NAME'] . $ENCODE; } else { - $pro['datasources'][$db['DBS_UID']]['connection'] = $db['DBS_TYPE'] . '://' . $db['DBS_USERNAME'] . ':' . $db['DBS_PASSWORD'] . '@' . $db['DBS_SERVER'] .$dbsPort. '/' . $db['DBS_DATABASE_NAME'] . $ENCODE; + $pro['datasources'][$db['DBS_UID']]['connection'] = $db['DBS_TYPE'] . '://' . $db['DBS_USERNAME'] . ':' . $db['DBS_PASSWORD'] . '@' . $db['DBS_SERVER'] . $dbsPort . '/' . $db['DBS_DATABASE_NAME'] . $ENCODE; } $pro['datasources'][$db['DBS_UID']]['adapter'] = $db['DBS_TYPE']; } return $pro; } -?> diff --git a/workflow/engine/methods/dbConnections/rootDbConnections.php b/workflow/engine/methods/dbConnections/rootDbConnections.php index 0b88cfb16..7fd6fc624 100755 --- a/workflow/engine/methods/dbConnections/rootDbConnections.php +++ b/workflow/engine/methods/dbConnections/rootDbConnections.php @@ -1,21 +1,23 @@ - * @Description:This is a additional configuration for load all connections; if exist in a particular proccess - * @Date: 15-05-2008 + * ription:This is a additional configuration for load all connections; if exist in a particular proccess + * @Date: 15-05-2008 + * + * @author : Erik Amaru Ortiz */ - $dbHash = @explode(SYSTEM_HASH, G::decrypt(HASH_INSTALLATION, SYSTEM_HASH)); - - $host = $dbHash[0]; - $user = $dbHash[1]; - $pass = $dbHash[2]; - $dbName = DB_NAME; - - $pro = include (PATH_CORE . "config/databases.php"); - - $pro['datasources']['root'] = Array (); - $pro['datasources']['root']['connection'] = "mysql://$user:$pass@$host/$dbName?encoding=utf8"; - $pro['datasources']['root']['adapter'] = "mysql"; - - return $pro; +$dbHash = @explode( SYSTEM_HASH, G::decrypt( HASH_INSTALLATION, SYSTEM_HASH ) ); + +$host = $dbHash[0]; +$user = $dbHash[1]; +$pass = $dbHash[2]; +$dbName = DB_NAME; + +$pro = include (PATH_CORE . "config/databases.php"); + +$pro['datasources']['root'] = Array (); +$pro['datasources']['root']['connection'] = "mysql://$user:$pass@$host/$dbName?encoding=utf8"; +$pro['datasources']['root']['adapter'] = "mysql"; + +return $pro; +