1674 lines
52 KiB
PHP
Executable File
1674 lines
52 KiB
PHP
Executable File
<?php
|
||
/**
|
||
*
|
||
* SugarCRM Community Edition is a customer relationship management program developed by
|
||
* SugarCRM, Inc. Copyright (C) 2004-2013 SugarCRM Inc.
|
||
*
|
||
* SuiteCRM is an extension to SugarCRM Community Edition developed by SalesAgility Ltd.
|
||
* Copyright (C) 2011 - 2018 SalesAgility Ltd.
|
||
*
|
||
* This program is free software; you can redistribute it and/or modify it under
|
||
* the terms of the GNU Affero General Public License version 3 as published by the
|
||
* Free Software Foundation with the addition of the following permission added
|
||
* to Section 15 as permitted in Section 7(a): FOR ANY PART OF THE COVERED WORK
|
||
* IN WHICH THE COPYRIGHT IS OWNED BY SUGARCRM, SUGARCRM DISCLAIMS THE WARRANTY
|
||
* OF NON INFRINGEMENT OF THIRD PARTY RIGHTS.
|
||
*
|
||
* This program is distributed in the hope that it will be useful, but WITHOUT
|
||
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
||
* FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more
|
||
* details.
|
||
*
|
||
* You should have received a copy of the GNU Affero General Public License along with
|
||
* this program; if not, see http://www.gnu.org/licenses or write to the Free
|
||
* Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
||
* 02110-1301 USA.
|
||
*
|
||
* You can contact SugarCRM, Inc. headquarters at 10050 North Wolfe Road,
|
||
* SW2-130, Cupertino, CA 95014, USA. or at email address contact@sugarcrm.com.
|
||
*
|
||
* The interactive user interfaces in modified source and object code versions
|
||
* of this program must display Appropriate Legal Notices, as required under
|
||
* Section 5 of the GNU Affero General Public License version 3.
|
||
*
|
||
* In accordance with Section 7(b) of the GNU Affero General Public License version 3,
|
||
* these Appropriate Legal Notices must retain the display of the "Powered by
|
||
* SugarCRM" logo and "Supercharged by SuiteCRM" logo. If the display of the logos is not
|
||
* reasonably feasible for technical reasons, the Appropriate Legal Notices must
|
||
* display the words "Powered by SugarCRM" and "Supercharged by SuiteCRM".
|
||
*/
|
||
|
||
if (!defined('sugarEntry') || !sugarEntry) {
|
||
die('Not A Valid Entry Point');
|
||
}
|
||
|
||
/*********************************************************************************
|
||
* Description: This file handles the Data base functionality for the application.
|
||
* It acts as the DB abstraction layer for the application. It depends on helper classes
|
||
* which generate the necessary SQL. This sql is then passed to PEAR DB classes.
|
||
* The helper class is chosen in DBManagerFactory, which is driven by 'db_type' in 'dbconfig' under config.php.
|
||
*
|
||
* All the functions in this class will work with any bean which implements the meta interface.
|
||
* The passed bean is passed to helper class which uses these functions to generate correct sql.
|
||
*
|
||
* The meta interface has the following functions:
|
||
* getTableName() Returns table name of the object.
|
||
* getFieldDefinitions() Returns a collection of field definitions in order.
|
||
* getFieldDefintion(name) Return field definition for the field.
|
||
* getFieldValue(name) Returns the value of the field identified by name.
|
||
* If the field is not set, the function will return boolean FALSE.
|
||
* getPrimaryFieldDefinition() Returns the field definition for primary key
|
||
*
|
||
* The field definition is an array with the following keys:
|
||
*
|
||
* name This represents name of the field. This is a required field.
|
||
* type This represents type of the field. This is a required field and valid values are:
|
||
* <20> int
|
||
* <20> long
|
||
* <20> varchar
|
||
* <20> text
|
||
* <20> date
|
||
* <20> datetime
|
||
* <20> double
|
||
* <20> float
|
||
* <20> uint
|
||
* <20> ulong
|
||
* <20> time
|
||
* <20> short
|
||
* <20> enum
|
||
* length This is used only when the type is varchar and denotes the length of the string.
|
||
* The max value is 255.
|
||
* enumvals This is a list of valid values for an enum separated by "|".
|
||
* It is used only if the type is <20>enum<75>;
|
||
* required This field dictates whether it is a required value.
|
||
* The default value is <20>FALSE<53>.
|
||
* isPrimary This field identifies the primary key of the table.
|
||
* If none of the fields have this flag set to <20>TRUE<55>,
|
||
* the first field definition is assume to be the primary key.
|
||
* Default value for this field is <20>FALSE<53>.
|
||
* default This field sets the default value for the field definition.
|
||
*
|
||
*
|
||
* Portions created by SugarCRM are Copyright (C) SugarCRM, Inc.
|
||
* All Rights Reserved.
|
||
* Contributor(s): ______________________________________..
|
||
********************************************************************************/
|
||
|
||
/**
|
||
* MySQL manager implementation for mysql extension
|
||
*/
|
||
class MysqlManager extends DBManager
|
||
{
|
||
/**
|
||
* @see DBManager::$dbType
|
||
*/
|
||
public $dbType = 'mysql';
|
||
public $variant = 'mysql';
|
||
public $dbName = 'MySQL';
|
||
public $label = 'LBL_MYSQL';
|
||
|
||
protected $maxNameLengths = array(
|
||
'table' => 64,
|
||
'column' => 64,
|
||
'index' => 64,
|
||
'alias' => 256
|
||
);
|
||
|
||
protected $type_map = array(
|
||
'int' => 'int',
|
||
'double' => 'double',
|
||
'float' => 'float',
|
||
'uint' => 'int unsigned',
|
||
'ulong' => 'bigint unsigned',
|
||
'long' => 'bigint',
|
||
'short' => 'smallint',
|
||
'varchar' => 'varchar',
|
||
'text' => 'text',
|
||
'longtext' => 'longtext',
|
||
'date' => 'date',
|
||
'enum' => 'varchar',
|
||
'relate' => 'varchar',
|
||
'multienum' => 'text',
|
||
'html' => 'text',
|
||
'emailbody' => 'nvarchar(max)',
|
||
'longhtml' => 'longtext',
|
||
'datetime' => 'datetime',
|
||
'datetimecombo' => 'datetime',
|
||
'time' => 'time',
|
||
'bool' => 'bool',
|
||
'tinyint' => 'tinyint',
|
||
'char' => 'char',
|
||
'blob' => 'blob',
|
||
'longblob' => 'longblob',
|
||
'currency' => 'decimal(26,6)',
|
||
'decimal' => 'decimal',
|
||
'decimal2' => 'decimal',
|
||
'id' => 'char(36)',
|
||
'url' => 'varchar',
|
||
'encrypt' => 'varchar',
|
||
'file' => 'varchar',
|
||
'decimal_tpl' => 'decimal(%d, %d)',
|
||
|
||
);
|
||
|
||
protected $capabilities = array(
|
||
"affected_rows" => true,
|
||
"select_rows" => true,
|
||
"inline_keys" => true,
|
||
"create_user" => true,
|
||
"fulltext" => true,
|
||
"collation" => true,
|
||
"create_db" => true,
|
||
"disable_keys" => true,
|
||
);
|
||
|
||
/**
|
||
* Parses and runs queries
|
||
*
|
||
* @param string $sql SQL Statement to execute
|
||
* @param bool $dieOnError True if we want to call die if the query returns errors
|
||
* @param string $msg Message to log if error occurs
|
||
* @param bool $suppress Flag to suppress all error output unless in debug logging mode.
|
||
* @param bool $keepResult True if we want to push this result into the $lastResult array.
|
||
* @return resource result set
|
||
*/
|
||
public function query($sql, $dieOnError = false, $msg = '', $suppress = false, $keepResult = false)
|
||
{
|
||
if (is_array($sql)) {
|
||
return $this->queryArray($sql, $dieOnError, $msg, $suppress);
|
||
}
|
||
|
||
parent::countQuery($sql);
|
||
$GLOBALS['log']->info('Query:' . $sql);
|
||
$this->checkConnection();
|
||
$this->query_time = microtime(true);
|
||
$this->lastsql = $sql;
|
||
$result = $suppress ? @mysql_query($sql, $this->database) : mysql_query($sql, $this->database);
|
||
|
||
$this->query_time = microtime(true) - $this->query_time;
|
||
$GLOBALS['log']->info('Query Execution Time:' . $this->query_time);
|
||
|
||
|
||
if ($keepResult) {
|
||
$this->lastResult = $result;
|
||
}
|
||
|
||
$this->checkError($msg . ' Query Failed:' . $sql . '::', $dieOnError);
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* Returns the number of rows affected by the last query
|
||
* @param $result
|
||
* @return int
|
||
*/
|
||
public function getAffectedRowCount($result)
|
||
{
|
||
return mysql_affected_rows($this->getDatabase());
|
||
}
|
||
|
||
/**
|
||
* Returns the number of rows returned by the result
|
||
*
|
||
* This function can't be reliably implemented on most DB, do not use it.
|
||
* @abstract
|
||
* @deprecated
|
||
* @param resource $result
|
||
* @return int
|
||
*/
|
||
public function getRowCount($result)
|
||
{
|
||
return mysql_num_rows($result);
|
||
}
|
||
|
||
/**
|
||
* Disconnects from the database
|
||
*
|
||
* Also handles any cleanup needed
|
||
*/
|
||
public function disconnect()
|
||
{
|
||
$GLOBALS['log']->debug('Calling MySQL::disconnect()');
|
||
if (!empty($this->database)) {
|
||
$this->freeResult();
|
||
mysql_close($this->database);
|
||
$this->database = null;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::freeDbResult()
|
||
*/
|
||
protected function freeDbResult($dbResult)
|
||
{
|
||
if (!empty($dbResult)) {
|
||
mysql_free_result($dbResult);
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* @abstract
|
||
* Check if query has LIMIT clause
|
||
* Relevant for now only for Mysql
|
||
* @param string $sql
|
||
* @return bool
|
||
*/
|
||
protected function hasLimit($sql)
|
||
{
|
||
return stripos($sql, " limit ") !== false;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::limitQuery()
|
||
*/
|
||
public function limitQuery($sql, $start, $count, $dieOnError = false, $msg = '', $execute = true)
|
||
{
|
||
$start = (int)$start;
|
||
$count = (int)$count;
|
||
if ($start < 0) {
|
||
$start = 0;
|
||
}
|
||
$GLOBALS['log']->debug('Limit Query:' . $sql . ' Start: ' . $start . ' count: ' . $count);
|
||
|
||
$sql = "$sql LIMIT $start,$count";
|
||
$this->lastsql = $sql;
|
||
|
||
if (!empty($GLOBALS['sugar_config']['check_query'])) {
|
||
$this->checkQuery($sql);
|
||
}
|
||
if (!$execute) {
|
||
return $sql;
|
||
}
|
||
|
||
return $this->query($sql, $dieOnError, $msg);
|
||
}
|
||
|
||
|
||
/**
|
||
* @see DBManager::checkQuery()
|
||
*/
|
||
protected function checkQuery($sql, $object_name = false)
|
||
{
|
||
$result = $this->query('EXPLAIN ' . $sql);
|
||
$badQuery = array();
|
||
while ($row = $this->fetchByAssoc($result)) {
|
||
if (empty($row['table'])) {
|
||
continue;
|
||
}
|
||
$badQuery[$row['table']] = '';
|
||
if (strtoupper($row['type']) == 'ALL') {
|
||
$badQuery[$row['table']] .= ' Full Table Scan;';
|
||
}
|
||
if (empty($row['key'])) {
|
||
$badQuery[$row['table']] .= ' No Index Key Used;';
|
||
}
|
||
if (!empty($row['Extra']) && substr_count((string) $row['Extra'], 'Using filesort') > 0) {
|
||
$badQuery[$row['table']] .= ' Using FileSort;';
|
||
}
|
||
if (!empty($row['Extra']) && substr_count((string) $row['Extra'], 'Using temporary') > 0) {
|
||
$badQuery[$row['table']] .= ' Using Temporary Table;';
|
||
}
|
||
}
|
||
|
||
if (empty($badQuery)) {
|
||
return true;
|
||
}
|
||
|
||
foreach ($badQuery as $table => $data) {
|
||
if (!empty($data)) {
|
||
$warning = ' Table:' . $table . ' Data:' . $data;
|
||
if (!empty($GLOBALS['sugar_config']['check_query_log'])) {
|
||
$GLOBALS['log']->fatal($sql);
|
||
$GLOBALS['log']->fatal('CHECK QUERY:' . $warning);
|
||
} else {
|
||
$GLOBALS['log']->warn('CHECK QUERY:' . $warning);
|
||
}
|
||
}
|
||
}
|
||
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::get_columns()
|
||
*/
|
||
public function get_columns($tablename)
|
||
{
|
||
//find all unique indexes and primary keys.
|
||
$result = $this->query("DESCRIBE $tablename");
|
||
|
||
$columns = array();
|
||
while (($row = $this->fetchByAssoc($result)) != null) {
|
||
$name = strtolower($row['Field']);
|
||
$columns[$name]['name'] = $name;
|
||
$matches = array();
|
||
preg_match_all('/(\w+)(?:\(([0-9]+,?[0-9]*)\)|)( unsigned)?/i', (string) $row['Type'], $matches);
|
||
$columns[$name]['type'] = strtolower($matches[1][0]);
|
||
if (isset($matches[2][0]) && in_array(
|
||
strtolower($matches[1][0]),
|
||
array('varchar', 'char', 'varchar2', 'int', 'decimal', 'float')
|
||
)
|
||
) {
|
||
$columns[$name]['len'] = strtolower($matches[2][0]);
|
||
}
|
||
if (stristr((string) $row['Extra'], 'auto_increment')) {
|
||
$columns[$name]['auto_increment'] = '1';
|
||
}
|
||
if ($row['Null'] == 'NO' && !stristr((string) $row['Key'], 'PRI')) {
|
||
$columns[$name]['required'] = 'true';
|
||
}
|
||
if (!empty($row['Default'])) {
|
||
$columns[$name]['default'] = $row['Default'];
|
||
}
|
||
}
|
||
|
||
return $columns;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::getFieldsArray()
|
||
*/
|
||
public function getFieldsArray($result, $make_lower_case = false)
|
||
{
|
||
$field_array = array();
|
||
|
||
if (empty($result)) {
|
||
return 0;
|
||
}
|
||
|
||
$fields = mysql_num_fields($result);
|
||
for ($i = 0; $i < $fields; $i++) {
|
||
$meta = mysql_fetch_field($result, $i);
|
||
if (!$meta) {
|
||
return array();
|
||
}
|
||
|
||
if ($make_lower_case == true) {
|
||
$meta->name = strtolower($meta->name);
|
||
}
|
||
|
||
$field_array[] = $meta->name;
|
||
}
|
||
|
||
return $field_array;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::fetchRow()
|
||
*/
|
||
public function fetchRow($result)
|
||
{
|
||
if (empty($result)) {
|
||
return false;
|
||
}
|
||
|
||
return mysql_fetch_assoc($result);
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::getTablesArray()
|
||
*/
|
||
public function getTablesArray()
|
||
{
|
||
$this->log->debug('Fetching table list');
|
||
|
||
if ($this->getDatabase()) {
|
||
$tables = array();
|
||
$r = $this->query('SHOW TABLES');
|
||
if (!empty($r)) {
|
||
while ($a = $this->fetchByAssoc($r)) {
|
||
$row = array_values($a);
|
||
$tables[] = $row[0];
|
||
}
|
||
|
||
return $tables;
|
||
}
|
||
}
|
||
|
||
return false; // no database available
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::version()
|
||
*/
|
||
public function version()
|
||
{
|
||
return $this->getOne("SELECT version() version");
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::tableExists()
|
||
*/
|
||
public function tableExists($tableName)
|
||
{
|
||
$this->log->info("tableExists: $tableName");
|
||
|
||
if ($this->getDatabase()) {
|
||
$result = $this->query("SHOW TABLES LIKE " . $this->quoted($tableName));
|
||
if (empty($result)) {
|
||
return false;
|
||
}
|
||
$row = $this->fetchByAssoc($result);
|
||
|
||
return !empty($row);
|
||
}
|
||
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* Get tables like expression
|
||
* @param string $like
|
||
* @return array
|
||
*/
|
||
public function tablesLike($like)
|
||
{
|
||
if ($this->getDatabase()) {
|
||
$tables = array();
|
||
$r = $this->query('SHOW TABLES LIKE ' . $this->quoted($like));
|
||
if (!empty($r)) {
|
||
while ($a = $this->fetchByAssoc($r)) {
|
||
$row = array_values($a);
|
||
$tables[] = $row[0];
|
||
}
|
||
|
||
return $tables;
|
||
}
|
||
}
|
||
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::quote()
|
||
*/
|
||
public function quote($string)
|
||
{
|
||
if (is_array($string)) {
|
||
return $this->arrayQuote($string);
|
||
}
|
||
|
||
return mysql_real_escape_string($this->quoteInternal($string), $this->getDatabase());
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::quoteIdentifier()
|
||
*/
|
||
public function quoteIdentifier($string)
|
||
{
|
||
return '`' . $string . '`';
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::connect()
|
||
*/
|
||
public function connect(array $configOptions = null, $dieOnError = false)
|
||
{
|
||
global $sugar_config;
|
||
|
||
if (is_null($configOptions)) {
|
||
$configOptions = $sugar_config['dbconfig'];
|
||
}
|
||
|
||
if ($this->getOption('persistent')) {
|
||
$this->database = @mysql_pconnect(
|
||
$configOptions['db_host_name'],
|
||
$configOptions['db_user_name'],
|
||
$configOptions['db_password']
|
||
);
|
||
}
|
||
|
||
if (!$this->database) {
|
||
$this->database = mysql_connect(
|
||
$configOptions['db_host_name'],
|
||
$configOptions['db_user_name'],
|
||
$configOptions['db_password']
|
||
);
|
||
if (empty($this->database)) {
|
||
$GLOBALS['log']->fatal("Could not connect to server " . $configOptions['db_host_name'] . " as " . $configOptions['db_user_name'] . ":" . mysql_error());
|
||
if ($dieOnError) {
|
||
if (isset($GLOBALS['app_strings']['ERR_NO_DB'])) {
|
||
sugar_die($GLOBALS['app_strings']['ERR_NO_DB']);
|
||
} else {
|
||
sugar_die("Could not connect to the database. Please refer to suitecrm.log for details (1).");
|
||
}
|
||
} else {
|
||
return false;
|
||
}
|
||
}
|
||
// Do not pass connection information because we have not connected yet
|
||
if ($this->database && $this->getOption('persistent')) {
|
||
$_SESSION['administrator_error'] = "<b>Severe Performance Degradation: Persistent Database Connections "
|
||
. "not working. Please set \$sugar_config['dbconfigoption']['persistent'] to false "
|
||
. "in your config.php file</b>";
|
||
}
|
||
}
|
||
if (!empty($configOptions['db_name']) && !@mysql_select_db($configOptions['db_name'])) {
|
||
$GLOBALS['log']->fatal("Unable to select database {$configOptions['db_name']}: " . mysql_error($this->database));
|
||
if ($dieOnError) {
|
||
sugar_die($GLOBALS['app_strings']['ERR_NO_DB']);
|
||
} else {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
// cn: using direct calls to prevent this from spamming the Logs
|
||
$charset = $this->getCharset();
|
||
|
||
if(!empty($charset)) {
|
||
$msg = "Error setting character set";
|
||
$this->query("SET CHARACTER SET $charset", true, $msg);
|
||
|
||
$names = "SET NAMES '$charset'";
|
||
$collation = $this->getCollation();
|
||
|
||
if (!empty($collation)) {
|
||
$names .= " COLLATE '$collation'";
|
||
}
|
||
|
||
$msg = "Error setting character set and collation";
|
||
$this->query($names, true, $msg);
|
||
}
|
||
|
||
if (!$this->checkError('Could Not Connect:', $dieOnError)) {
|
||
$GLOBALS['log']->info("connected to db");
|
||
}
|
||
$this->connectOptions = $configOptions;
|
||
|
||
$GLOBALS['log']->info("Connect:" . $this->database);
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::repairTableParams()
|
||
*
|
||
* For MySQL, we can write the ALTER TABLE statement all in one line, which speeds things
|
||
* up quite a bit. So here, we'll parse the returned SQL into a single ALTER TABLE command.
|
||
*/
|
||
public function repairTableParams($tablename, $fielddefs, $indices, $execute = true, $engine = null)
|
||
{
|
||
$sql = parent::repairTableParams($tablename, $fielddefs, $indices, false, $engine);
|
||
|
||
if ($sql == '') {
|
||
return '';
|
||
}
|
||
|
||
if (stristr($sql, 'create table')) {
|
||
if ($execute) {
|
||
$msg = "Error creating table: " . $tablename . ":";
|
||
$this->query($sql, true, $msg);
|
||
}
|
||
|
||
return $sql;
|
||
}
|
||
|
||
// first, parse out all the comments
|
||
$match = array();
|
||
preg_match_all('!/\*.*?\*/!is', $sql, $match);
|
||
$commentBlocks = $match[0];
|
||
$sql = preg_replace('!/\*.*?\*/!is', '', $sql);
|
||
|
||
// now, we should only have alter table statements
|
||
// let's replace the 'alter table name' part with a comma
|
||
$sql = preg_replace("!alter table $tablename!is", ', ', $sql);
|
||
|
||
// re-add it at the beginning
|
||
$sql = substr_replace($sql, '', strpos($sql, ','), 1);
|
||
$sql = str_replace(";", "", $sql);
|
||
$sql = str_replace("\n", "", $sql);
|
||
$sql = "ALTER TABLE $tablename $sql";
|
||
|
||
if ($execute) {
|
||
$this->query($sql, 'Error with MySQL repair table');
|
||
}
|
||
|
||
// and re-add the comments at the beginning
|
||
$sql = implode("\n", $commentBlocks) . "\n" . $sql . "\n";
|
||
|
||
return $sql;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::convert()
|
||
*/
|
||
public function convert($string, $type, array $additional_parameters = array())
|
||
{
|
||
$all_parameters = $additional_parameters;
|
||
if (is_array($string)) {
|
||
$all_parameters = array_merge($string, $all_parameters);
|
||
} elseif (!is_null($string)) {
|
||
array_unshift($all_parameters, $string);
|
||
}
|
||
$all_strings = implode(',', $all_parameters);
|
||
|
||
switch (strtolower($type)) {
|
||
case 'today':
|
||
return "CURDATE()";
|
||
case 'left':
|
||
return "LEFT($all_strings)";
|
||
case 'date_format':
|
||
if (empty($additional_parameters)) {
|
||
return "DATE_FORMAT($string,'%Y-%m-%d')";
|
||
} else {
|
||
$format = $additional_parameters[0];
|
||
if ($format[0] != "'") {
|
||
$format = $this->quoted($format);
|
||
}
|
||
|
||
return "DATE_FORMAT($string,$format)";
|
||
}
|
||
// no break
|
||
case 'ifnull':
|
||
if (empty($additional_parameters) && !strstr($all_strings, ",")) {
|
||
$all_strings .= ",''";
|
||
}
|
||
|
||
return "IFNULL($all_strings)";
|
||
case 'concat':
|
||
return "CONCAT($all_strings)";
|
||
case 'quarter':
|
||
return "QUARTER($string)";
|
||
case "length":
|
||
return "LENGTH($string)";
|
||
case 'month':
|
||
return "MONTH($string)";
|
||
case 'add_date':
|
||
return "DATE_ADD($string, INTERVAL {$additional_parameters[0]} {$additional_parameters[1]})";
|
||
case 'add_time':
|
||
return "DATE_ADD($string, INTERVAL + CONCAT({$additional_parameters[0]}, ':', {$additional_parameters[1]}) HOUR_MINUTE)";
|
||
case 'add_tz_offset':
|
||
$getUserUTCOffset = $GLOBALS['timedate']->getUserUTCOffset();
|
||
$operation = $getUserUTCOffset < 0 ? '-' : '+';
|
||
|
||
return $string . ' ' . $operation . ' INTERVAL ' . abs($getUserUTCOffset) . ' MINUTE';
|
||
case 'avg':
|
||
return "avg($string)";
|
||
case 'now':
|
||
return 'NOW()';
|
||
}
|
||
|
||
return $string;
|
||
}
|
||
|
||
/**
|
||
* (non-PHPdoc)
|
||
* @see DBManager::fromConvert()
|
||
*/
|
||
public function fromConvert($string, $type)
|
||
{
|
||
return $string;
|
||
}
|
||
|
||
/**
|
||
* Returns the name of the engine to use or null if we are to use the default
|
||
*
|
||
* @param object $bean SugarBean instance
|
||
* @return string
|
||
*/
|
||
protected function getEngine($bean)
|
||
{
|
||
global $dictionary;
|
||
$engine = null;
|
||
if (isset($dictionary[$bean->getObjectName()]['engine'])) {
|
||
$engine = $dictionary[$bean->getObjectName()]['engine'];
|
||
}
|
||
|
||
return $engine;
|
||
}
|
||
|
||
/**
|
||
* Returns true if the engine given is enabled in the backend
|
||
*
|
||
* @param string $engine
|
||
* @return bool
|
||
*/
|
||
protected function isEngineEnabled($engine)
|
||
{
|
||
if (!is_string($engine)) {
|
||
return false;
|
||
}
|
||
|
||
$engine = strtoupper($engine);
|
||
|
||
$r = $this->query("SHOW ENGINES");
|
||
|
||
while ($row = $this->fetchByAssoc($r)) {
|
||
if (strtoupper($row['Engine']) == $engine) {
|
||
return ($row['Support'] == 'YES' || $row['Support'] == 'DEFAULT');
|
||
}
|
||
}
|
||
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::createTableSQL()
|
||
*/
|
||
public function createTableSQL(SugarBean $bean)
|
||
{
|
||
$tablename = $bean->getTableName();
|
||
$fieldDefs = $bean->getFieldDefinitions();
|
||
$indices = $bean->getIndices();
|
||
$engine = $this->getEngine($bean);
|
||
|
||
return $this->createTableSQLParams($tablename, $fieldDefs, $indices, $engine);
|
||
}
|
||
|
||
/**
|
||
* Generates sql for create table statement for a bean.
|
||
*
|
||
* @param string $tablename
|
||
* @param array $fieldDefs
|
||
* @param array $indices
|
||
* @param string $engine optional, MySQL engine to use
|
||
* @return string SQL Create Table statement
|
||
*/
|
||
public function createTableSQLParams($tablename, $fieldDefs, $indices, $engine = null)
|
||
{
|
||
if (empty($engine) && isset($fieldDefs['engine'])) {
|
||
$engine = $fieldDefs['engine'];
|
||
}
|
||
if (!$this->isEngineEnabled($engine)) {
|
||
$engine = '';
|
||
}
|
||
|
||
$columns = $this->columnSQLRep($fieldDefs, false, $tablename);
|
||
if (empty($columns)) {
|
||
return false;
|
||
}
|
||
|
||
$keys = $this->keysSQL($indices);
|
||
if (!empty($keys)) {
|
||
$keys = ",$keys";
|
||
}
|
||
|
||
// cn: bug 9873 - module tables do not get created in utf8 with assoc collation
|
||
$collation = $this->getCollation();
|
||
$charset = $this->getCharset();
|
||
|
||
$sql = "CREATE TABLE $tablename ($columns $keys) CHARACTER SET $charset COLLATE $collation";
|
||
|
||
if (!empty($engine)) {
|
||
$sql .= " ENGINE=$engine";
|
||
}
|
||
|
||
return $sql;
|
||
}
|
||
|
||
/**
|
||
* Does this type represent text (i.e., non-varchar) value?
|
||
* @param string $type
|
||
*/
|
||
public function isTextType($type)
|
||
{
|
||
$type = $this->getColumnType(strtolower($type));
|
||
|
||
return in_array($type, array('blob', 'text', 'longblob', 'longtext'));
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::oneColumnSQLRep()
|
||
*/
|
||
protected function oneColumnSQLRep($fieldDef, $ignoreRequired = false, $table = '', $return_as_array = false)
|
||
{
|
||
// always return as array for post-processing
|
||
$ref = parent::oneColumnSQLRep($fieldDef, $ignoreRequired, $table, true);
|
||
|
||
if ($ref['colType'] == 'int' && !empty($fieldDef['len'])) {
|
||
$ref['colType'] .= "(" . $fieldDef['len'] . ")";
|
||
}
|
||
|
||
// bug 22338 - don't set a default value on text or blob fields
|
||
if (isset($ref['default']) &&
|
||
in_array($ref['colBaseType'], array('text', 'blob', 'longtext', 'longblob'))
|
||
) {
|
||
$ref['default'] = '';
|
||
}
|
||
|
||
// Quote the name column incase it has been reserved by dbms
|
||
$ref['name'] = $this->quoteIdentifier($ref['name']);
|
||
|
||
if ($return_as_array) {
|
||
return $ref;
|
||
} else {
|
||
return "{$ref['name']} {$ref['colType']} {$ref['default']} {$ref['required']} {$ref['auto_increment']}";
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::changeColumnSQL()
|
||
*/
|
||
protected function changeColumnSQL($tablename, $fieldDefs, $action, $ignoreRequired = false)
|
||
{
|
||
$columns = array();
|
||
if ($this->isFieldArray($fieldDefs)) {
|
||
foreach ($fieldDefs as $def) {
|
||
if ($action == 'drop') {
|
||
$columns[] = $def['name'];
|
||
} else {
|
||
$columns[] = $this->oneColumnSQLRep($def, $ignoreRequired);
|
||
}
|
||
}
|
||
} else {
|
||
if ($action == 'drop') {
|
||
$columns[] = $fieldDefs['name'];
|
||
} else {
|
||
$columns[] = $this->oneColumnSQLRep($fieldDefs);
|
||
}
|
||
}
|
||
|
||
return "ALTER TABLE $tablename $action COLUMN " . implode(",$action column ", $columns);
|
||
}
|
||
|
||
/**
|
||
* Generates SQL for key specification inside CREATE TABLE statement
|
||
*
|
||
* The passes array is an array of field definitions or a field definition
|
||
* itself. The keys generated will be either primary, foreign, unique, index
|
||
* or none at all depending on the setting of the "key" parameter of a field definition
|
||
*
|
||
* @param array $indices
|
||
* @param bool $alter_table
|
||
* @param string $alter_action
|
||
* @return string SQL Statement
|
||
*/
|
||
protected function keysSQL($indices, $alter_table = false, $alter_action = '')
|
||
{
|
||
// check if the passed value is an array of fields.
|
||
// if not, convert it into an array
|
||
if (!$this->isFieldArray($indices)) {
|
||
$indices[] = $indices;
|
||
}
|
||
|
||
$columns = array();
|
||
foreach ($indices as $index) {
|
||
if (!empty($index['db']) && $index['db'] != $this->dbType) {
|
||
continue;
|
||
}
|
||
if (isset($index['source']) && $index['source'] != 'db') {
|
||
continue;
|
||
}
|
||
|
||
$type = $index['type'];
|
||
$name = $index['name'];
|
||
|
||
if (is_array($index['fields'])) {
|
||
$fields = implode(", ", $index['fields']);
|
||
} else {
|
||
$fields = $index['fields'];
|
||
}
|
||
|
||
switch ($type) {
|
||
case 'unique':
|
||
$columns[] = " UNIQUE $name ($fields)";
|
||
break;
|
||
case 'primary':
|
||
$columns[] = " PRIMARY KEY ($fields)";
|
||
break;
|
||
case 'index':
|
||
case 'foreign':
|
||
case 'clustered':
|
||
case 'alternate_key':
|
||
/**
|
||
* @todo here it is assumed that the primary key of the foreign
|
||
* table will always be named 'id'. It must be noted though
|
||
* that this can easily be fixed by referring to db dictionary
|
||
* to find the correct primary field name
|
||
*/
|
||
if ($alter_table) {
|
||
$columns[] = " INDEX $name ($fields)";
|
||
} else {
|
||
$columns[] = " KEY $name ($fields)";
|
||
}
|
||
break;
|
||
case 'fulltext':
|
||
if ($this->full_text_indexing_installed()) {
|
||
$columns[] = " FULLTEXT ($fields)";
|
||
} else {
|
||
$GLOBALS['log']->debug(
|
||
'MYISAM engine is not available/enabled, full-text indexes will be skipped. Skipping:',
|
||
$name
|
||
);
|
||
}
|
||
break;
|
||
}
|
||
}
|
||
$columns = implode(", $alter_action ", $columns);
|
||
if (!empty($alter_action)) {
|
||
$columns = $alter_action . ' ' . $columns;
|
||
}
|
||
|
||
return $columns;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::setAutoIncrement()
|
||
*/
|
||
protected function setAutoIncrement($table, $field_name)
|
||
{
|
||
return "auto_increment";
|
||
}
|
||
|
||
/**
|
||
* Sets the next auto-increment value of a column to a specific value.
|
||
*
|
||
* @param string $table tablename
|
||
* @param string $field_name
|
||
*/
|
||
public function setAutoIncrementStart($table, $field_name, $start_value)
|
||
{
|
||
$start_value = (int)$start_value;
|
||
|
||
return $this->query("ALTER TABLE $table AUTO_INCREMENT = $start_value;");
|
||
}
|
||
|
||
/**
|
||
* Returns the next value for an auto increment
|
||
*
|
||
* @param string $table tablename
|
||
* @param string $field_name
|
||
* @return string
|
||
*/
|
||
public function getAutoIncrement($table, $field_name)
|
||
{
|
||
$result = $this->query("SHOW TABLE STATUS LIKE '$table'");
|
||
$row = $this->fetchByAssoc($result);
|
||
if (!empty($row['Auto_increment'])) {
|
||
return $row['Auto_increment'];
|
||
}
|
||
|
||
return "";
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::get_indices()
|
||
*/
|
||
public function get_indices($tablename)
|
||
{
|
||
//find all unique indexes and primary keys.
|
||
$result = $this->query("SHOW INDEX FROM $tablename");
|
||
|
||
$indices = array();
|
||
while (($row = $this->fetchByAssoc($result)) != null) {
|
||
$index_type = 'index';
|
||
if ($row['Key_name'] == 'PRIMARY') {
|
||
$index_type = 'primary';
|
||
} elseif ($row['Non_unique'] == '0') {
|
||
$index_type = 'unique';
|
||
}
|
||
$name = strtolower($row['Key_name']);
|
||
$indices[$name]['name'] = $name;
|
||
$indices[$name]['type'] = $index_type;
|
||
$field = strtolower($row['Column_name']);
|
||
|
||
if (is_numeric($row['Sub_part'])) {
|
||
$field = strtolower($row['Column_name'])." ({$row['Sub_part']})";
|
||
}
|
||
$indices[$name]['fields'][] = $field;
|
||
}
|
||
|
||
return $indices;
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::add_drop_constraint()
|
||
*/
|
||
public function add_drop_constraint($table, $definition, $drop = false)
|
||
{
|
||
$type = $definition['type'];
|
||
$fields = implode(',', $definition['fields']);
|
||
$name = $definition['name'];
|
||
$sql = '';
|
||
|
||
switch ($type) {
|
||
// generic indices
|
||
case 'index':
|
||
case 'alternate_key':
|
||
case 'clustered':
|
||
if ($drop) {
|
||
$sql = "ALTER TABLE {$table} DROP INDEX {$name} ";
|
||
} else {
|
||
$sql = "ALTER TABLE {$table} ADD INDEX {$name} ({$fields})";
|
||
}
|
||
break;
|
||
// constraints as indices
|
||
case 'unique':
|
||
if ($drop) {
|
||
$sql = "ALTER TABLE {$table} DROP INDEX $name";
|
||
} else {
|
||
$sql = "ALTER TABLE {$table} ADD CONSTRAINT UNIQUE {$name} ({$fields})";
|
||
}
|
||
break;
|
||
case 'primary':
|
||
if ($drop) {
|
||
$sql = "ALTER TABLE {$table} DROP PRIMARY KEY";
|
||
} else {
|
||
$sql = "ALTER TABLE {$table} ADD CONSTRAINT PRIMARY KEY ({$fields})";
|
||
}
|
||
break;
|
||
case 'foreign':
|
||
if ($drop) {
|
||
$sql = "ALTER TABLE {$table} DROP FOREIGN KEY ({$fields})";
|
||
} else {
|
||
$sql = "ALTER TABLE {$table} ADD CONSTRAINT FOREIGN KEY {$name} ({$fields}) REFERENCES {$definition['foreignTable']}({$definition['foreignField']})";
|
||
}
|
||
break;
|
||
}
|
||
|
||
return $sql;
|
||
}
|
||
|
||
/**
|
||
* Runs a query and returns a single row
|
||
*
|
||
* @param string $sql SQL Statement to execute
|
||
* @param bool $dieOnError True if we want to call die if the query returns errors
|
||
* @param string $msg Message to log if error occurs
|
||
* @param bool $suppress Message to log if error occurs
|
||
* @return array single row from the query
|
||
*/
|
||
public function fetchOne($sql, $dieOnError = false, $msg = '', $suppress = false)
|
||
{
|
||
if (stripos($sql, ' LIMIT ') === false) {
|
||
// little optimization to just fetch one row
|
||
$sql .= " LIMIT 0,1";
|
||
}
|
||
|
||
return parent::fetchOne($sql, $dieOnError, $msg, $suppress);
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::full_text_indexing_installed()
|
||
*/
|
||
public function full_text_indexing_installed($dbname = null)
|
||
{
|
||
return $this->isEngineEnabled('MyISAM');
|
||
}
|
||
|
||
/**
|
||
* @see DBManager::massageFieldDef()
|
||
*/
|
||
public function massageFieldDef(&$fieldDef, $tablename)
|
||
{
|
||
parent::massageFieldDef($fieldDef, $tablename);
|
||
|
||
if (isset($fieldDef['default']) &&
|
||
($fieldDef['dbType'] == 'text'
|
||
|| $fieldDef['dbType'] == 'blob'
|
||
|| $fieldDef['dbType'] == 'longtext'
|
||
|| $fieldDef['dbType'] == 'longblob')
|
||
) {
|
||
unset($fieldDef['default']);
|
||
}
|
||
if ($fieldDef['dbType'] == 'uint') {
|
||
$fieldDef['len'] = '10';
|
||
}
|
||
if ($fieldDef['dbType'] == 'ulong') {
|
||
$fieldDef['len'] = '20';
|
||
}
|
||
if ($fieldDef['dbType'] == 'bool') {
|
||
$fieldDef['type'] = 'tinyint';
|
||
}
|
||
if ($fieldDef['dbType'] == 'bool' && empty($fieldDef['default'])) {
|
||
$fieldDef['default'] = '0';
|
||
}
|
||
if (($fieldDef['dbType'] == 'varchar' || $fieldDef['dbType'] == 'enum') && empty($fieldDef['len'])) {
|
||
$fieldDef['len'] = '255';
|
||
}
|
||
if ($fieldDef['dbType'] == 'uint') {
|
||
$fieldDef['len'] = '10';
|
||
}
|
||
if ($fieldDef['dbType'] == 'int' && empty($fieldDef['len'])) {
|
||
$fieldDef['len'] = '11';
|
||
}
|
||
|
||
if ($fieldDef['dbType'] == 'decimal') {
|
||
if (isset($fieldDef['len'])) {
|
||
if (strstr((string) $fieldDef['len'], ",") === false) {
|
||
$fieldDef['len'] .= ",0";
|
||
}
|
||
} else {
|
||
$fieldDef['len'] = '10,0';
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Generates SQL for dropping a table.
|
||
*
|
||
* @param string $name table name
|
||
* @return string SQL statement
|
||
*/
|
||
public function dropTableNameSQL($name)
|
||
{
|
||
return "DROP TABLE IF EXISTS " . $name;
|
||
}
|
||
|
||
public function dropIndexes($tablename, $indexes, $execute = true)
|
||
{
|
||
$sql = array();
|
||
foreach ($indexes as $index) {
|
||
$name = $index['name'];
|
||
if ($execute) {
|
||
unset(self::$index_descriptions[$tablename][$name]);
|
||
}
|
||
if ($index['type'] == 'primary') {
|
||
$sql[] = 'DROP PRIMARY KEY';
|
||
} else {
|
||
$sql[] = "DROP INDEX $name";
|
||
}
|
||
}
|
||
if (!empty($sql)) {
|
||
$sql = "ALTER TABLE $tablename " . implode(",", $sql) . ";";
|
||
if ($execute) {
|
||
$this->query($sql);
|
||
}
|
||
} else {
|
||
$sql = '';
|
||
}
|
||
|
||
return $sql;
|
||
}
|
||
|
||
/**
|
||
* Get default collation settings
|
||
* @return string
|
||
*/
|
||
public function getCollation()
|
||
{
|
||
$collation = $this->getOption('collation');
|
||
if (empty($collation)) {
|
||
$collation = $this->getDefaultCollation();
|
||
}
|
||
|
||
return $this->quote($collation);
|
||
}
|
||
|
||
/**
|
||
* Get default charset settings
|
||
* @return string
|
||
*/
|
||
public function getCharset()
|
||
{
|
||
$charset = $this->getOption('charset');
|
||
if (empty($charset)) {
|
||
$charset = $this->getDefaultCharset();
|
||
}
|
||
|
||
return $this->quote($charset);
|
||
}
|
||
|
||
/**
|
||
* List of available collation settings
|
||
* @return string
|
||
*/
|
||
public function getDefaultCollation()
|
||
{
|
||
return 'utf8_general_ci';
|
||
}
|
||
|
||
/**
|
||
* Get default charset settings
|
||
* @return string
|
||
*/
|
||
public function getDefaultCharset()
|
||
{
|
||
return 'utf8';
|
||
}
|
||
|
||
/**
|
||
* List of available collation settings
|
||
* @return array
|
||
*/
|
||
public function getCollationList()
|
||
{
|
||
$q = "SHOW COLLATION LIKE 'utf8%'";
|
||
$r = $this->query($q);
|
||
$res = array();
|
||
while ($a = $this->fetchByAssoc($r)) {
|
||
$res[] = $a['Collation'];
|
||
}
|
||
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* (non-PHPdoc)
|
||
* @see DBManager::renameColumnSQL()
|
||
*/
|
||
public function renameColumnSQL($tablename, $column, $newname)
|
||
{
|
||
$field = $this->describeField($column, $tablename);
|
||
$field['name'] = $newname;
|
||
|
||
return "ALTER TABLE $tablename CHANGE COLUMN $column " . $this->oneColumnSQLRep($field);
|
||
}
|
||
|
||
public function emptyValue($type)
|
||
{
|
||
$ctype = $this->getColumnType($type);
|
||
if ($ctype == "datetime") {
|
||
return 'NULL';
|
||
}
|
||
if ($ctype == "date") {
|
||
return 'NULL';
|
||
}
|
||
if ($ctype == "time") {
|
||
return 'NULL';
|
||
}
|
||
|
||
return parent::emptyValue($type);
|
||
}
|
||
|
||
/**
|
||
* (non-PHPdoc)
|
||
* @see DBManager::lastDbError()
|
||
*/
|
||
public function lastDbError()
|
||
{
|
||
if ($this->database) {
|
||
if (mysql_errno($this->database)) {
|
||
return "MySQL error " . mysql_errno($this->database) . ": " . mysql_error($this->database);
|
||
}
|
||
} else {
|
||
$err = mysql_error();
|
||
if ($err) {
|
||
return $err;
|
||
}
|
||
}
|
||
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* Quote MySQL search term
|
||
* @param unknown_type $term
|
||
*/
|
||
protected function quoteTerm($term)
|
||
{
|
||
if (strpos($term, ' ') !== false) {
|
||
return '"' . $term . '"';
|
||
}
|
||
|
||
return $term;
|
||
}
|
||
|
||
/**
|
||
* Generate fulltext query from set of terms
|
||
* @param string $fields Field to search against
|
||
* @param array $terms Search terms that may be or not be in the result
|
||
* @param array $must_terms Search terms that have to be in the result
|
||
* @param array $exclude_terms Search terms that have to be not in the result
|
||
*/
|
||
public function getFulltextQuery($field, $terms, $must_terms = array(), $exclude_terms = array())
|
||
{
|
||
$condition = array();
|
||
foreach ($terms as $term) {
|
||
$condition[] = $this->quoteTerm($term);
|
||
}
|
||
foreach ($must_terms as $term) {
|
||
$condition[] = "+" . $this->quoteTerm($term);
|
||
}
|
||
foreach ($exclude_terms as $term) {
|
||
$condition[] = "-" . $this->quoteTerm($term);
|
||
}
|
||
$condition = $this->quoted(implode(" ", $condition));
|
||
|
||
return "MATCH($field) AGAINST($condition IN BOOLEAN MODE)";
|
||
}
|
||
|
||
/**
|
||
* Get list of all defined charsets
|
||
* @return array
|
||
*/
|
||
protected function getCharsetInfo()
|
||
{
|
||
$charsets = array();
|
||
$res = $this->query("show variables like 'character\\_set\\_%'");
|
||
while ($row = $this->fetchByAssoc($res)) {
|
||
$charsets[$row['Variable_name']] = $row['Value'];
|
||
}
|
||
|
||
return $charsets;
|
||
}
|
||
|
||
public function getDbInfo()
|
||
{
|
||
$charsets = $this->getCharsetInfo();
|
||
$charset_str = array();
|
||
foreach ($charsets as $name => $value) {
|
||
$charset_str[] = "$name = $value";
|
||
}
|
||
|
||
return array(
|
||
"MySQL Version" => @mysql_get_client_info(),
|
||
"MySQL Host Info" => @mysql_get_host_info($this->database),
|
||
"MySQL Server Info" => @mysql_get_server_info($this->database),
|
||
"MySQL Client Encoding" => @mysql_client_encoding($this->database),
|
||
"MySQL Character Set Settings" => implode(", ", $charset_str),
|
||
);
|
||
}
|
||
|
||
public function validateQuery($query)
|
||
{
|
||
$res = $this->query("EXPLAIN $query");
|
||
|
||
return !empty($res);
|
||
}
|
||
|
||
protected function makeTempTableCopy($table)
|
||
{
|
||
$this->log->debug("creating temp table for [$table]...");
|
||
$result = $this->query("SHOW CREATE TABLE {$table}");
|
||
if (empty($result)) {
|
||
return false;
|
||
}
|
||
$row = $this->fetchByAssoc($result);
|
||
if (empty($row) || empty($row['Create Table'])) {
|
||
return false;
|
||
}
|
||
$create = $row['Create Table'];
|
||
// rewrite DDL with _temp name
|
||
$tempTableQuery = str_replace("CREATE TABLE `{$table}`", "CREATE TABLE `{$table}__uw_temp`", (string) $create);
|
||
$r2 = $this->query($tempTableQuery);
|
||
if (empty($r2)) {
|
||
return false;
|
||
}
|
||
|
||
// get sample data into the temp table to test for data/constraint conflicts
|
||
$this->log->debug('inserting temp dataset...');
|
||
$q3 = "INSERT INTO `{$table}__uw_temp` SELECT * FROM `{$table}` LIMIT 10";
|
||
$this->query($q3, false, "Preflight Failed for: {$q3}");
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* Tests an ALTER TABLE query
|
||
* @param string table The table name to get DDL
|
||
* @param string query The query to test.
|
||
* @return string Non-empty if error found
|
||
*/
|
||
protected function verifyAlterTable($table, $query)
|
||
{
|
||
$this->log->debug("verifying ALTER TABLE");
|
||
// Skipping ALTER TABLE [table] DROP PRIMARY KEY because primary keys are not being copied
|
||
// over to the temp tables
|
||
if (strpos(strtoupper($query), 'DROP PRIMARY KEY') !== false) {
|
||
$this->log->debug("Skipping DROP PRIMARY KEY");
|
||
|
||
return '';
|
||
}
|
||
if (!$this->makeTempTableCopy($table)) {
|
||
return 'Could not create temp table copy';
|
||
}
|
||
|
||
// test the query on the test table
|
||
$this->log->debug('testing query: [' . $query . ']');
|
||
$tempTableTestQuery = str_replace("ALTER TABLE `{$table}`", "ALTER TABLE `{$table}__uw_temp`", (string) $query);
|
||
if (strpos($tempTableTestQuery, 'idx') === false) {
|
||
if (strpos($tempTableTestQuery, '__uw_temp') === false) {
|
||
return 'Could not use a temp table to test query!';
|
||
}
|
||
|
||
$this->log->debug('testing query on temp table: [' . $tempTableTestQuery . ']');
|
||
$this->query($tempTableTestQuery, false, "Preflight Failed for: {$query}");
|
||
} else {
|
||
// test insertion of an index on a table
|
||
$tempTableTestQuery_idx = str_replace("ADD INDEX `idx_", "ADD INDEX `temp_idx_", $tempTableTestQuery);
|
||
$this->log->debug('testing query on temp table: [' . $tempTableTestQuery_idx . ']');
|
||
$this->query($tempTableTestQuery_idx, false, "Preflight Failed for: {$query}");
|
||
}
|
||
$mysqlError = $this->getL();
|
||
if (!empty($mysqlError)) {
|
||
return $mysqlError;
|
||
}
|
||
$this->dropTableName("{$table}__uw_temp");
|
||
|
||
return '';
|
||
}
|
||
|
||
protected function verifyGenericReplaceQuery($querytype, $table, $query)
|
||
{
|
||
$this->log->debug("verifying $querytype statement");
|
||
|
||
if (!$this->makeTempTableCopy($table)) {
|
||
return 'Could not create temp table copy';
|
||
}
|
||
// test the query on the test table
|
||
$this->log->debug('testing query: [' . $query . ']');
|
||
$tempTableTestQuery = str_replace("$querytype `{$table}`", "$querytype `{$table}__uw_temp`", (string) $query);
|
||
if (strpos($tempTableTestQuery, '__uw_temp') === false) {
|
||
return 'Could not use a temp table to test query!';
|
||
}
|
||
|
||
$this->query($tempTableTestQuery, false, "Preflight Failed for: {$query}");
|
||
$error = $this->lastError(); // empty on no-errors
|
||
$this->dropTableName("{$table}__uw_temp"); // just in case
|
||
|
||
return $error;
|
||
}
|
||
|
||
/**
|
||
* Tests a DROP TABLE query
|
||
* @param string table The table name to get DDL
|
||
* @param string query The query to test.
|
||
* @return string Non-empty if error found
|
||
*/
|
||
public function verifyDropTable($table, $query)
|
||
{
|
||
return $this->verifyGenericReplaceQuery("DROP TABLE", $table, $query);
|
||
}
|
||
|
||
/**
|
||
* Tests an INSERT INTO query
|
||
* @param string table The table name to get DDL
|
||
* @param string query The query to test.
|
||
* @return string Non-empty if error found
|
||
*/
|
||
public function verifyInsertInto($table, $query)
|
||
{
|
||
return $this->verifyGenericReplaceQuery("INSERT INTO", $table, $query);
|
||
}
|
||
|
||
/**
|
||
* Tests an UPDATE query
|
||
* @param string table The table name to get DDL
|
||
* @param string query The query to test.
|
||
* @return string Non-empty if error found
|
||
*/
|
||
public function verifyUpdate($table, $query)
|
||
{
|
||
return $this->verifyGenericReplaceQuery("UPDATE", $table, $query);
|
||
}
|
||
|
||
/**
|
||
* Tests an DELETE FROM query
|
||
* @param string table The table name to get DDL
|
||
* @param string query The query to test.
|
||
* @return string Non-empty if error found
|
||
*/
|
||
public function verifyDeleteFrom($table, $query)
|
||
{
|
||
return $this->verifyGenericReplaceQuery("DELETE FROM", $table, $query);
|
||
}
|
||
|
||
/**
|
||
* Check if certain database exists
|
||
* @param string $dbname
|
||
*/
|
||
public function dbExists($dbname)
|
||
{
|
||
$db = $this->getOne("SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME = " . $this->quoted($dbname));
|
||
|
||
return !empty($db);
|
||
}
|
||
|
||
/**
|
||
* Select database
|
||
* @param string $dbname
|
||
*/
|
||
protected function selectDb($dbname)
|
||
{
|
||
return mysql_select_db($dbname);
|
||
}
|
||
|
||
/**
|
||
* Check if certain DB user exists
|
||
* @param string $username
|
||
*/
|
||
public function userExists($username)
|
||
{
|
||
$db = $this->getOne("SELECT DATABASE()");
|
||
if (!$this->selectDb("mysql")) {
|
||
return false;
|
||
}
|
||
$user = $this->getOne("select count(*) from user where user = " . $this->quoted($username));
|
||
if (!$this->selectDb($db)) {
|
||
$this->checkError("Cannot select database $db", true);
|
||
}
|
||
|
||
return !empty($user);
|
||
}
|
||
|
||
/**
|
||
* Create DB user
|
||
* @param string $database_name
|
||
* @param string $host_name
|
||
* @param string $user
|
||
* @param string $password
|
||
*/
|
||
public function createDbUser($database_name, $host_name, $user, $password)
|
||
{
|
||
$qpassword = $this->quote($password);
|
||
$this->query("GRANT SELECT, INSERT, UPDATE, DELETE, CREATE, ALTER, DROP, INDEX
|
||
ON `$database_name`.*
|
||
TO \"$user\"@\"$host_name\"
|
||
IDENTIFIED BY '{$qpassword}';", true);
|
||
|
||
$this->query("SET PASSWORD FOR \"{$user}\"@\"{$host_name}\" = password('{$qpassword}');", true);
|
||
if ($host_name != 'localhost') {
|
||
$this->createDbUser($database_name, "localhost", $user, $password);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Create a database
|
||
* @param string $dbname
|
||
*/
|
||
public function createDatabase($dbname)
|
||
{
|
||
$collation = $this->getCollation();
|
||
$charset = $this->getCharset();
|
||
|
||
$this->query("CREATE DATABASE `$dbname` CHARACTER SET $charset COLLATE $collation", true);
|
||
}
|
||
|
||
public function preInstall()
|
||
{
|
||
$setup_db_database_name = '';
|
||
$collation = $this->getCollation();
|
||
$charset = $this->getCharset();
|
||
|
||
$this->query("ALTER DATABASE `{$setup_db_database_name}` DEFAULT CHARACTER SET $charset", true);
|
||
$this->query("ALTER DATABASE `{$setup_db_database_name}` DEFAULT COLLATE $collation", true);
|
||
}
|
||
|
||
/**
|
||
* Drop a database
|
||
* @param string $dbname
|
||
*/
|
||
public function dropDatabase($dbname)
|
||
{
|
||
return $this->query("DROP DATABASE IF EXISTS `$dbname`", true);
|
||
}
|
||
|
||
/**
|
||
* Check if this driver can be used
|
||
* @return bool
|
||
*/
|
||
public function valid()
|
||
{
|
||
return function_exists("mysql_connect");
|
||
}
|
||
|
||
/**
|
||
* Check DB version
|
||
* @see DBManager::canInstall()
|
||
*/
|
||
public function canInstall()
|
||
{
|
||
$db_version = $this->version();
|
||
if (empty($db_version)) {
|
||
return array('ERR_DB_VERSION_FAILURE');
|
||
}
|
||
if (version_compare($db_version, '4.1.2') < 0) {
|
||
return array('ERR_DB_MYSQL_VERSION', $db_version);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
public function installConfig()
|
||
{
|
||
return array(
|
||
'LBL_DBCONFIG_MSG3' => array(
|
||
"setup_db_database_name" => array("label" => 'LBL_DBCONF_DB_NAME', "required" => true),
|
||
),
|
||
'LBL_DBCONFIG_MSG2' => array(
|
||
"setup_db_host_name" => array("label" => 'LBL_DBCONF_HOST_NAME', "required" => true),
|
||
),
|
||
'LBL_DBCONF_TITLE_USER_INFO' => array(),
|
||
'LBL_DBCONFIG_B_MSG1' => array(
|
||
"setup_db_admin_user_name" => array("label" => 'LBL_DBCONF_DB_ADMIN_USER', "required" => true),
|
||
"setup_db_admin_password" => array("label" => 'LBL_DBCONF_DB_ADMIN_PASSWORD', "type" => "password"),
|
||
)
|
||
);
|
||
}
|
||
|
||
/**
|
||
* Disable keys on the table
|
||
* @abstract
|
||
* @param string $tableName
|
||
*/
|
||
public function disableKeys($tableName)
|
||
{
|
||
return $this->query('ALTER TABLE ' . $tableName . ' DISABLE KEYS');
|
||
}
|
||
|
||
/**
|
||
* Re-enable keys on the table
|
||
* @abstract
|
||
* @param string $tableName
|
||
*/
|
||
public function enableKeys($tableName)
|
||
{
|
||
return $this->query('ALTER TABLE ' . $tableName . ' ENABLE KEYS');
|
||
}
|
||
|
||
/**
|
||
* Returns a DB specific FROM clause which can be used to select against functions.
|
||
* Note that depending on the database that this may also be an empty string.
|
||
* @return string
|
||
*/
|
||
public function getFromDummyTable()
|
||
{
|
||
return '';
|
||
}
|
||
|
||
/**
|
||
* Returns a DB specific piece of SQL which will generate GUID (UUID)
|
||
* This string can be used in dynamic SQL to do multiple inserts with a single query.
|
||
* I.e. generate a unique Sugar id in a sub select of an insert statement.
|
||
* @return string
|
||
*/
|
||
|
||
public function getGuidSQL()
|
||
{
|
||
return 'UUID()';
|
||
}
|
||
}
|