388 lines
13 KiB
PHP
388 lines
13 KiB
PHP
<?php
|
|
declare(strict_types = 1);
|
|
|
|
require_once dirname(__FILE__, 5) . '/test/lib/test.class.php';
|
|
|
|
class metricTaoTest extends baseTest
|
|
{
|
|
protected $moduleName = 'metric';
|
|
protected $className = 'tao';
|
|
|
|
/**
|
|
* Test getObjectsWithPager method.
|
|
*
|
|
* @param object $metric
|
|
* @param object $query
|
|
* @param object|null $pager
|
|
* @param array $extra
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function getObjectsWithPagerTest($metric = null, $query = null, $pager = null, $extra = array())
|
|
{
|
|
$result = $this->invokeArgs('getObjectsWithPager', [$metric, $query, $pager, $extra]);
|
|
if(dao::isError()) return dao::getError();
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Test executeDelete method.
|
|
*
|
|
* @param string $code
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function executeDeleteTest($code = '')
|
|
{
|
|
global $tester;
|
|
|
|
if(empty($code)) return 'invalid_code';
|
|
|
|
// 记录删除前的记录数
|
|
$beforeCount = $this->instance->dao->select('COUNT(*) as count')
|
|
->from(TABLE_METRICLIB)
|
|
->where('metricCode')->eq($code)
|
|
->fetch('count');
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('executeDelete');
|
|
$method->setAccessible(true);
|
|
|
|
$method->invoke($this->instance, $code);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 记录删除后的记录数
|
|
$afterCount = $this->instance->dao->select('COUNT(*) as count')
|
|
->from(TABLE_METRICLIB)
|
|
->where('metricCode')->eq($code)
|
|
->fetch('count');
|
|
|
|
return $beforeCount - $afterCount;
|
|
}
|
|
|
|
/**
|
|
* Test fetchLatestMetricRecords method.
|
|
*
|
|
* @param string $code
|
|
* @param array $fieldList
|
|
* @param array $query
|
|
* @param object|null $pager
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function fetchLatestMetricRecordsTest($code = null, $fieldList = array(), $query = array(), $pager = null)
|
|
{
|
|
if(!$code) return array();
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('fetchLatestMetricRecords');
|
|
$method->setAccessible(true);
|
|
|
|
$result = $method->invoke($this->instance, $code, $fieldList, $query, $pager);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Test fetchMetricRecordByDate method.
|
|
*
|
|
* @param string $code
|
|
* @param string $date
|
|
* @param int $limit
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function fetchMetricRecordByDateTest($code = 'all', $date = '', $limit = 100)
|
|
{
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('fetchMetricRecordByDate');
|
|
$method->setAccessible(true);
|
|
|
|
$result = $method->invoke($this->instance, $code, $date, $limit);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Test fetchMetricRecords method.
|
|
*
|
|
* @param string $code
|
|
* @param array $fieldList
|
|
* @param array $query
|
|
* @param object $pager
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function fetchMetricRecordsTest($code = '', $fieldList = array(), $query = array(), $pager = null)
|
|
{
|
|
// 检查度量项是否存在，如果不存在则返回空数组
|
|
$metric = $this->instance->getByCode($code);
|
|
if(!$metric) return array();
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('fetchMetricRecords');
|
|
$method->setAccessible(true);
|
|
|
|
$result = $method->invoke($this->instance, $code, $fieldList, $query, $pager);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Test fetchMetricRecordsWithOption method.
|
|
*
|
|
* @param string $code
|
|
* @param array $fieldList
|
|
* @param array $options
|
|
* @param object $pager
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function fetchMetricRecordsWithOptionTest($code = '', $fieldList = array(), $options = array(), $pager = null)
|
|
{
|
|
// 检查度量项是否存在，如果不存在则返回空数组
|
|
$metric = $this->instance->getByCode($code);
|
|
if(!$metric) return array();
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('fetchMetricRecordsWithOption');
|
|
$method->setAccessible(true);
|
|
|
|
$result = $method->invoke($this->instance, $code, $fieldList, $options, $pager);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* Test keepLatestRecords method.
|
|
*
|
|
* @param string $code
|
|
* @param array $fields
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function keepLatestRecordsTest($code = '', $fields = array())
|
|
{
|
|
global $tester;
|
|
|
|
if(empty($code)) return 'invalid_code';
|
|
|
|
// 记录操作前未删除的记录数
|
|
$beforeUndeleted = $this->instance->dao->select('COUNT(*) as count')
|
|
->from(TABLE_METRICLIB)
|
|
->where('metricCode')->eq($code)
|
|
->andWhere('deleted')->eq('0')
|
|
->fetch('count');
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('keepLatestRecords');
|
|
$method->setAccessible(true);
|
|
|
|
$method->invoke($this->instance, $code, $fields);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 记录操作后未删除的记录数
|
|
$afterUndeleted = $this->instance->dao->select('COUNT(*) as count')
|
|
->from(TABLE_METRICLIB)
|
|
->where('metricCode')->eq($code)
|
|
->andWhere('deleted')->eq('0')
|
|
->fetch('count');
|
|
|
|
return $afterUndeleted - $beforeUndeleted;
|
|
}
|
|
|
|
/**
|
|
* Test rebuildIdColumn method.
|
|
*
|
|
* @param string $testType
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function rebuildIdColumnTest($testType = '')
|
|
{
|
|
global $tester;
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('rebuildIdColumn');
|
|
$method->setAccessible(true);
|
|
|
|
if(empty($testType))
|
|
{
|
|
// 测试空表情况
|
|
$this->instance->dao->delete()->from(TABLE_METRICLIB)->exec();
|
|
$method->invoke($this->instance);
|
|
if(dao::isError()) return dao::getError();
|
|
return array('result' => 'empty_table');
|
|
}
|
|
|
|
if($testType == 'normal')
|
|
{
|
|
// 清空表并插入正常数据
|
|
$this->instance->dao->delete()->from(TABLE_METRICLIB)->exec();
|
|
for($i = 1; $i <= 5; $i++)
|
|
{
|
|
$record = new stdClass();
|
|
$record->metricCode = 'test_metric_' . $i;
|
|
$record->value = $i * 10;
|
|
$record->year = '2024';
|
|
$record->month = '01';
|
|
$record->day = sprintf('%02d', $i);
|
|
$record->date = '2024-01-' . sprintf('%02d', $i);
|
|
$this->instance->dao->insert(TABLE_METRICLIB)->data($record)->exec();
|
|
}
|
|
|
|
$method->invoke($this->instance);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 验证ID是否从1开始连续
|
|
$records = $this->instance->dao->select('id')->from(TABLE_METRICLIB)->orderBy('id')->fetchAll();
|
|
for($i = 0; $i < count($records); $i++)
|
|
{
|
|
if($records[$i]->id != ($i + 1)) return array('result' => 'failed');
|
|
}
|
|
return array('result' => 'success');
|
|
}
|
|
|
|
if($testType == 'discontinuous')
|
|
{
|
|
// 清空表并插入不连续ID数据
|
|
$this->instance->dao->delete()->from(TABLE_METRICLIB)->exec();
|
|
$ids = array(2, 5, 8, 12, 15);
|
|
foreach($ids as $index => $id)
|
|
{
|
|
$record = new stdClass();
|
|
$record->metricCode = 'test_metric_' . $id;
|
|
$record->value = $id * 10;
|
|
$record->year = '2024';
|
|
$record->month = '01';
|
|
$record->day = sprintf('%02d', $index + 1);
|
|
$record->date = '2024-01-' . sprintf('%02d', $index + 1);
|
|
$this->instance->dao->insert(TABLE_METRICLIB)->data($record)->exec();
|
|
$this->instance->dao->update(TABLE_METRICLIB)->set('id')->eq($id)->where('metricCode')->eq('test_metric_' . $id)->exec();
|
|
}
|
|
|
|
$method->invoke($this->instance);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 验证ID是否变为连续
|
|
$records = $this->instance->dao->select('id')->from(TABLE_METRICLIB)->orderBy('id')->fetchAll();
|
|
for($i = 0; $i < count($records); $i++)
|
|
{
|
|
if($records[$i]->id != ($i + 1)) return array('result' => 'failed');
|
|
}
|
|
return array('result' => 'success');
|
|
}
|
|
|
|
if($testType == 'large')
|
|
{
|
|
// 清空表并插入大量数据测试
|
|
$this->instance->dao->delete()->from(TABLE_METRICLIB)->exec();
|
|
for($i = 1; $i <= 50; $i++)
|
|
{
|
|
$record = new stdClass();
|
|
$record->metricCode = 'large_test_' . $i;
|
|
$record->value = $i * 100;
|
|
$record->year = '2024';
|
|
$record->month = '01';
|
|
$record->day = sprintf('%02d', $i % 28 + 1);
|
|
$record->date = '2024-01-' . sprintf('%02d', $i % 28 + 1);
|
|
$this->instance->dao->insert(TABLE_METRICLIB)->data($record)->exec();
|
|
}
|
|
|
|
$method->invoke($this->instance);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 验证大量数据的ID连续性
|
|
$count = $this->instance->dao->select('COUNT(*) as count')->from(TABLE_METRICLIB)->fetch('count');
|
|
$maxId = $this->instance->dao->select('MAX(id) as maxId')->from(TABLE_METRICLIB)->fetch('maxId');
|
|
if($count == $maxId && $count == 50) return array('result' => 'success');
|
|
return array('result' => 'failed');
|
|
}
|
|
|
|
if($testType == 'autoincrement')
|
|
{
|
|
// 验证AUTO_INCREMENT值设置
|
|
$this->instance->dao->delete()->from(TABLE_METRICLIB)->exec();
|
|
for($i = 1; $i <= 3; $i++)
|
|
{
|
|
$record = new stdClass();
|
|
$record->metricCode = 'auto_test_' . $i;
|
|
$record->value = $i * 10;
|
|
$record->year = '2024';
|
|
$record->month = '01';
|
|
$record->day = sprintf('%02d', $i);
|
|
$record->date = '2024-01-' . sprintf('%02d', $i);
|
|
$this->instance->dao->insert(TABLE_METRICLIB)->data($record)->exec();
|
|
}
|
|
|
|
$method->invoke($this->instance);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 验证下次插入的ID是否正确
|
|
$record = new stdClass();
|
|
$record->metricCode = 'auto_increment_test';
|
|
$record->value = 999;
|
|
$record->year = '2024';
|
|
$record->month = '01';
|
|
$record->day = '04';
|
|
$record->date = '2024-01-04';
|
|
$this->instance->dao->insert(TABLE_METRICLIB)->data($record)->exec();
|
|
|
|
$newId = $this->instance->dao->select('id')->from(TABLE_METRICLIB)->where('metricCode')->eq('auto_increment_test')->fetch('id');
|
|
return array('autoIncrement' => ($newId == 4 ? '1' : '0'));
|
|
}
|
|
|
|
return array('result' => 'unknown_test_type');
|
|
}
|
|
|
|
/**
|
|
* Test setDeleted method.
|
|
*
|
|
* @param string $code
|
|
* @param string $value
|
|
* @access public
|
|
* @return mixed
|
|
*/
|
|
public function setDeletedTest($code = '', $value = '0')
|
|
{
|
|
global $tester;
|
|
|
|
if(empty($code)) return 'invalid_code';
|
|
|
|
// 记录更新前的状态
|
|
$beforeCount = $this->instance->dao->select('COUNT(*) as count')
|
|
->from(TABLE_METRICLIB)
|
|
->where('metricCode')->eq($code)
|
|
->andWhere('deleted')->eq($value)
|
|
->fetch('count');
|
|
|
|
// 使用反射来调用protected方法
|
|
$reflection = new ReflectionClass($this->instance);
|
|
$method = $reflection->getMethod('setDeleted');
|
|
$method->setAccessible(true);
|
|
|
|
$method->invoke($this->instance, $code, $value);
|
|
if(dao::isError()) return dao::getError();
|
|
|
|
// 记录更新后的状态
|
|
$afterCount = $this->instance->dao->select('COUNT(*) as count')
|
|
->from(TABLE_METRICLIB)
|
|
->where('metricCode')->eq($code)
|
|
->andWhere('deleted')->eq($value)
|
|
->fetch('count');
|
|
|
|
return $afterCount - $beforeCount;
|
|
}
|
|
}
|