<?php
/**
* Zend Framework (http://framework.zend.com/)
*
* @link http://github.com/zendframework/zf2 for the canonical source repository
* @copyright Copyright (c) 2005-2014 Zend Technologies USA Inc. (http://www.zend.com)
* @license http://framework.zend.com/license/new-bsd New BSD License
*/
namespace Zend\Log\Writer;
use Traversable;
use Zend\Db\Adapter\Adapter;
use Zend\Log\Exception;
use Zend\Log\Formatter;
use Zend\Log\Formatter\Db as DbFormatter;
class Db extends AbstractWriter
{
/**
* Db adapter instance
*
* @var Adapter
*/
protected $db;
/**
* Table name
*
* @var string
*/
protected $tableName;
/**
* Relates database columns names to log data field keys.
*
* @var null|array
*/
protected $columnMap;
/**
* Field separator for sub-elements
*
* @var string
*/
protected $separator = '_';
/**
* Constructor
*
* We used the Adapter instead of Zend\Db for a performance reason.
*
* @param Adapter|array|Traversable $db
* @param string $tableName
* @param array $columnMap
* @param string $separator
* @throws Exception\InvalidArgumentException
*/
public function __construct($db, $tableName = null, array $columnMap = null, $separator = null)
{
if ($db instanceof Traversable) {
$db = iterator_to_array($db);
}
if (is_array($db)) {
parent::__construct($db);
$separator = isset($db['separator']) ? $db['separator'] : null;
$columnMap = isset($db['column']) ? $db['column'] : null;
$tableName = isset($db['table']) ? $db['table'] : null;
$db = isset($db['db']) ? $db['db'] : null;
}
if (!$db instanceof Adapter) {
throw new Exception\InvalidArgumentException('You must pass a valid Zend\Db\Adapter\Adapter');
}
$tableName = (string) $tableName;
if ('' === $tableName) {
throw new Exception\InvalidArgumentException('You must specify a table name. Either directly in the constructor, or via options');
}
$this->db = $db;
$this->tableName = $tableName;
$this->columnMap = $columnMap;
if (!empty($separator)) {
$this->separator = $separator;
}
$this->setFormatter(new DbFormatter());
}
/**
* Remove reference to database adapter
*
* @return void
*/
public function shutdown()
{
$this->db = null;
}
/**
* Write a message to the log.
*
* @param array $event event data
* @return void
* @throws Exception\RuntimeException
*/
protected function doWrite(array $event)
{
if (null === $this->db) {
throw new Exception\RuntimeException('Database adapter is null');
}
$event = $this->formatter->format($event);
// Transform the event array into fields
if (null === $this->columnMap) {
$dataToInsert = $this->eventIntoColumn($event);
} else {
$dataToInsert = $this->mapEventIntoColumn($event, $this->columnMap);
}
$statement = $this->db->query($this->prepareInsert($this->db, $this->tableName, $dataToInsert));
$statement->execute($dataToInsert);
}
/**
* Prepare the INSERT SQL statement
*
* @param Adapter $db
* @param string $tableName
* @param array $fields
* @return string
*/
protected function prepareInsert(Adapter $db, $tableName, array $fields)
{
$keys = array_keys($fields);
$sql = 'INSERT INTO ' . $db->platform->quoteIdentifier($tableName) . ' (' .
implode(",",array_map(array($db->platform, 'quoteIdentifier'), $keys)) . ') VALUES (' .
implode(",",array_map(array($db->driver, 'formatParameterName'), $keys)) . ')';
return $sql;
}
/**
* Map event into column using the $columnMap array
*
* @param array $event
* @param array $columnMap
* @return array
*/
protected function mapEventIntoColumn(array $event, array $columnMap = null)
{
if (empty($event)) {
return array();
}
$data = array();
foreach ($event as $name => $value) {
if (is_array($value)) {
foreach ($value as $key => $subvalue) {
if (isset($columnMap[$name][$key])) {
$data[$columnMap[$name][$key]] = $subvalue;
}
}
} elseif (isset($columnMap[$name])) {
$data[$columnMap[$name]] = $value;
}
}
return $data;
}
/**
* Transform event into column for the db table
*
* @param array $event
* @return array
*/
protected function eventIntoColumn(array $event)
{
if (empty($event)) {
return array();
}
$data = array();
foreach ($event as $name => $value) {
if (is_array($value)) {
foreach ($value as $key => $subvalue) {
$data[$name . $this->separator . $key] = $subvalue;
}
} else {
$data[$name] = $value;
}
}
return $data;
}
}
# |
Change |
User |
Description |
Committed |
|
#1
|
18334 |
Liz Lam |
initial add of jambox |
|
|