InfluxPHP/tests/DBTest.php
2014-09-04 18:33:45 +02:00

123 lines
3.6 KiB
PHP

<?php
use crodas\InfluxPHP\Client;
use crodas\InfluxPHP\DB;
class DBTest extends \PHPUnit_Framework_TestCase
{
public function testCreate()
{
$client = new Client;
return $client->createDatabase("test_foobar");
}
/**
* @expectedException RuntimeException
*/
public function testCreateException()
{
$client = new Client;
return $client->createDatabase("test_foobar");
}
/**
* @dependsOn testCreateException
*/
public function testDelete()
{
$client = new Client;
return $client->deleteDatabase("test_foobar");
}
/**
* @dependsOn testDelete
* @expectedException RuntimeException
*/
public function testDeleteException()
{
$client = new Client;
return $client->deleteDatabase("test_foobar");
}
public function testDBObject()
{
$client = new Client;
$client->createDatabase("test_xxx");
$this->assertTrue($client->test_xxx instanceof DB);
$this->assertTrue($client->getDatabase("test_xxx") instanceof DB);
$client->test_xxx->drop();
}
public function testTimePrecision()
{
$client = new Client;
$this->assertEquals('s', $client->getTimePrecision());
$db = $client->createDatabase("test_yyyy");
$this->assertEquals('s', $db->getTimePrecision());
$client->setTimePrecision('m');
$this->assertEquals('m', $client->getTimePrecision());
$this->assertEquals('m', $db->getTimePrecision());
$db1 = $client->createDatabase("test_yyyx");
$this->assertEquals('m', $db->getTimePrecision());
}
/**
* @expectedException InvalidArgumentException
*/
public function testInvalidTimePrecision()
{
$client = new Client;
$client->SetTimePrecision(array());
}
public function testQuery()
{
$client = new Client;
$db = $client->createDatabase("test_xxx");
$db->createUser("root", "root");
$db->insert("foobar", array('type' => '/foobar', 'karma' => 10));
$db->insert("foobar", array('type' => '/foobar', 'karma' => 20));
$db->insert("foobar", array('type' => '/barfoo', 'karma' => 30));
$this->assertEquals($db->first("SELECT max(karma) FROM foobar")->max, 30);
$this->assertEquals($db->first("SELECT min(karma) FROM foobar")->min, 10);
$this->assertEquals($db->first("SELECT mean(karma) FROM foobar")->mean, 20);
foreach ($db->query("SELECT mean(karma) FROM foobar GROUP BY type") as $row) {
$this->assertTrue(is_int($row->time));
if ($row->type == "/foobar") {
$this->assertEquals(15, $row->mean);
} else {
$this->assertEquals(30, $row->mean);
}
}
}
/** @dependsOn testQuery */
function testDifferentTimePeriod()
{
$client = new Client;
$db = $client->test_xxx;
$client->setTimePrecision('u');
foreach ($db->query("SELECT mean(karma) FROM foobar GROUP BY type, time(1h)") as $row) {
$this->assertTrue($row->time > time()*1000);
}
$client->setTimePrecision('m');
foreach ($db->query("SELECT mean(karma) FROM foobar GROUP BY type, time(1h)") as $row) {
$this->assertTrue($row->time < time()*10000);
}
$client->setTimePrecision('s');
foreach ($db->query("SELECT mean(karma) FROM foobar GROUP BY type, time(1h)") as $row) {
$this->assertTrue($row->time < time()+20);
}
$db->drop();
}
}