fernando/luos
1
0
Fork 0
Code Releases Activity

ODE STYLE Formating gulliver/system/class.database_mssql.php

Browse Source 
Change format files in gulliver/system/class.database_mssql.php
This commit is contained in:
norahmollo
2012-10-17 15:50:19 +00:00
parent 44415b7fc7
commit 4635a2b69c
1 changed files with 762 additions and 767 deletions
Download Patch File Download Diff File Expand all files Collapse all files

227
gulliver/system/class.database_mssql.php
View File

@@ -1,6 +1,7 @@
<?php
/**
* class.database_mssql.php
*
* @package gulliver.system
*
* ProcessMaker Open Source Edition
@@ -25,16 +26,19 @@
*/
/**
*
* @package gulliver.system
*
*/
G::LoadSystem( 'database_base' );
class database extends database_base {
class database extends database_base
{
public $iFetchType = MSSQL_ASSOC;
public function __construct($sType = DB_ADAPTER, $sServer = DB_HOST, $sUser = DB_USER, $sPass = DB_PASS, $sDataBase = DB_NAME) {
public function __construct ($sType = DB_ADAPTER, $sServer = DB_HOST, $sUser = DB_USER, $sPass = DB_PASS, $sDataBase = DB_NAME)
{
$this->sType = $sType;
$this->sServer = $sServer;
$this->sUser = $sUser;
@@ -47,9 +51,8 @@ class database extends database_base {
$this->sQuoteCharacterEnd = ']';
}
public function generateCreateTableSQL($sTable, $aColumns) {
public function generateCreateTableSQL ($sTable, $aColumns)
{
$sKeys = '';
$sSQL = 'CREATE TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . '(';
@@ -85,45 +88,48 @@ class database extends database_base {
return $sSQL;
}
public function generateDropTableSQL($sTable) {
public function generateDropTableSQL ($sTable)
{
return 'DROP TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . $this->sEndLine;
}
public function generateDropColumnSQL($sTable, $sColumn) {
public function generateDropColumnSQL ($sTable, $sColumn)
{
// SQL Server first should remove the restriction before the Elimination of the field
$oConstraint = $this->dropFieldConstraint( $sTable, $sColumn );
$sSQL = 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter .
' DROP COLUMN ' . $this->sQuoteCharacter . $sColumn . $this->sQuoteCharacter . $this->sEndLine;
$sSQL = 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . ' DROP COLUMN ' . $this->sQuoteCharacter . $sColumn . $this->sQuoteCharacter . $this->sEndLine;
return $sSQL;
}
public function generateAddColumnSQL($sTable, $sColumn, $aParameters) {
public function generateAddColumnSQL ($sTable, $sColumn, $aParameters)
{
if (isset( $aParameters['Type'] ) && isset( $aParameters['Null'] )) {
$sDefault = "";
$sType = $aParameters['Type'];
$sDataType = $aParameters['Type'];
if(! in_array($sDataType, array("TEXT", "DATE") )) {
if (! in_array( $sDataType, array ("TEXT","DATE"
) )) {
$sType = substr( $sType, 0, strpos( $sType, '(' ) );
}
switch ($sType) {
case 'VARCHAR':
case 'TEXT' : $sDefault = " DEFAULT '' ";
case 'TEXT':
$sDefault = " DEFAULT '' ";
break;
case 'DATE' : $sDataType = " CHAR(19) ";
case 'DATE':
$sDataType = " CHAR(19) ";
$sDefault = " DEFAULT '0000-00-00' "; // The date data type to use char (19)
break;
case 'INT':
case 'FLOAT' : $sDataType = $sType;
case 'FLOAT':
$sDataType = $sType;
$sDefault = " DEFAULT 0 ";
break;
}
$sSQL = "ALTER TABLE " . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter .
" ADD " . $this->sQuoteCharacter . $sColumn . $this->sQuoteCharacter .
" " . $aParameters['Type'];
$sSQL = "ALTER TABLE " . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . " ADD " . $this->sQuoteCharacter . $sColumn . $this->sQuoteCharacter . " " . $aParameters['Type'];
if ($aParameters['Null'] == 'YES') {
$sSQL .= " NULL";
}
else {
} else {
$sSQL .= " NOT NULL " . $sDefault;
}
@@ -135,14 +141,12 @@ class database extends database_base {
if (isset( $aParameters['AI'] )) {
if ($aParameters['AI'] == 1) {
$sSQL .= ' AUTO_INCREMENT';
}
else {
} else {
if ($aParameters['Default'] != '') {
$sSQL .= " DEFAULT '" . $aParameters['Default'] . "'";
}
}
}
else {
} else {
if (isset( $aParameters['Default'] ) && $aParameters['Default'] != '') {
$sSQL .= " DEFAULT '" . $aParameters['Default'] . "'";
}
@@ -151,18 +155,16 @@ class database extends database_base {
return $sSQL;
}
public function generateChangeColumnSQL($sTable, $sColumn, $aParameters, $sColumnNewName = '') {
$sSQL = 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter .
' CHANGE COLUMN ' . $this->sQuoteCharacter . ($sColumnNewName != '' ? $sColumnNewName : $sColumn) . $this->sQuoteCharacter .
' ' . $this->sQuoteCharacter . $sColumn . $this->sQuoteCharacter;
public function generateChangeColumnSQL ($sTable, $sColumn, $aParameters, $sColumnNewName = '')
{
$sSQL = 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . ' CHANGE COLUMN ' . $this->sQuoteCharacter . ($sColumnNewName != '' ? $sColumnNewName : $sColumn) . $this->sQuoteCharacter . ' ' . $this->sQuoteCharacter . $sColumn . $this->sQuoteCharacter;
if (isset( $aParameters['Type'] )) {
$sSQL .= ' ' . $aParameters['Type'];
}
if (isset( $aParameters['Null'] )) {
if ($aParameters['Null'] == 'YES') {
$sSQL .= ' NULL';
}
else {
} else {
$sSQL .= ' NOT NULL';
}
}
@@ -182,8 +184,7 @@ class database extends database_base {
if (isset( $aParameters['Default'] )) {
if (trim( $aParameters['Default'] == '' ) && $aParameters['Type'] == 'datetime') {
//do nothing
}
else
} else
$sSQL .= " DEFAULT '" . $aParameters['Default'] . "'";
//}
}
@@ -195,33 +196,28 @@ class database extends database_base {
return $sSQL;
}
public function generateGetPrimaryKeysSQL($sTable) {
public function generateGetPrimaryKeysSQL ($sTable)
{
try {
if ($sTable == '') {
throw new Exception( 'The table name cannot be empty!' );
}
return 'SHOW INDEX FROM ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . ' WHERE Seq_in_index = 1' . $this->sEndLine;
}
catch (Exception $oException) {
} catch (Exception $oException) {
throw $oException;
}
}
/**
* Get primary key
*
* @param eter string $sTable
* @return string $sPrimaryKey
*/
public function getPrimaryKey ($sTable)
{
try {
$sSQL = " SELECT c.COLUMN_NAME " .
" FROM INFORMATION_SCHEMA.TABLE_CONSTRAINTS pk , " .
" INFORMATION_SCHEMA.KEY_COLUMN_USAGE c " .
" WHERE pk.TABLE_NAME = '" . trim($sTable) . "' " .
" AND CONSTRAINT_TYPE = 'PRIMARY KEY' " .
" AND c.TABLE_NAME = pk.TABLE_NAME " .
" AND c.CONSTRAINT_NAME = pk.CONSTRAINT_NAME ";
$sSQL = " SELECT c.COLUMN_NAME " . " FROM INFORMATION_SCHEMA.TABLE_CONSTRAINTS pk , " . " INFORMATION_SCHEMA.KEY_COLUMN_USAGE c " . " WHERE pk.TABLE_NAME = '" . trim( $sTable ) . "' " . " AND CONSTRAINT_TYPE = 'PRIMARY KEY' " . " AND c.TABLE_NAME = pk.TABLE_NAME " . " AND c.CONSTRAINT_NAME = pk.CONSTRAINT_NAME ";
$oPrimaryKey = $this->executeQuery( $sSQL );
$aPrimaryKey = mssql_fetch_array( $oPrimaryKey );
mssql_free_result( $oPrimaryKey );
@@ -233,6 +229,7 @@ class database extends database_base {
/**
* Get Field Constraint
*
* @param eter string $sTable
* @param eter string $sField
* @return string $sFieldConstraint
@@ -240,12 +237,7 @@ class database extends database_base {
public function getFieldConstraint ($sTable, $sField)
{
try {
$sSQL = " select a.name " .
" from sysobjects a " .
" inner join syscolumns b on a.id = b.cdefault " .
" where a.xtype = 'D' " .
" and a.parent_obj = (select id from sysobjects where xtype = 'U' and name = '" . trim($sTable) . "') " .
" and b.name = '" . trim($sField) . "' ";
$sSQL = " select a.name " . " from sysobjects a " . " inner join syscolumns b on a.id = b.cdefault " . " where a.xtype = 'D' " . " and a.parent_obj = (select id from sysobjects where xtype = 'U' and name = '" . trim( $sTable ) . "') " . " and b.name = '" . trim( $sField ) . "' ";
$oFieldConstraint = $this->executeQuery( $sSQL );
$aFieldConstraint = mssql_fetch_array( $oFieldConstraint );
@@ -256,9 +248,9 @@ class database extends database_base {
}
}
/**
* drop Field Constraint
*
* @param eter string $sTable
* @param eter string $sField
* @return object $oFieldConstraint
@@ -275,8 +267,8 @@ class database extends database_base {
}
}
public function generateDropPrimaryKeysSQL($sTable) {
public function generateDropPrimaryKeysSQL ($sTable)
{
try {
if ($sTable == '') {
throw new Exception( 'The table name cannot be empty!' );
@@ -284,31 +276,30 @@ class database extends database_base {
$sPrimayKey = $this->getPrimaryKey( $sTable );
return ' ALTER TABLE ' . $sTable . ' DROP CONSTRAINT ' . $sPrimayKey . $this->sEndLine;
}
catch (Exception $oException) {
} catch (Exception $oException) {
throw $oException;
}
}
public function generateAddPrimaryKeysSQL($sTable, $aPrimaryKeys) {
public function generateAddPrimaryKeysSQL ($sTable, $aPrimaryKeys)
{
try {
if ($sTable == '') {
throw new Exception( 'The table name cannot be empty!' );
}
$sSQL = 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter .
' ADD PRIMARY KEY (';
$sSQL = 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . ' ADD PRIMARY KEY (';
foreach ($aPrimaryKeys as $sKey) {
$sSQL .= $this->sQuoteCharacter . $sKey . $this->sQuoteCharacter . ',';
}
$sSQL = substr( $sSQL, 0, - 1 ) . ')' . $this->sEndLine;
return $sSQL;
}
catch (Exception $oException) {
} catch (Exception $oException) {
throw $oException;
}
}
public function generateDropKeySQL($sTable, $sIndexName) {
public function generateDropKeySQL ($sTable, $sIndexName)
{
try {
if ($sTable == '') {
throw new Exception( 'The table name cannot be empty!' );
@@ -317,13 +308,13 @@ class database extends database_base {
throw new Exception( 'The column name cannot be empty!' );
}
return 'ALTER TABLE ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . ' DROP INDEX ' . $this->sQuoteCharacter . $sIndexName . $this->sQuoteCharacter . $this->sEndLine;
}
catch (Exception $oException) {
} catch (Exception $oException) {
throw $oException;
}
}
public function generateAddKeysSQL($sTable, $indexName, $aKeys) {
public function generateAddKeysSQL ($sTable, $indexName, $aKeys)
{
try {
$indexType = 'INDEX';
if ($indexName == 'primaryKey' || $indexName == 'PRIMARY') {
@@ -337,62 +328,70 @@ class database extends database_base {
$sSQL = substr( $sSQL, 0, - 2 );
$sSQL .= ')' . $this->sEndLine;
return $sSQL;
}
catch (Exception $oException) {
} catch (Exception $oException) {
throw $oException;
}
}
public function generateShowTablesSQL() {
public function generateShowTablesSQL ()
{
return 'SHOW TABLES' . $this->sEndLine;
}
public function generateShowTablesLikeSQL($sTable) {
public function generateShowTablesLikeSQL ($sTable)
{
return "SHOW TABLES LIKE '" . $sTable . "'" . $this->sEndLine;
}
public function generateDescTableSQL($sTable) {
public function generateDescTableSQL ($sTable)
{
try {
if ($sTable == '') {
throw new Exception( 'The table name cannot be empty!' );
}
return 'DESC ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . $this->sEndLine;
}
catch (Exception $oException) {
} catch (Exception $oException) {
throw $oException;
}
}
public function generateTableIndexSQL($sTable) {
public function generateTableIndexSQL ($sTable)
{
return 'SHOW INDEX FROM ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . " " . $this->sEndLine;
//return 'SHOW INDEX FROM ' . $this->sQuoteCharacter . $sTable . $this->sQuoteCharacter . " WHERE Key_name <> 'PRIMARY'" . $this->sEndLine;
}
public function isConnected() {
public function isConnected ()
{
if (! $this->oConnection)
return false;
return $this->executeQuery( 'USE ' . $this->sDataBase );
}
public function logQuery($sQuery ) {
public function logQuery ($sQuery)
{
try {
$found = false;
if ( substr($sQuery,0, 6) == 'SELECT' ) $found = true;
if ( substr($sQuery,0, 4) == 'SHOW' ) $found = true;
if ( substr($sQuery,0, 4) == 'DESC' ) $found = true;
if ( substr($sQuery,0, 4) == 'USE ' ) $found = true;
if (substr( $sQuery, 0, 6 ) == 'SELECT')
$found = true;
if (substr( $sQuery, 0, 4 ) == 'SHOW')
$found = true;
if (substr( $sQuery, 0, 4 ) == 'DESC')
$found = true;
if (substr( $sQuery, 0, 4 ) == 'USE ')
$found = true;
if (! $found) {
$logFile = PATH_DATA . 'log' . PATH_SEP . 'query.log';
$fp = fopen( $logFile, 'a+' );
fwrite( $fp, date( "Y-m-d H:i:s" ) . " " . $this->sDataBase . " " . $sQuery . "\n" );
fclose( $fp );
}
}
catch (Exception $oException) {
} catch (Exception $oException) {
}
}
public function executeQuery($sQuery) {
public function executeQuery ($sQuery)
{
$this->logQuery( $sQuery );
try {
@@ -400,30 +399,32 @@ class database extends database_base {
@mssql_select_db( $this->sDataBase );
return @mssql_query( $sQuery );
}
else {
} else {
throw new Exception( 'invalid connection to database ' . $this->sDataBase );
}
}
catch (Exception $oException) {
} catch (Exception $oException) {
$this->logQuery( $oException->getMessage() );
throw $oException;
}
}
public function countResults($oDataset) {
public function countResults ($oDataset)
{
return @mssql_num_rows( $oDataset );
}
public function getRegistry($oDataset) {
public function getRegistry ($oDataset)
{
return @mssql_fetch_array( $oDataset, $this->iFetchType );
}
public function close() {
public function close ()
{
@mssql_close( $this->oConnection );
}
public function generateInsertSQL($table, $data) {
public function generateInsertSQL ($table, $data)
{
$fields = array ();
$values = array ();
foreach ($data as $field) {
@@ -439,17 +440,18 @@ class database extends database_base {
$values[] = addslashes( $field['value'] );
break;
}
}
else {
} else {
$values[] = $this->nullString;
}
}
$fields = array_map(array($this, 'putQuotes'), $fields);
$fields = array_map( array ($this,'putQuotes'
), $fields );
$sql = sprintf( "INSERT INTO %s (%s) VALUES (%s)", $this->putQuotes( $table ), implode( ', ', $fields ), implode( ', ', $values ) );
return $sql;
}
public function generateUpdateSQL($table, $keys, $data) {
public function generateUpdateSQL ($table, $keys, $data)
{
$fields = array ();
$where = array ();
foreach ($data as $field) {
@@ -464,8 +466,7 @@ class database extends database_base {
$fields[] = $this->putQuotes( $field['field'] ) . " = " . addslashes( $field['value'] );
break;
}
}
else {
} else {
$values[] = $this->nullString;
}
if (in_array( $field['field'], $keys )) {
@@ -476,7 +477,8 @@ class database extends database_base {
return $sql;
}
public function generateDeleteSQL($table, $keys, $data) {
public function generateDeleteSQL ($table, $keys, $data)
{
$fields = array ();
$where = array ();
foreach ($data as $field) {
@@ -492,8 +494,7 @@ class database extends database_base {
$where[] = $this->putQuotes( $field['field'] ) . " = " . addslashes( $field['value'] );
break;
}
}
else {
} else {
$values[] = $this->nullString;
}
}
@@ -502,7 +503,8 @@ class database extends database_base {
return $sql;
}
public function generateSelectSQL($table, $keys, $data) {
public function generateSelectSQL ($table, $keys, $data)
{
$fields = array ();
$where = array ();
foreach ($data as $field) {
@@ -518,8 +520,7 @@ class database extends database_base {
$where[] = $this->putQuotes( $field['field'] ) . " = " . mysql_real_escape_string( $field['value'] );
break;
}
}
else {
} else {
$values[] = $this->nullString;
}
}
@@ -528,7 +529,8 @@ class database extends database_base {
return $sql;
}
private function putQuotes($element) {
private function putQuotes ($element)
{
return $this->sQuoteCharacterBegin . $element . $this->sQuoteCharacterEnd;
}
@@ -620,8 +622,7 @@ class database extends database_base {
$sqlConcat = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME AS [USER] ";
$sqlGroupBy = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME ";
$sql = "SELECT " . $sqlConcat . ", " .
" COUNT(*) AS CANTCASES,
$sql = "SELECT " . $sqlConcat . ", " . " COUNT(*) AS CANTCASES,
MIN(AD.DEL_DURATION) AS MIN,
MAX(AD.DEL_DURATION) AS MAX,
SUM(AD.DEL_DURATION) AS TOTALDUR,
@@ -649,8 +650,7 @@ class database extends database_base {
$sqlConcat = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME AS [USER] ";
$sqlGroupBy = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME ";
$sql = " SELECT " . $sqlConcat . ", " .
" COUNT(*) AS CANTCASES,
$sql = " SELECT " . $sqlConcat . ", " . " COUNT(*) AS CANTCASES,
MIN(AD.DEL_DURATION) AS MIN,
MAX(AD.DEL_DURATION) AS MAX,
SUM(AD.DEL_DURATION) AS TOTALDUR,
@@ -679,8 +679,7 @@ class database extends database_base {
$sqlConcat = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME AS [USER] ";
$sqlGroupBy = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME ";
$sql = " SELECT " . $sqlConcat . ", " .
" COUNT(*) AS CANTCASES,
$sql = " SELECT " . $sqlConcat . ", " . " COUNT(*) AS CANTCASES,
MIN(AD.DEL_DURATION) AS MIN,
MAX(AD.DEL_DURATION) AS MAX,
SUM(AD.DEL_DURATION) AS TOTALDUR,
@@ -709,8 +708,7 @@ class database extends database_base {
$sqlConcat = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME AS [USER] ";
$sqlGroupBy = " U.USR_LASTNAME + ' ' + USR_FIRSTNAME ";
$sql = "SELECT " . $sqlConcat . ", " .
" COUNT(*) AS CANTCASES,
$sql = "SELECT " . $sqlConcat . ", " . " COUNT(*) AS CANTCASES,
MIN(AD.DEL_DURATION) AS MIN,
MAX(AD.DEL_DURATION) AS MAX,
SUM(AD.DEL_DURATION) AS TOTALDUR,
@@ -746,19 +744,16 @@ class database extends database_base {
}
/*
* query functions for class class.net.php
*
*/
function getDropTable($sTableName)
{
$sql = "IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='" . $sTableName . "' AND xtype='U') " .
"DROP TABLE ['" . $sTableName . "']";
$sql = "IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='" . $sTableName . "' AND xtype='U') " . "DROP TABLE ['" . $sTableName . "']";
return $sql;
}
function getTableDescription($sTableName)
{
$sql = " select column_name as Field,
@@ -777,8 +772,7 @@ class database extends database_base {
when 'No' then 'NO' else 'YES' END) AS AsNull,
COLUMN_DEFAULT as [Default]
FROM information_schema.columns
WHERE table_name = '" . trim($sTableName) . "'" .
" Order by Ordinal_Position asc ";
WHERE table_name = '" . trim( $sTableName ) . "'" . " Order by Ordinal_Position asc ";
return $sql;
}
@@ -820,7 +814,8 @@ class database extends database_base {
/**
* Determining the existence of a table
*/
function tableExists ($table, $db) {
function tableExists($table, $db)
{
$sql = "SELECT * FROM sysobjects WHERE name='" . $table . "' AND type='u'";
$bExists = true;
$oConnection = mssql_connect( DB_HOST, DB_USER, DB_PASS );
@@ -828,5 +823,5 @@ class database extends database_base {
$oDataset = mssql_query( $sql ) || ($bExists = false);
return $bExists;
}
}