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

CODE STYLE class.dbConnections.php

Browse Source
This commit is contained in:
Fernando Ontiveros
2012-10-09 12:39:52 -04:00
parent 916d79ea80
commit a339d5ffed
1 changed files with 369 additions and 389 deletions
Download Patch File Download Diff File Expand all files Collapse all files

360
workflow/engine/classes/class.dbConnections.php
View File

@@ -8,7 +8,6 @@
* class.dbConnections.php * class.dbConnections.php
* *
* Email bugs/suggestions to erik@colosa.com * Email bugs/suggestions to erik@colosa.com
*
*/ */
require_once 'model/DbSource.php'; require_once 'model/DbSource.php';
@@ -40,7 +39,7 @@ class dbConnections
* @param string $pPRO_UID * @param string $pPRO_UID
* @return void * @return void
*/ */
public function __construct($pPRO_UID = null) public function __construct ($pPRO_UID = null)
{ {
$this->errno = 0; $this->errno = 0;
$this->errstr = ""; $this->errstr = "";
@@ -54,52 +53,43 @@ class dbConnections
* *
* @return Array $connections * @return Array $connections
*/ */
public function getAllConnections() public function getAllConnections ()
{ {
if( isset($this->PRO_UID) ){ if (isset( $this->PRO_UID )) {
$oDBSource = new DbSource(); $oDBSource = new DbSource();
$oContent = new Content(); $oContent = new Content();
$connections = Array(); $connections = Array ();
$types = Array(); $types = Array ();
$this->have_any_connectios = false; $this->have_any_connectios = false;
$c = new Criteria(); $c = new Criteria();
$c->clearSelectColumns(); $c->clearSelectColumns();
$c->addSelectColumn(DbSourcePeer::DBS_UID); $c->addSelectColumn( DbSourcePeer::DBS_UID );
$c->addSelectColumn(DbSourcePeer::PRO_UID); $c->addSelectColumn( DbSourcePeer::PRO_UID );
$c->addSelectColumn(DbSourcePeer::DBS_TYPE); $c->addSelectColumn( DbSourcePeer::DBS_TYPE );
$c->addSelectColumn(DbSourcePeer::DBS_SERVER); $c->addSelectColumn( DbSourcePeer::DBS_SERVER );
$c->addSelectColumn(DbSourcePeer::DBS_DATABASE_NAME); $c->addSelectColumn( DbSourcePeer::DBS_DATABASE_NAME );
$c->addSelectColumn(DbSourcePeer::DBS_USERNAME); $c->addSelectColumn( DbSourcePeer::DBS_USERNAME );
$c->addSelectColumn(DbSourcePeer::DBS_PASSWORD); $c->addSelectColumn( DbSourcePeer::DBS_PASSWORD );
$c->addSelectColumn(DbSourcePeer::DBS_PORT); $c->addSelectColumn( DbSourcePeer::DBS_PORT );
$c->addSelectColumn(DbSourcePeer::DBS_ENCODE); $c->addSelectColumn( DbSourcePeer::DBS_ENCODE );
$c->addSelectColumn(ContentPeer::CON_VALUE); $c->addSelectColumn( ContentPeer::CON_VALUE );
$c->add(DbSourcePeer::PRO_UID, $this->PRO_UID); $c->add( DbSourcePeer::PRO_UID, $this->PRO_UID );
$c->add(ContentPeer::CON_CATEGORY, 'DBS_DESCRIPTION'); $c->add( ContentPeer::CON_CATEGORY, 'DBS_DESCRIPTION' );
$c->addJoin(DbSourcePeer::DBS_UID, ContentPeer::CON_ID); $c->addJoin( DbSourcePeer::DBS_UID, ContentPeer::CON_ID );
$result = DbSourcePeer::doSelectRS($c); $result = DbSourcePeer::doSelectRS( $c );
$result->next(); $result->next();
$row = $result->getRow(); $row = $result->getRow();
while ($row = $result->getRow()) { while ($row = $result->getRow()) {
$connections[] = Array( $connections[] = Array ('DBS_UID' => $row[0],'DBS_TYPE' => $row[2],'DBS_SERVER' => $row[3],'DBS_DATABASE_NAME' => $row[4],'DBS_USERNAME' => $row[5],'DBS_PASSWORD' => $row[6],'DBS_PORT' => $row[7],'DBS_ENCODE' => $row[8],'CON_VALUE' => $row[9]
'DBS_UID' => $row[0],
'DBS_TYPE' => $row[2],
'DBS_SERVER' => $row[3],
'DBS_DATABASE_NAME' => $row[4],
'DBS_USERNAME' => $row[5],
'DBS_PASSWORD' => $row[6],
'DBS_PORT' => $row[7],
'DBS_ENCODE' => $row[8],
'CON_VALUE' => $row[9],
); );
$result->next(); $result->next();
} }
if(!in_array($row[2], $types)) { if (! in_array( $row[2], $types )) {
$types[] = $row[2]; $types[] = $row[2];
} }
$this->connections = $connections; $this->connections = $connections;
@@ -113,14 +103,15 @@ class dbConnections
* @param string $pType * @param string $pType
* @return Array $connections * @return Array $connections
*/ */
public function getConnections($pType){ public function getConnections ($pType)
$connections = Array(); {
foreach($this->connections as $c){ $connections = Array ();
if(trim($pType) == trim($c['DBS_TYPE'])){ foreach ($this->connections as $c) {
if (trim( $pType ) == trim( $c['DBS_TYPE'] )) {
$connections[] = $c; $connections[] = $c;
} }
} }
if(count($connections) > 0){ if (count( $connections ) > 0) {
return $connections; return $connections;
} else { } else {
return false; return false;
@@ -128,56 +119,51 @@ class dbConnections
} }
/** /**
* getConnectionsProUid * getConnectionsProUid
* *
* @param string $pType * @param string $pType
* @return Array $connections * @return Array $connections
*/ */
public function getConnectionsProUid($pProUid) public function getConnectionsProUid ($pProUid)
{ {
$connections = Array(); $connections = Array ();
$c = new Criteria(); $c = new Criteria();
$c->clearSelectColumns(); $c->clearSelectColumns();
$c->addSelectColumn(DbSourcePeer::DBS_UID); $c->addSelectColumn( DbSourcePeer::DBS_UID );
$c->addSelectColumn(DbSourcePeer::PRO_UID); $c->addSelectColumn( DbSourcePeer::PRO_UID );
$c->addSelectColumn(DbSourcePeer::DBS_TYPE); $c->addSelectColumn( DbSourcePeer::DBS_TYPE );
$c->addSelectColumn(DbSourcePeer::DBS_SERVER); $c->addSelectColumn( DbSourcePeer::DBS_SERVER );
$c->addSelectColumn(DbSourcePeer::DBS_DATABASE_NAME); $c->addSelectColumn( DbSourcePeer::DBS_DATABASE_NAME );
$result = DbSourcePeer::doSelectRS($c); $result = DbSourcePeer::doSelectRS( $c );
$result->next(); $result->next();
$row = $result->getRow(); $row = $result->getRow();
while ($row = $result->getRow()) { while ($row = $result->getRow()) {
if(trim($pProUid) == trim($row[1])){ if (trim( $pProUid ) == trim( $row[1] )) {
$connections[] = Array( $connections[] = Array ('DBS_UID' => $row[0],'DBS_NAME' => '[' . $row[3] . '] ' . $row[2] . ': ' . $row[4]
'DBS_UID' => $row[0],
'DBS_NAME' => '[' . $row[3] . '] ' . $row[2] . ': ' . $row[4]
); );
} }
$result->next(); $result->next();
} }
if(count($connections) > 0){ if (count( $connections ) > 0) {
return $connections; return $connections;
} else { } else {
return Array(); return Array ();
} }
} }
/** /**
* loadAdditionalConnections * loadAdditionalConnections
* *
* @return void * @return void
*/ */
public function loadAdditionalConnections() public function loadAdditionalConnections ()
{ {
PROPEL::Init ( PATH_METHODS.'dbConnections/genericDbConnections.php'); PROPEL::Init( PATH_METHODS . 'dbConnections/genericDbConnections.php' );
} }
/** /**
@@ -185,29 +171,14 @@ class dbConnections
* *
* @return array $servicesAvailables * @return array $servicesAvailables
*/ */
public function getDbServicesAvailables() public function getDbServicesAvailables ()
{ {
$servicesAvailables = Array(); $servicesAvailables = Array ();
$dbServices = Array( $dbServices = Array ('mysql' => Array ('id' => 'mysql','command' => 'mysql_connect','name' => 'MySql'
'mysql' => Array( ),'pgsql' => Array ('id' => 'pgsql','command' => 'pg_connect','name' => 'PostgreSql'
'id' => 'mysql', ),'mssql' => Array ('id' => 'mssql','command' => 'mssql_connect','name' => 'Microsoft SQL Server'
'command' => 'mysql_connect', ),'oracle' => Array ('id' => 'oracle','command' => 'oci_connect','name' => 'Oracle'
'name' => 'MySql'
),
'pgsql' => Array(
'id' => 'pgsql',
'command' => 'pg_connect',
'name' => 'PostgreSql'
),
'mssql' => Array(
'id' => 'mssql',
'command' => 'mssql_connect',
'name' => 'Microsoft SQL Server'),
'oracle'=> Array(
'id' => 'oracle',
'command' => 'oci_connect',
'name' => 'Oracle'
) )
); );
/*, /*,
@@ -223,8 +194,8 @@ class dbConnections
) )
*/ */
foreach($dbServices as $service) { foreach ($dbServices as $service) {
if(@function_exists($service['command'])){ if (@function_exists( $service['command'] )) {
$servicesAvailables[] = $service; $servicesAvailables[] = $service;
} }
} }
@@ -236,7 +207,7 @@ class dbConnections
* *
* @return void * @return void
*/ */
public function showMsg() public function showMsg ()
{ {
if ($this->errno != 0) { if ($this->errno != 0) {
$msg = " $msg = "
@@ -250,7 +221,7 @@ class dbConnections
</div> </div>
</fieldset> </fieldset>
<center>"; <center>";
print ($msg); print ($msg) ;
} }
} }
@@ -260,98 +231,101 @@ class dbConnections
* @param string $engine * @param string $engine
* @return $this->ordx($this->encodesList); * @return $this->ordx($this->encodesList);
*/ */
public function getEncondeList($engine = ''){ public function getEncondeList ($engine = '')
switch( $engine ){ {
switch ($engine) {
default: default:
case 'mysql': case 'mysql':
$encodes = Array( $encodes = Array (Array ('big5','big5 - Big5 Traditional Chinese'
Array('big5', 'big5 - Big5 Traditional Chinese'), ),Array ('dec8','dec8 - DEC West European'
Array('dec8', 'dec8 - DEC West European'), ),Array ('cp850','cp850 - DOS West European'
Array('cp850', 'cp850 - DOS West European'), ),Array ('hp8','hp8 - HP West European'
Array('hp8', 'hp8 - HP West European'), ),Array ('koi8r','koi8r - KOI8-R Relcom Russian'
Array('koi8r', 'koi8r - KOI8-R Relcom Russian'), ),Array ('latin1','latin1 - cp1252 West European'
Array('latin1', 'latin1 - cp1252 West European'), ),Array ('latin2','latin2 - ISO 8859-2 Central European'
Array('latin2', 'latin2 - ISO 8859-2 Central European'), ),Array ('swe7','swe7 - 7bit Swedish'
Array('swe7', 'swe7 - 7bit Swedish'), ),Array ('ascii','ascii - US ASCII'
Array('ascii', 'ascii - US ASCII'), ),Array ('ujis','ujis - EUC-JP Japanese'
Array('ujis', 'ujis - EUC-JP Japanese'), ),Array ('sjis','sjis - Shift-JIS Japanese'
Array('sjis', 'sjis - Shift-JIS Japanese'), ),Array ('hebrew','hebrew - ISO 8859-8 Hebrew'
Array('hebrew', 'hebrew - ISO 8859-8 Hebrew'), ),Array ('tis620','tis620 - TIS620 Thai'
Array('tis620', 'tis620 - TIS620 Thai'), ),Array ('euckr','euckr - EUC-KR Korean'
Array('euckr', 'euckr - EUC-KR Korean'), ),Array ('koi8u','koi8u - KOI8-U Ukrainian'
Array('koi8u', 'koi8u - KOI8-U Ukrainian'), ),Array ('gb2312','gb2312 - GB2312 Simplified Chinese'
Array('gb2312', 'gb2312 - GB2312 Simplified Chinese'), ),Array ('greek','greek - ISO 8859-7 Greek'
Array('greek', 'greek - ISO 8859-7 Greek'), ),Array ('cp1250','cp1250 - Windows Central European'
Array('cp1250', 'cp1250 - Windows Central European'), ),Array ('gbk','gbk - GBK Simplified Chinese'
Array('gbk', 'gbk - GBK Simplified Chinese'), ),Array ('latin5','latin5 - ISO 8859-9 Turkish'
Array('latin5', 'latin5 - ISO 8859-9 Turkish'), ),Array ('armscii8','armscii8 - ARMSCII-8 Armenian'
Array('armscii8', 'armscii8 - ARMSCII-8 Armenian'), ),Array ('utf8','utf8 - UTF-8 Unicode'
Array('utf8', 'utf8 - UTF-8 Unicode'), ),Array ('ucs2','ucs2 - UCS-2 Unicode'
Array('ucs2', 'ucs2 - UCS-2 Unicode'), ),Array ('cp866','cp866 - DOS Russian'
Array('cp866', 'cp866 - DOS Russian'), ),Array ('keybcs2','keybcs2 - DOS Kamenicky Czech-Slovak'
Array('keybcs2', 'keybcs2 - DOS Kamenicky Czech-Slovak'), ),Array ('macce','macce - Mac Central European'
Array('macce', 'macce - Mac Central European'), ),Array ('macroman','macroman - Mac West European'
Array('macroman', 'macroman - Mac West European'), ),Array ('cp852','cp852 - DOS Central European'
Array('cp852', 'cp852 - DOS Central European'), ),Array ('latin7','atin7 - ISO 8859-13 Baltic'
Array('latin7', 'atin7 - ISO 8859-13 Baltic'), ),Array ('cp1251','cp1251 - Windows Cyrillic'
Array('cp1251', 'cp1251 - Windows Cyrillic'), ),Array ('cp1256','cp1256 - Windows Arabic'
Array('cp1256', 'cp1256 - Windows Arabic'), ),Array ('cp1257','cp1257 - Windows Baltic'
Array('cp1257', 'cp1257 - Windows Baltic'), ),Array ('binary','binary - Binary pseudo charset'
Array('binary', 'binary - Binary pseudo charset'), ),Array ('geostd8','geostd8 - GEOSTD8 Georgian'
Array('geostd8', 'geostd8 - GEOSTD8 Georgian'), ),Array ('cp932','cp932] - SJIS for Windows Japanese'
Array('cp932', 'cp932] - SJIS for Windows Japanese'), ),Array ('eucjpms','eucjpms - UJIS for Windows Japanese'
Array('eucjpms', 'eucjpms - UJIS for Windows Japanese') )
); );
break; break;
case 'pgsql': case 'pgsql':
$encodes = Array( $encodes = Array (Array ("BIG5","BIG5"
Array("BIG5", "BIG5"), ),Array ("EUC_CN","EUC_CN"
Array("EUC_CN", "EUC_CN"), ),Array ("EUC_JP","EUC_JP"
Array("EUC_JP", "EUC_JP"), ),Array ("EUC_KR","EUC_KR"
Array("EUC_KR", "EUC_KR"), ),Array ("EUC_TW","EUC_TW"
Array("EUC_TW", "EUC_TW"), ),Array ("GB18030","GB18030"
Array("GB18030", "GB18030"), ),Array ("GBK","GBK"
Array("GBK", "GBK"), ),Array ("ISO_8859_5","ISO_8859_5"
Array("ISO_8859_5", "ISO_8859_5"), ),Array ("ISO_8859_6","ISO_8859_6"
Array("ISO_8859_6", "ISO_8859_6"), ),Array ("ISO_8859_7","ISO_8859_7"
Array("ISO_8859_7", "ISO_8859_7"), ),Array ("ISO_8859_8","ISO_8859_8"
Array("ISO_8859_8", "ISO_8859_8"), ),Array ("JOHAB","JOHAB"
Array("JOHAB", "JOHAB"), ),Array ("KOI8","KOI8"
Array("KOI8", "KOI8"), ),Array ("selected","LATIN1"
Array("selected", "LATIN1"), ),Array ("LATIN2","LATIN2"
Array("LATIN2", "LATIN2"), ),Array ("LATIN3","LATIN3"
Array("LATIN3", "LATIN3"), ),Array ("LATIN4","LATIN4"
Array("LATIN4", "LATIN4"), ),Array ("LATIN5","LATIN5"
Array("LATIN5", "LATIN5"), ),Array ("LATIN6","LATIN6"
Array("LATIN6", "LATIN6"), ),Array ("LATIN7","LATIN7"
Array("LATIN7", "LATIN7"), ),Array ("LATIN8","LATIN8"
Array("LATIN8", "LATIN8"), ),Array ("LATIN9","LATIN9"
Array("LATIN9", "LATIN9"), ),Array ("LATIN10","LATIN10"
Array("LATIN10", "LATIN10"), ),Array ("SJIS","SJIS"
Array("SJIS", "SJIS"), ),Array ("SQL_ASCII","SQL_ASCII"
Array("SQL_ASCII", "SQL_ASCII"), ),Array ("UHC","UHC"
Array("UHC", "UHC"), ),Array ("UTF8","UTF8"
Array("UTF8", "UTF8"), ),Array ("WIN866","WIN866"
Array("WIN866", "WIN866"), ),Array ("WIN874","WIN874"
Array("WIN874", "WIN874"), ),Array ("WIN1250","WIN1250"
Array("WIN1250", "WIN1250"), ),Array ("WIN1251","WIN1251"
Array("WIN1251", "WIN1251"), ),Array ("WIN1252","WIN1252"
Array("WIN1252", "WIN1252"), ),Array ("WIN1256","WIN1256"
Array("WIN1256", "WIN1256"), ),Array ("WIN1258","WIN1258"
Array("WIN1258", "WIN1258") )
); );
break; break;
case 'mssql': case 'mssql':
$encodes = Array(Array('utf8', 'utf8 - UTF-8 Unicode')); $encodes = Array (Array ('utf8','utf8 - UTF-8 Unicode'
)
);
break; break;
case 'oracle': case 'oracle':
$encodes = Array(); $encodes = Array ();
break; break;
} }
$this->encodesList = $encodes; $this->encodesList = $encodes;
return $this->ordx($this->encodesList); return $this->ordx( $this->encodesList );
} }
/** /**
@@ -359,7 +333,7 @@ class dbConnections
* *
* @return integer $errno * @return integer $errno
*/ */
public function getErrno() public function getErrno ()
{ {
return $this->errno; return $this->errno;
} }
@@ -369,7 +343,7 @@ class dbConnections
* *
* @return string errstr * @return string errstr
*/ */
public function getErrmsg() public function getErrmsg ()
{ {
return $this->errstr; return $this->errstr;
} }
@@ -380,72 +354,78 @@ class dbConnections
* @param array $m * @param array $m
* @return array $aRet * @return array $aRet
*/ */
public function ordx($m) public function ordx ($m)
{ {
$aTmp = Array(); $aTmp = Array ();
$aRet = Array(); $aRet = Array ();
for($i=0; $i<count($m); $i++){ for ($i = 0; $i < count( $m ); $i ++) {
array_push($aTmp, $m[$i][0].'|'.$m[$i][1]); array_push( $aTmp, $m[$i][0] . '|' . $m[$i][1] );
} }
usort($aTmp,"strnatcasecmp"); usort( $aTmp, "strnatcasecmp" );
for($i=0; $i<count($aTmp); $i++){ for ($i = 0; $i < count( $aTmp ); $i ++) {
$x = explode('|', $aTmp[$i]); $x = explode( '|', $aTmp[$i] );
array_push($aRet, Array($x[0], $x[1])); array_push( $aRet, Array ($x[0],$x[1]
) );
} }
return $aRet; return $aRet;
} }
/** /**
* Function encryptThepassw * Function encryptThepassw
*
* @author krlos Pacha C. <carlos@colosa.com> * @author krlos Pacha C. <carlos@colosa.com>
* @access public * @access public
* @param string proUid * @param string proUid
* @return void * @return void
*/ */
public function encryptThepassw($proUid){ public function encryptThepassw ($proUid)
{
$oDBSource = new DbSource(); $oDBSource = new DbSource();
$c = new Criteria(); $c = new Criteria();
$c->clearSelectColumns(); $c->clearSelectColumns();
$c->addSelectColumn(DbSourcePeer::DBS_UID); $c->addSelectColumn( DbSourcePeer::DBS_UID );
$c->addSelectColumn(DbSourcePeer::DBS_DATABASE_NAME); $c->addSelectColumn( DbSourcePeer::DBS_DATABASE_NAME );
$c->addSelectColumn(DbSourcePeer::DBS_PASSWORD); $c->addSelectColumn( DbSourcePeer::DBS_PASSWORD );
$c->add(DbSourcePeer::PRO_UID, $proUid); $c->add( DbSourcePeer::PRO_UID, $proUid );
$result = DbSourcePeer::doSelectRS($c); $result = DbSourcePeer::doSelectRS( $c );
$result->next(); $result->next();
$row = $result->getRow(); $row = $result->getRow();
while ($row = $result->getRow()) { while ($row = $result->getRow()) {
if($row[2]!=''){ if ($row[2] != '') {
$aPass = explode('_', $row[2]); $aPass = explode( '_', $row[2] );
if(count($aPass)==1) { if (count( $aPass ) == 1) {
$passEncrypt = G::encrypt($row[2], $row[1]); $passEncrypt = G::encrypt( $row[2], $row[1] );
$passEncrypt.="_2NnV3ujj3w"; $passEncrypt .= "_2NnV3ujj3w";
$c2 = new Criteria('workflow'); $c2 = new Criteria( 'workflow' );
$c2->add(DbSourcePeer::DBS_PASSWORD, $passEncrypt); $c2->add( DbSourcePeer::DBS_PASSWORD, $passEncrypt );
$c3 = new Criteria('workflow'); $c3 = new Criteria( 'workflow' );
$c3->add(DbSourcePeer::DBS_UID, $row[0]); $c3->add( DbSourcePeer::DBS_UID, $row[0] );
BasePeer::doUpdate($c3, $c2, Propel::getConnection('workflow')); BasePeer::doUpdate( $c3, $c2, Propel::getConnection( 'workflow' ) );
} }
} }
$result->next(); $result->next();
} }
return 1; return 1;
} }
/** /**
* Function getPassWithoutEncrypt * Function getPassWithoutEncrypt
*
* @author krlos Pacha C. <carlos@colosa.com> * @author krlos Pacha C. <carlos@colosa.com>
* @access public * @access public
* @param string passw * @param string passw
* @return string * @return string
*/ */
public function getPassWithoutEncrypt($aInfoCon){ public function getPassWithoutEncrypt ($aInfoCon)
$passw=''; {
if($aInfoCon['DBS_PASSWORD']!=''){ $passw = '';
$aPassw =explode('_',$aInfoCon['DBS_PASSWORD']); if ($aInfoCon['DBS_PASSWORD'] != '') {
$aPassw = explode( '_', $aInfoCon['DBS_PASSWORD'] );
$passw = $aPassw[0]; $passw = $aPassw[0];
if(sizeof($aPassw)>1) if (sizeof( $aPassw ) > 1)
$passw = ($passw == 'none') ? "": G::decrypt($passw,$aInfoCon['DBS_DATABASE_NAME']); $passw = ($passw == 'none') ? "" : G::decrypt( $passw, $aInfoCon['DBS_DATABASE_NAME'] );
} }
return $passw; return $passw;
} }