namespace Friendica\Database;
-use Friendica\BaseObject;
+use Friendica\DI;
use mysqli;
use mysqli_result;
use mysqli_stmt;
*
* This class is for the low level database stuff that does driver specific things.
*/
-class DBA extends BaseObject
+class DBA
{
/**
* Lowest possible date value
public static function connect()
{
- return self::getClass(Database::class)->connect();
+ return DI::dba()->connect();
}
/**
*/
public static function disconnect()
{
- self::getClass(Database::class)->disconnect();
+ DI::dba()->disconnect();
}
/**
*/
public static function reconnect()
{
- return self::getClass(Database::class)->reconnect();
+ return DI::dba()->reconnect();
}
/**
*/
public static function getConnection()
{
- return self::getClass(Database::class)->getConnection();
+ return DI::dba()->getConnection();
}
/**
*/
public static function serverInfo()
{
- return self::getClass(Database::class)->serverInfo();
+ return DI::dba()->serverInfo();
}
/**
*/
public static function databaseName()
{
- return self::getClass(Database::class)->databaseName();
+ return DI::dba()->databaseName();
}
public static function escape($str)
{
- return self::getClass(Database::class)->escape($str);
+ return DI::dba()->escape($str);
}
public static function connected()
{
- return self::getClass(Database::class)->connected();
+ return DI::dba()->connected();
}
/**
*/
public static function anyValueFallback($sql)
{
- return self::getClass(Database::class)->anyValueFallback($sql);
+ return DI::dba()->anyValueFallback($sql);
}
/**
{
$params = self::getParam(func_get_args());
- return self::getClass(Database::class)->p($sql, $params);
+ return DI::dba()->p($sql, $params);
}
/**
$params = self::getParam(func_get_args());
- return self::getClass(Database::class)->e($sql, $params);
+ return DI::dba()->e($sql, $params);
}
/**
*/
public static function exists($table, $condition)
{
- return self::getClass(Database::class)->exists($table, $condition);
+ return DI::dba()->exists($table, $condition);
}
/**
{
$params = self::getParam(func_get_args());
- return self::getClass(Database::class)->fetchFirst($sql, $params);
+ return DI::dba()->fetchFirst($sql, $params);
}
/**
*/
public static function affectedRows()
{
- return self::getClass(Database::class)->affectedRows();
+ return DI::dba()->affectedRows();
}
/**
*/
public static function columnCount($stmt)
{
- return self::getClass(Database::class)->columnCount($stmt);
+ return DI::dba()->columnCount($stmt);
}
/**
* @brief Returns the number of rows of a statement
*/
public static function numRows($stmt)
{
- return self::getClass(Database::class)->numRows($stmt);
+ return DI::dba()->numRows($stmt);
}
/**
*/
public static function fetch($stmt)
{
- return self::getClass(Database::class)->fetch($stmt);
+ return DI::dba()->fetch($stmt);
}
/**
*/
public static function insert($table, $param, $on_duplicate_update = false)
{
- return self::getClass(Database::class)->insert($table, $param, $on_duplicate_update);
+ return DI::dba()->insert($table, $param, $on_duplicate_update);
}
/**
*/
public static function lastInsertId()
{
- return self::getClass(Database::class)->lastInsertId();
+ return DI::dba()->lastInsertId();
}
/**
*/
public static function lock($table)
{
- return self::getClass(Database::class)->lock($table);
+ return DI::dba()->lock($table);
}
/**
*/
public static function unlock()
{
- return self::getClass(Database::class)->unlock();
+ return DI::dba()->unlock();
}
/**
*/
public static function transaction()
{
- return self::getClass(Database::class)->transaction();
+ return DI::dba()->transaction();
}
/**
*/
public static function commit()
{
- return self::getClass(Database::class)->commit();
+ return DI::dba()->commit();
}
/**
*/
public static function rollback()
{
- return self::getClass(Database::class)->rollback();
+ return DI::dba()->rollback();
}
/**
*/
public static function delete($table, array $conditions, array $options = [])
{
- return self::getClass(Database::class)->delete($table, $conditions, $options);
+ return DI::dba()->delete($table, $conditions, $options);
}
/**
*/
public static function update($table, $fields, $condition, $old_fields = [])
{
- return self::getClass(Database::class)->update($table, $fields, $condition, $old_fields);
+ return DI::dba()->update($table, $fields, $condition, $old_fields);
}
/**
*/
public static function selectFirst($table, array $fields = [], array $condition = [], $params = [])
{
- return self::getClass(Database::class)->selectFirst($table, $fields, $condition, $params);
+ return DI::dba()->selectFirst($table, $fields, $condition, $params);
}
/**
*/
public static function selectToArray($table, array $fields = [], array $condition = [], array $params = [])
{
- return self::getClass(Database::class)->selectToArray($table, $fields, $condition, $params);
+ return DI::dba()->selectToArray($table, $fields, $condition, $params);
}
/**
*/
public static function select($table, array $fields = [], array $condition = [], array $params = [])
{
- return self::getClass(Database::class)->select($table, $fields, $condition, $params);
+ return DI::dba()->select($table, $fields, $condition, $params);
}
/**
*/
public static function count($table, array $condition = [], array $params = [])
{
- return self::getClass(Database::class)->count($table, $condition, $params);
+ return DI::dba()->count($table, $condition, $params);
}
/**
*/
public static function buildCondition(array &$condition = [])
{
+ $condition = self::collapseCondition($condition);
+
$condition_string = '';
if (count($condition) > 0) {
- reset($condition);
- $first_key = key($condition);
- if (is_int($first_key)) {
- $condition_string = " WHERE (" . array_shift($condition) . ")";
- } else {
- $new_values = [];
- $condition_string = "";
- foreach ($condition as $field => $value) {
- if ($condition_string != "") {
- $condition_string .= " AND ";
- }
- if (is_array($value)) {
- if (count($value)) {
- /* Workaround for MySQL Bug #64791.
- * Never mix data types inside any IN() condition.
- * In case of mixed types, cast all as string.
- * Logic needs to be consistent with DBA::p() data types.
- */
- $is_int = false;
- $is_alpha = false;
- foreach ($value as $single_value) {
- if (is_int($single_value)) {
- $is_int = true;
- } else {
- $is_alpha = true;
- }
- }
+ $condition_string = " WHERE (" . array_shift($condition) . ")";
+ }
- if ($is_int && $is_alpha) {
- foreach ($value as &$ref) {
- if (is_int($ref)) {
- $ref = (string)$ref;
- }
- }
- unset($ref); //Prevent accidental re-use.
- }
+ return $condition_string;
+ }
+
+ /**
+ * Collapse an associative array condition into a SQL string + parameters condition array.
+ *
+ * ['uid' => 1, 'network' => ['dspr', 'apub']]
+ *
+ * gets transformed into
+ *
+ * ["`uid` = ? AND `network` IN (?, ?)", 1, 'dspr', 'apub']
+ *
+ * @param array $condition
+ * @return array
+ */
+ public static function collapseCondition(array $condition)
+ {
+ // Ensures an always true condition is returned
+ if (count($condition) < 1) {
+ return ['1'];
+ }
+
+ reset($condition);
+ $first_key = key($condition);
+
+ if (is_int($first_key)) {
+ // Already collapsed
+ return $condition;
+ }
+
+ $values = [];
+ $condition_string = "";
+ foreach ($condition as $field => $value) {
+ if ($condition_string != "") {
+ $condition_string .= " AND ";
+ }
- $new_values = array_merge($new_values, array_values($value));
- $placeholders = substr(str_repeat("?, ", count($value)), 0, -2);
- $condition_string .= self::quoteIdentifier($field) . " IN (" . $placeholders . ")";
+ if (is_array($value)) {
+ if (count($value)) {
+ /* Workaround for MySQL Bug #64791.
+ * Never mix data types inside any IN() condition.
+ * In case of mixed types, cast all as string.
+ * Logic needs to be consistent with DBA::p() data types.
+ */
+ $is_int = false;
+ $is_alpha = false;
+ foreach ($value as $single_value) {
+ if (is_int($single_value)) {
+ $is_int = true;
} else {
- // Empty value array isn't supported by IN and is logically equivalent to no match
- $condition_string .= "FALSE";
+ $is_alpha = true;
+ }
+ }
+
+ if ($is_int && $is_alpha) {
+ foreach ($value as &$ref) {
+ if (is_int($ref)) {
+ $ref = (string)$ref;
+ }
}
- } elseif (is_null($value)) {
- $condition_string .= self::quoteIdentifier($field) . " IS NULL";
- } else {
- $new_values[$field] = $value;
- $condition_string .= self::quoteIdentifier($field) . " = ?";
+ unset($ref); //Prevent accidental re-use.
}
+
+ $values = array_merge($values, array_values($value));
+ $placeholders = substr(str_repeat("?, ", count($value)), 0, -2);
+ $condition_string .= self::quoteIdentifier($field) . " IN (" . $placeholders . ")";
+ } else {
+ // Empty value array isn't supported by IN and is logically equivalent to no match
+ $condition_string .= "FALSE";
}
- $condition_string = " WHERE (" . $condition_string . ")";
- $condition = $new_values;
+ } elseif (is_null($value)) {
+ $condition_string .= self::quoteIdentifier($field) . " IS NULL";
+ } else {
+ $values[$field] = $value;
+ $condition_string .= self::quoteIdentifier($field) . " = ?";
}
}
- return $condition_string;
+ $condition = array_merge([$condition_string], array_values($values));
+
+ return $condition;
}
/**
*/
public static function toArray($stmt, $do_close = true)
{
- return self::getClass(Database::class)->toArray($stmt, $do_close);
+ return DI::dba()->toArray($stmt, $do_close);
}
/**
*/
public static function errorNo()
{
- return self::getClass(Database::class)->errorNo();
+ return DI::dba()->errorNo();
}
/**
*/
public static function errorMessage()
{
- return self::getClass(Database::class)->errorMessage();
+ return DI::dba()->errorMessage();
}
/**
*/
public static function close($stmt)
{
- return self::getClass(Database::class)->close($stmt);
+ return DI::dba()->close($stmt);
}
/**
*/
public static function processlist()
{
- return self::getClass(Database::class)->processlist();
+ return DI::dba()->processlist();
}
/**
*/
public static function isResult($array)
{
- return self::getClass(Database::class)->isResult($array);
+ return DI::dba()->isResult($array);
}
/**
*/
public static function escapeArray(&$arr, $add_quotation = false)
{
- return self::getClass(Database::class)->escapeArray($arr, $add_quotation);
+ DI::dba()->escapeArray($arr, $add_quotation);
}
}
projects / friendica.git / blobdiff