diff --git a/config/config.sample.php b/config/config.sample.php index ddd91d84a3e..f9943ddfe19 100644 --- a/config/config.sample.php +++ b/config/config.sample.php @@ -2585,6 +2585,28 @@ $CONFIG = [ */ 'query_log_file' => '', +/** + * Prefix all queries with the requestid when set to `yes` + * + * Requires `query_log_file` to be set. + */ +'query_log_file_requestid' => '', + +/** + * Add all query parameters to the query log entry when set to `yes` + * + * Requires `query_log_file` to be set. + * Warning: This will log sensitive data into a plain text file. + */ +'query_log_file_parameters' => '', + +/** + * Add a backtrace to the query log entry when set to `yes` + * + * Requires `query_log_file` to be set. + */ +'query_log_file_backtrace' => '', + /** * Log all redis requests into a file * diff --git a/lib/private/DB/Connection.php b/lib/private/DB/Connection.php index eecf83ace95..96dd578b2ef 100644 --- a/lib/private/DB/Connection.php +++ b/lib/private/DB/Connection.php @@ -414,7 +414,7 @@ class Connection extends PrimaryReadReplicaConnection { $sql = $this->finishQuery($sql); $this->queriesExecuted++; - $this->logQueryToFile($sql); + $this->logQueryToFile($sql, $params); try { return parent::executeQuery($sql, $params, $types, $qcp); } catch (\Exception $e) { @@ -461,7 +461,7 @@ class Connection extends PrimaryReadReplicaConnection { } $sql = $this->finishQuery($sql); $this->queriesExecuted++; - $this->logQueryToFile($sql); + $this->logQueryToFile($sql, $params); try { return (int)parent::executeStatement($sql, $params, $types); } catch (\Exception $e) { @@ -470,14 +470,19 @@ class Connection extends PrimaryReadReplicaConnection { } } - protected function logQueryToFile(string $sql): void { + protected function logQueryToFile(string $sql, array $params): void { $logFile = $this->systemConfig->getValue('query_log_file'); if ($logFile !== '' && is_writable(dirname($logFile)) && (!file_exists($logFile) || is_writable($logFile))) { $prefix = ''; if ($this->systemConfig->getValue('query_log_file_requestid') === 'yes') { $prefix .= Server::get(IRequestId::class)->getId() . "\t"; } + $postfix = ''; + if ($this->systemConfig->getValue('query_log_file_parameters') === 'yes') { + $postfix .= '; ' . json_encode($params); + } + if ($this->systemConfig->getValue('query_log_file_backtrace') === 'yes') { $trace = debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS); array_pop($trace);