fanbinit/rhymix
1
0
Fork 0
mirror of https://github.com/Lastorder-DC/rhymix.git synced 2026-05-01 16:22:41 +09:00
Code Issues Projects Releases Packages Wiki Activity

add priority_hint to mysql

Browse source 
git-svn-id: http://xe-core.googlecode.com/svn/branches/1.5.0@9485 201d5d3c-b55e-5fd7-737f-ddc643e51545
This commit is contained in:
lickawtl 2011-10-04 16:58:40 +00:00
parent cc7477d4e3
commit 055b7e0d68
4 changed files with 30 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

16
classes/db/DB.class.php
View file

@ -583,9 +583,10 @@
return $select . ' ' . $from . ' ' . $where . ' ' . $index_hint_list . ' ' . $groupBy . ' ' . $orderBy . ' ' . $limit;
}
function getDeleteSql($query, $with_values = true){
function getDeleteSql($query, $with_values = true, $with_priority = false){
$sql = 'DELETE ';
$sql .= $with_priority?$query->getPriority():'';
$tables = $query->getTables();
$sql .= $tables[0]->getAlias();
@ -600,7 +601,7 @@
return $sql;
}
function getUpdateSql($query, $with_values = true){
function getUpdateSql($query, $with_values = true, $with_priority = false){
$columnsList = $query->getUpdateString($with_values);
if($columnsList == '') return new Object(-1, "Invalid query");
@ -609,15 +610,18 @@
$where = $query->getWhereString($with_values);
if($where != '') $where = ' WHERE ' . $where;
$priority = $with_priority?$query->getPriority():'';
return "UPDATE $tableName SET $columnsList ".$where;
return "UPDATE $priority $tableName SET $columnsList ".$where;
}
function getInsertSql($query, $with_values = true){
function getInsertSql($query, $with_values = true, $with_priority = false){
$tableName = $query->getFirstTableName();
$values = $query->getInsertString($with_values);
return "INSERT INTO $tableName \n $values";
$priority = $with_priority?$query->getPriority():'';
return "INSERT $priority INTO $tableName \n $values";
}
function _getSlaveConnectionStringIndex() {

6
classes/db/DBMysql.class.php
View file

@ -369,7 +369,7 @@
//$priority = '';
//if($output->priority) $priority = $output->priority['type'].'_priority';
$query = $this->getInsertSql($queryObject);
$query = $this->getInsertSql($queryObject, true, true);
if(is_a($query, 'Object')) return;
return $this->_query($query);
}
@ -383,7 +383,7 @@
//$priority = '';
//if($output->priority) $priority = $output->priority['type'].'_priority';
$query = $this->getUpdateSql($queryObject);
$query = $this->getUpdateSql($queryObject, true, true);
if(is_a($query, 'Object')) return;
return $this->_query($query);
}
@ -392,7 +392,7 @@
* @brief Handle deleteAct
**/
function _executeDeleteAct($queryObject) {
$query = $this->getDeleteSql($queryObject);
$query = $this->getDeleteSql($queryObject, true, true);
if(is_a($query, 'Object')) return;

10
classes/db/queryparts/Query.class.php
View file

@ -3,6 +3,7 @@
class Query extends Object {
var $queryID;
var $action;
var $priority;
var $columns;
var $tables;
@ -27,6 +28,7 @@
, $limit = null){
$this->queryID = $queryID;
$this->action = $action;
$this->priority = $priority;
if(!isset($tables)) return;
$this->columns = $this->setColumns($columns);
@ -48,6 +50,10 @@
function setAction($action){
$this->action = $action;
}
function setPriority($priority){
$this->priority = $priority;
}
function setColumnList($columnList){
$this->columnList = $columnList;
@ -152,6 +158,10 @@
function getAction(){
return $this->action;
}
function getPriority(){
return $this->priority?'LOW_PRIORITY':'';
}
function getSelectString($with_values = true){
foreach($this->columns as $column){