93 lines
4.1 KiB
PHP
93 lines
4.1 KiB
PHP
<?php
|
|
/*
|
|
+---------------------------------------------------------------------------------+
|
|
| Copyright (c) 2013 César Rodas |
|
|
+---------------------------------------------------------------------------------+
|
|
| Redistribution and use in source and binary forms, with or without |
|
|
| modification, are permitted provided that the following conditions are met: |
|
|
| 1. Redistributions of source code must retain the above copyright |
|
|
| notice, this list of conditions and the following disclaimer. |
|
|
| |
|
|
| 2. Redistributions in binary form must reproduce the above copyright |
|
|
| notice, this list of conditions and the following disclaimer in the |
|
|
| documentation and/or other materials provided with the distribution. |
|
|
| |
|
|
| 3. All advertising materials mentioning features or use of this software |
|
|
| must display the following acknowledgement: |
|
|
| This product includes software developed by César D. Rodas. |
|
|
| |
|
|
| 4. Neither the name of the César D. Rodas nor the |
|
|
| names of its contributors may be used to endorse or promote products |
|
|
| derived from this software without specific prior written permission. |
|
|
| |
|
|
| THIS SOFTWARE IS PROVIDED BY CÉSAR D. RODAS ''AS IS'' AND ANY |
|
|
| EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
|
|
| WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE |
|
|
| DISCLAIMED. IN NO EVENT SHALL CÉSAR D. RODAS BE LIABLE FOR ANY |
|
|
| DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
|
|
| (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
|
|
| LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
|
|
| ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
|
|
| (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
|
|
| SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE |
|
|
+---------------------------------------------------------------------------------+
|
|
| Authors: César Rodas <crodas@php.net> |
|
|
+---------------------------------------------------------------------------------+
|
|
*/
|
|
|
|
namespace crodas\InfluxPHP;
|
|
|
|
class DB extends BaseHTTP
|
|
{
|
|
protected $client;
|
|
protected $name;
|
|
|
|
public function __construct(Client $client, $name)
|
|
{
|
|
$this->client = $client;
|
|
$this->name = $name;
|
|
$this->inherits($client);
|
|
$this->base = "db/$name/";
|
|
}
|
|
|
|
public function getName()
|
|
{
|
|
return $this->name;
|
|
}
|
|
|
|
public function drop()
|
|
{
|
|
return $this->client->deleteDatabase($this->name);
|
|
}
|
|
|
|
public function insert($name, array $data)
|
|
{
|
|
$points = [];
|
|
$first = current($data);
|
|
if (!is_array($first)) {
|
|
return $this->insert($name, [$data]);
|
|
}
|
|
$columns = array_keys($first);
|
|
foreach ($data as $value) {
|
|
$points[] = array_values($value);
|
|
}
|
|
$body = compact('name', 'columns', 'points');
|
|
return $this->post('series', [$body], ['time_precision' => $this->timePrecision]);
|
|
}
|
|
|
|
public function first($sql)
|
|
{
|
|
return current($this->query($sql));
|
|
}
|
|
|
|
public function query($sql)
|
|
{
|
|
return new Cursor($this->get('series', ['q' => $sql, 'time_precision' => $this->timePrecision]));
|
|
}
|
|
|
|
public function createUser($username, $password)
|
|
{
|
|
return $this->post('users', compact('username', 'password'));
|
|
}
|
|
}
|