This reverts commit ed130065
.
Conflicts:
adminer/drivers/mongo.inc.php
adminer/include/functions.inc.php
111 lines
3.1 KiB
PHP
111 lines
3.1 KiB
PHP
<?php
|
|
|
|
/*abstract*/ class Min_SQL {
|
|
var $_conn;
|
|
|
|
/** Create object for performing database operations
|
|
* @param Min_DB
|
|
*/
|
|
function Min_SQL($connection) {
|
|
$this->_conn = $connection;
|
|
}
|
|
|
|
/** Select data from table
|
|
* @param string
|
|
* @param array result of $adminer->selectColumnsProcess()[0]
|
|
* @param array result of $adminer->selectSearchProcess()
|
|
* @param array result of $adminer->selectColumnsProcess()[1]
|
|
* @param array result of $adminer->selectOrderProcess()
|
|
* @param int result of $adminer->selectLimitProcess()
|
|
* @param int index of page starting at zero
|
|
* @param bool whether to print the query
|
|
* @return Min_Result
|
|
*/
|
|
function select($table, $select, $where, $group, $order = array(), $limit = 1, $page = 0, $print = false) {
|
|
global $adminer, $jush;
|
|
$is_group = (count($group) < count($select));
|
|
$query = $adminer->selectQueryBuild($select, $where, $group, $order, $limit, $page);
|
|
if (!$query) {
|
|
$query = "SELECT" . limit(
|
|
($_GET["page"] != "last" && +$limit && $group && $is_group && $jush == "sql" ? "SQL_CALC_FOUND_ROWS " : "") . implode(", ", $select) . "\nFROM " . table($table),
|
|
($where ? "\nWHERE " . implode(" AND ", $where) : "") . ($group && $is_group ? "\nGROUP BY " . implode(", ", $group) : "") . ($order ? "\nORDER BY " . implode(", ", $order) : ""),
|
|
($limit != "" ? +$limit : null),
|
|
($page ? $limit * $page : 0),
|
|
"\n"
|
|
);
|
|
}
|
|
$start = microtime(true);
|
|
$return = $this->_conn->query($query);
|
|
if ($print) {
|
|
echo $adminer->selectQuery($query, format_time($start));
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
/** Delete data from table
|
|
* @param string
|
|
* @param string " WHERE ..."
|
|
* @param int 0 or 1
|
|
* @return bool
|
|
*/
|
|
function delete($table, $queryWhere, $limit = 0) {
|
|
$query = "FROM " . table($table);
|
|
return queries("DELETE" . ($limit ? limit1($query, $queryWhere) : " $query$queryWhere"));
|
|
}
|
|
|
|
/** Update data in table
|
|
* @param string
|
|
* @param array escaped columns in keys, quoted data in values
|
|
* @param string " WHERE ..."
|
|
* @param int 0 or 1
|
|
* @param string
|
|
* @return bool
|
|
*/
|
|
function update($table, $set, $queryWhere, $limit = 0, $separator = "\n") {
|
|
$values = array();
|
|
foreach ($set as $key => $val) {
|
|
$values[] = "$key = $val";
|
|
}
|
|
$query = table($table) . " SET$separator" . implode(",$separator", $values);
|
|
return queries("UPDATE" . ($limit ? limit1($query, $queryWhere) : " $query$queryWhere"));
|
|
}
|
|
|
|
/** Insert data into table
|
|
* @param string
|
|
* @param array escaped columns in keys, quoted data in values
|
|
* @return bool
|
|
*/
|
|
function insert($table, $set) {
|
|
return queries("INSERT INTO " . table($table) . ($set
|
|
? " (" . implode(", ", array_keys($set)) . ")\nVALUES (" . implode(", ", $set) . ")"
|
|
: " DEFAULT VALUES"
|
|
));
|
|
}
|
|
|
|
/** Insert or update data in table
|
|
* @param string
|
|
* @param array
|
|
* @param array of arrays with escaped columns in keys and quoted data in values
|
|
* @return bool
|
|
*/
|
|
/*abstract*/ function insertUpdate($table, $rows, $primary) {
|
|
return false;
|
|
}
|
|
|
|
/** Begin transaction
|
|
* @return bool
|
|
*/
|
|
function begin() {
|
|
return queries("BEGIN");
|
|
}
|
|
|
|
function commit() {
|
|
return queries("COMMIT");
|
|
}
|
|
|
|
function rollback() {
|
|
return queries("ROLLBACK");
|
|
}
|
|
|
|
}
|