<?php
namespace Yurun\InfluxDB\ORM\Meta;
use Doctrine\Common\Annotations\AnnotationReader;
use Doctrine\Common\Annotations\AnnotationRegistry;
use ReflectionClass;
use Swoole\Coroutine\Channel;
use Yurun\InfluxDB\ORM\Annotation\Field;
use Yurun\InfluxDB\ORM\Annotation\Measurement;
use Yurun\InfluxDB\ORM\Annotation\Tag;
use Yurun\InfluxDB\ORM\Annotation\Timestamp;
use Yurun\InfluxDB\ORM\Annotation\Value;
class Meta
{
/**
* 是否注册了加载器.
*
* @var bool
*/
private static $isRegisterLoader = false;
/**
* 注解读取器.
*
* @var \Doctrine\Common\Annotations\AnnotationReader
*/
private static $reader;
/**
* measurement.
*
* @var string
*/
private $measurement;
/**
* 客户端名.
*
* @var string
*/
private $client;
/**
* 数据库名.
*
* @var string
*/
private $database;
/**
* 属性列表.
*
* @var \Yurun\InfluxDB\ORM\Meta\PropertyMeta[]
*/
private $properties;
/**
* 字段名属性列表.
*
* @var \Yurun\InfluxDB\ORM\Meta\PropertyMeta[]
*/
private $propertiesByFieldName;
/**
* 标签列表.
*
* @var \Yurun\InfluxDB\ORM\Meta\PropertyMeta[]
*/
private $tags;
/**
* 字段列表.
*
* @var \Yurun\InfluxDB\ORM\Meta\PropertyMeta[]
*/
private $fields;
/**
* 时间戳.
*
* @var \Yurun\InfluxDB\ORM\Meta\PropertyMeta
*/
private $timestamp;
/**
* 时间戳记精度（默认为纳秒）。
*
* @var string
*/
private $precision;
/**
* 值
*
* @var \Yurun\InfluxDB\ORM\Meta\PropertyMeta
*/
private $value;
/**
* 指定写入所有点时要使用的显式保留策略。
* 如果未设置，将使用默认保留期。
* 这仅适用于Guzzle驱动程序。
* UDP驱动程序利用服务器的influxdb配置文件中定义的端点配置。
*
* @var string
*/
private $retentionPolicy;
/**
* 时区，用于查询时自动转换为当前时区的时间
* 为空则使用 PHP 当前时区.
*
* @var string
*/
private $timezone;
/**
* 是否正在初始化.
*
* @var \Swoole\Coroutine\Channel|null
*/
private static $swooleChannel;
public function __construct(string $className)
{
if (!self::$isRegisterLoader)
{
AnnotationRegistry::registerLoader(function ($class) {
return class_exists($class) || interface_exists($class);
});
self::$isRegisterLoader = true;
}
if (null === self::$reader)
{
self::$reader = new AnnotationReader();
}
$inSwoole = \defined('SWOOLE_VERSION') && \Swoole\Coroutine::getuid() >= 0;
if ($inSwoole)
{
if (null === static::$swooleChannel)
{
static::$swooleChannel = new Channel(1);
}
static::$swooleChannel->push(1);
}
try
{
$refClass = new ReflectionClass($className);
/** @var Measurement $measurement */
$measurement = self::$reader->getClassAnnotation($refClass, Measurement::class);
// @phpstan-ignore-next-line
if ($measurement || !$measurement->name)
{
$this->measurement = $measurement->name;
$this->client = $measurement->client;
$this->database = $measurement->database;
$this->retentionPolicy = $measurement->retentionPolicy;
$this->timezone = $measurement->timezone ?? date_default_timezone_get();
}
else
{
throw new \InvalidArgumentException(sprintf('@Measurement must set the name property in Class %s', $className));
}
$properties = $propertiesByFieldName = $tags = $fields = [];
$value = $timestamp = null;
foreach ($refClass->getProperties() as $property)
{
$name = $property->getName();
$tagName = $tagType = $fieldName = $fieldType = $valueType = $timeFormat = null;
$isTimestamp = $isValue = false;
foreach (self::$reader->getPropertyAnnotations($property) as $annotation)
{
switch (\get_class($annotation))
{
case Tag::class:
/** @var Tag $annotation */
$tagName = $annotation->name ?? $name;
$tagType = $annotation->type;
break;
case Field::class:
/** @var Field $annotation */
$fieldName = $annotation->name ?? $name;
$fieldType = $annotation->type;
break;
case Timestamp::class:
/** @var Timestamp $annotation */
$isTimestamp = true;
$this->precision = $annotation->precision;
$timeFormat = $annotation->format;
break;
case Value::class:
/** @var Value $annotation */
$isValue = true;
$valueType = $annotation->type;
break;
}
}
$propertyMeta = new PropertyMeta($name, $tagName, $tagType, $fieldName, $fieldType, $valueType, $timeFormat, $isTimestamp, $isValue);
$properties[$name] = $propertyMeta;
$propertiesByFieldName[$propertyMeta->getFieldName() ?? $propertyMeta->getTagName()] = $propertyMeta;
if ($propertyMeta->isTag())
{
$tags[$name] = $propertyMeta;
}
if ($propertyMeta->isField())
{
$fields[$name] = $propertyMeta;
}
if ($propertyMeta->isTimestamp())
{
$timestamp = $propertyMeta;
}
if ($propertyMeta->isValue())
{
$value = $propertyMeta;
}
}
$this->properties = $properties;
$this->propertiesByFieldName = $propertiesByFieldName;
$this->tags = $tags;
$this->fields = $fields;
if (null === $timestamp)
{
throw new \InvalidArgumentException(sprintf('Class %s must declared an @Timestamp property', $className));
}
$this->timestamp = $timestamp;
$this->value = $value;
}
finally
{
if (static::$swooleChannel)
{
static::$swooleChannel->pop();
}
}
}
/**
* Get the value of measurement.
*/
public function getMeasurement(): string
{
return $this->measurement;
}
/**
* Get 属性列表.
*
* @return \Yurun\InfluxDB\ORM\Meta\PropertyMeta[]
*/
public function getProperties(): array
{
return $this->properties;
}
/**
* Get 属性.
*
* @return \Yurun\InfluxDB\ORM\Meta\PropertyMeta|null
*/
public function getProperty(string $name): ?PropertyMeta
{
return $this->properties[$name] ?? null;
}
/**
* Get 属性.
*
* @return \Yurun\InfluxDB\ORM\Meta\PropertyMeta|null
*/
public function getByFieldName(string $fieldName): ?PropertyMeta
{
return $this->propertiesByFieldName[$fieldName] ?? null;
}
/**
* Get 标签列表.
*
influxdb-orm-master.zip （37个子文件） 
influxdb-orm-master 
phpstan.neon 583B .github docker-compose.yml 705B php.dockerfile 204B workflows phpstan.yml 525B ci.yml 576B phpcs.yml 514B src Annotation Value.php 291B Tag.php 365B Field.php 367B Measurement.php 855B Timestamp.php 466B Client Database.php 1KB Client.php 1KB ResultSet.php 2KB YurunHttpDriver.php 3KB BaseModel.php 8KB Util DateTime.php 1KB Query QueryBuilder.php 8KB Meta PropertyMeta.php 3KB Meta.php 9KB MetaManager.php 562B InfluxDBManager.php 4KB LICENSE 1KB composer.json 910B tests bootstrap.php 1KB test Model ModelA.php 2KB Tests ConnectionTest.php 2KB QueryBuilderTest.php 2KB ResultSetTest.php 2KB ModelTest.php 3KB DateTimeTest.php 1KB phpunit.xml 760B res 
pay.png 140KB .php_cs.dist 1KB .gitignore 24B example Model A.php 2KB test.php 2KB资源评论
Java程序员-张凯
- 粉丝: 1w+
- 资源: 7361
