X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FDatabase%2FDBA.php;h=bf3004ead4761eebdc2d46fc026c8240597a47cf;hb=50da89d861dce3b648c8f9e5c1e4c480ee320a43;hp=8fd117e5d2c56f742b399dcf93d8ea2988218317;hpb=a19f8d642d6078b2a9f43770fcc863b5c006c026;p=friendica.git

diff --git a/src/Database/DBA.php b/src/Database/DBA.php
index 8fd117e5d2..bf3004ead4 100644
--- a/src/Database/DBA.php
+++ b/src/Database/DBA.php
@@ -6,6 +6,7 @@ namespace Friendica\Database;
 // Please use App->getConfigVariable() instead.
 //use Friendica\Core\Config;
 
+use Friendica\Core\Logger;
 use Friendica\Core\System;
 use Friendica\Util\DateTimeFormat;
 use mysqli;
@@ -24,6 +25,15 @@ require_once 'include/dba.php';
  */
 class DBA
 {
+	/**
+	 * Lowest possible date value
+	 */
+	const NULL_DATE     = '0001-01-01';
+	/**
+	 * Lowest possible datetime value
+	 */
+	const NULL_DATETIME = '0001-01-01 00:00:00';
+
 	public static $connected = false;
 
 	private static $server_info = '';
@@ -403,7 +413,7 @@ class DBA
 
 		if ((substr_count($sql, '?') != count($args)) && (count($args) > 0)) {
 			// Question: Should we continue or stop the query here?
-			logger('Parameter mismatch. Query "'.$sql.'" - Parameters '.print_r($args, true), LOGGER_DEBUG);
+			Logger::log('Parameter mismatch. Query "'.$sql.'" - Parameters '.print_r($args, true), Logger::DEBUG);
 		}
 
 		$sql = self::cleanQuery($sql);
@@ -543,7 +553,7 @@ class DBA
 			$error = self::$error;
 			$errorno = self::$errorno;
 
-			logger('DB Error '.self::$errorno.': '.self::$error."\n".
+			Logger::log('DB Error '.self::$errorno.': '.self::$error."\n".
 				System::callstack(8)."\n".self::replaceParameters($sql, $args));
 
 			// On a lost connection we try to reconnect - but only once.
@@ -551,14 +561,14 @@ class DBA
 				if (self::$in_retrial || !self::reconnect()) {
 					// It doesn't make sense to continue when the database connection was lost
 					if (self::$in_retrial) {
-						logger('Giving up retrial because of database error '.$errorno.': '.$error);
+						Logger::log('Giving up retrial because of database error '.$errorno.': '.$error);
 					} else {
-						logger("Couldn't reconnect after database error ".$errorno.': '.$error);
+						Logger::log("Couldn't reconnect after database error ".$errorno.': '.$error);
 					}
 					exit(1);
 				} else {
 					// We try it again
-					logger('Reconnected after database error '.$errorno.': '.$error);
+					Logger::log('Reconnected after database error '.$errorno.': '.$error);
 					self::$in_retrial = true;
 					$ret = self::p($sql, $args);
 					self::$in_retrial = false;
@@ -627,13 +637,13 @@ class DBA
 			$error = self::$error;
 			$errorno = self::$errorno;
 
-			logger('DB Error '.self::$errorno.': '.self::$error."\n".
+			Logger::log('DB Error '.self::$errorno.': '.self::$error."\n".
 				System::callstack(8)."\n".self::replaceParameters($sql, $params));
 
 			// On a lost connection we simply quit.
 			// A reconnect like in self::p could be dangerous with modifications
 			if ($errorno == 2006) {
-				logger('Giving up because of database error '.$errorno.': '.$error);
+				Logger::log('Giving up because of database error '.$errorno.': '.$error);
 				exit(1);
 			}
 
@@ -826,7 +836,7 @@ class DBA
 	public static function insert($table, $param, $on_duplicate_update = false) {
 
 		if (empty($table) || empty($param)) {
-			logger('Table and fields have to be set');
+			Logger::log('Table and fields have to be set');
 			return false;
 		}
 
@@ -1042,7 +1052,7 @@ class DBA
 	public static function delete($table, array $conditions, array $options = [], $in_process = false, array &$callstack = [])
 	{
 		if (empty($table) || empty($conditions)) {
-			logger('Table and conditions have to be set');
+			Logger::log('Table and conditions have to be set');
 			return false;
 		}
 
@@ -1133,7 +1143,7 @@ class DBA
 
 				if ((count($command['conditions']) > 1) || is_int($first_key)) {
 					$sql = "DELETE FROM `" . $command['table'] . "`" . $condition_string;
-					logger(self::replaceParameters($sql, $conditions), LOGGER_DATA);
+					Logger::log(self::replaceParameters($sql, $conditions), Logger::DATA);
 
 					if (!self::e($sql, $conditions)) {
 						if ($do_transaction) {
@@ -1163,7 +1173,7 @@ class DBA
 						$sql = "DELETE FROM `" . $table . "` WHERE `" . $field . "` IN (" .
 							substr(str_repeat("?, ", count($field_values)), 0, -2) . ");";
 
-						logger(self::replaceParameters($sql, $field_values), LOGGER_DATA);
+						Logger::log(self::replaceParameters($sql, $field_values), Logger::DATA);
 
 						if (!self::e($sql, $field_values)) {
 							if ($do_transaction) {
@@ -1214,7 +1224,7 @@ class DBA
 	public static function update($table, $fields, $condition, $old_fields = []) {
 
 		if (empty($table) || empty($fields) || empty($condition)) {
-			logger('Table, fields and condition have to be set');
+			Logger::log('Table, fields and condition have to be set');
 			return false;
 		}