mirror of
https://gitee.com/fastadminnet/framework.git
synced 2026-07-01 12:42:48 +08:00
创建Db类单元测试
This commit is contained in:
chunice
@@ -11,6 +11,7 @@
|
||||
|
||||
/**
|
||||
* Db类测试
|
||||
* @author: 刘志淳 <chun@engineer.com>
|
||||
*/
|
||||
|
||||
namespace tests\thinkphp\library\think;
|
||||
@@ -19,9 +20,334 @@ use \think\Db;
|
||||
|
||||
class dbTest extends \PHPUnit_Framework_TestCase
|
||||
{
|
||||
public function testConnect()
|
||||
// 获取测试数据库配置
|
||||
private function getConfig()
|
||||
{
|
||||
Db::connect('mysql://root@127.0.0.1/test#utf8')->execute('show databases');
|
||||
return [
|
||||
// 数据库类型
|
||||
'type' => 'mysql',
|
||||
// 服务器地址
|
||||
'hostname' => '127.0.0.1',
|
||||
// 数据库名
|
||||
'database' => 'test',
|
||||
// 用户名
|
||||
'username' => 'root',
|
||||
// 密码
|
||||
'password' => '',
|
||||
// 端口
|
||||
'hostport' => '',
|
||||
// 连接dsn
|
||||
'dsn' => '',
|
||||
// 数据库连接参数
|
||||
'params' => [],
|
||||
// 数据库编码默认采用utf8
|
||||
'charset' => 'utf8',
|
||||
// 数据库表前缀
|
||||
'prefix' => 'tp_',
|
||||
// 数据库调试模式
|
||||
'debug' => true,
|
||||
// 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
|
||||
'deploy' => 0,
|
||||
// 数据库读写是否分离 主从式有效
|
||||
'rw_separate' => false,
|
||||
// 读写分离后 主服务器数量
|
||||
'master_num' => 1,
|
||||
// 指定从服务器序号
|
||||
'slave_no' => '',
|
||||
// 是否严格检查字段是否存在
|
||||
'fields_strict' => true,
|
||||
// 数据集返回类型 array 数组 collection Collection对象
|
||||
'resultset_type' => 'array',
|
||||
// 是否自动写入时间戳字段
|
||||
'auto_timestamp' => false,
|
||||
// 是否需要进行SQL性能分析
|
||||
'sql_explain' => false,
|
||||
];
|
||||
}
|
||||
|
||||
// 获取创建数据库 SQL
|
||||
private function getCreateTableSql()
|
||||
{
|
||||
$sql[] = <<<EOF
|
||||
DROP TABLE IF EXISTS `tp_user`;
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
CREATE TABLE `tp_user` (
|
||||
`id` int(10) unsigned NOT NULL PRIMARY KEY AUTO_INCREMENT,
|
||||
`username` char(40) NOT NULL DEFAULT '' COMMENT '用户名',
|
||||
`password` char(40) NOT NULL DEFAULT '' COMMENT '密码',
|
||||
`status` tinyint(1) NOT NULL DEFAULT '0' COMMENT '状态',
|
||||
`create_time` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间'
|
||||
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='会员表';
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
ALTER TABLE `tp_user` ADD INDEX(`create_time`);
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
DROP TABLE IF EXISTS `tp_order`;
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
CREATE TABLE `tp_order` (
|
||||
`id` int(10) unsigned NOT NULL PRIMARY KEY AUTO_INCREMENT,
|
||||
`user_id` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '用户id',
|
||||
`sn` char(20) NOT NULL DEFAULT '' COMMENT '订单号',
|
||||
`amount` decimal(10,2) unsigned NOT NULL DEFAULT '0' COMMENT '金额',
|
||||
`freight_fee` decimal(10,2) unsigned NOT NULL DEFAULT '0' COMMENT '运费',
|
||||
`address_id` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '地址id',
|
||||
`status` tinyint(1) NOT NULL DEFAULT '0' COMMENT '状态',
|
||||
`create_time` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间'
|
||||
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='订单表';
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
DROP TABLE IF EXISTS `tp_user_address`;
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
CREATE TABLE `tp_user_address` (
|
||||
`id` int(10) unsigned NOT NULL PRIMARY KEY AUTO_INCREMENT,
|
||||
`user_id` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '用户id',
|
||||
`consignee` varchar(60) NOT NULL DEFAULT '' COMMENT '收货人',
|
||||
`area_info` varchar(50) NOT NULL DEFAULT '' COMMENT '地区信息',
|
||||
`city_id` smallint(5) unsigned NOT NULL DEFAULT '0' COMMENT '城市id',
|
||||
`area_id` smallint(5) unsigned NOT NULL DEFAULT '0' COMMENT '地区id',
|
||||
`address` varchar(120) NOT NULL DEFAULT '' COMMENT '地址',
|
||||
`tel` varchar(60) NOT NULL DEFAULT '' COMMENT '电话',
|
||||
`mobile` varchar(60) NOT NULL DEFAULT '' COMMENT '手机',
|
||||
`isdefault` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '是否默认'
|
||||
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='地址表';
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
DROP TABLE IF EXISTS `tp_role_user`;
|
||||
EOF;
|
||||
$sql[] = <<<EOF
|
||||
CREATE TABLE `tp_role_user` (
|
||||
`role_id` smallint(5) unsigned NOT NULL,
|
||||
`user_id` int(10) unsigned NOT NULL,
|
||||
`remark` varchar(250) NOT NULL DEFAULT '',
|
||||
PRIMARY KEY (`role_id`,`user_id`)
|
||||
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
|
||||
EOF;
|
||||
|
||||
return $sql;
|
||||
}
|
||||
|
||||
public function testConnect()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$result = Db::connect($config)->execute('show databases');
|
||||
$this->assertNotEmpty($result);
|
||||
}
|
||||
|
||||
public function testExecute()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$sql = $this->getCreateTableSql();
|
||||
foreach ($sql as $one) {
|
||||
Db::connect($config)->execute($one);
|
||||
}
|
||||
$tableNum = Db::connect($config)->execute("show tables;");
|
||||
$this->assertEquals(4, $tableNum);
|
||||
}
|
||||
|
||||
public function testQuery()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$sql = $this->getCreateTableSql();
|
||||
Db::connect($config)->batchQuery($sql);
|
||||
|
||||
$tableQueryResult = Db::connect($config)->query("show tables;");
|
||||
|
||||
$this->assertTrue(is_array($tableQueryResult));
|
||||
|
||||
$tableNum = count($tableQueryResult);
|
||||
$this->assertEquals(4, $tableNum);
|
||||
}
|
||||
|
||||
public function testBatchQuery()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$sql = $this->getCreateTableSql();
|
||||
Db::connect($config)->batchQuery($sql);
|
||||
|
||||
$tableNum = Db::connect($config)->execute("show tables;");
|
||||
$this->assertEquals(4, $tableNum);
|
||||
}
|
||||
|
||||
public function testTable()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$tableName = 'tp_user';
|
||||
$result = Db::connect($config)->table($tableName);
|
||||
$this->assertEquals($tableName, $result->getOptions()['table']);
|
||||
}
|
||||
|
||||
public function testName()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$tableName = 'user';
|
||||
$result = Db::connect($config)->name($tableName);
|
||||
$this->assertEquals($config['prefix'] . $tableName, $result->getOptions()['table']);
|
||||
}
|
||||
|
||||
public function testInsert()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$data = [
|
||||
'username' => 'chunice',
|
||||
'password' => md5('chunice'),
|
||||
'status' => 1,
|
||||
'create_time' => time()
|
||||
];
|
||||
$result = Db::connect($config)->name('user')->insert($data);
|
||||
$this->assertEquals(1, $result);
|
||||
}
|
||||
|
||||
public function testUpdate()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$data = [
|
||||
'username' => 'chunice_update',
|
||||
'password' => md5('chunice'),
|
||||
'status' => 1,
|
||||
'create_time' => time()
|
||||
];
|
||||
$result = Db::connect($config)->name('user')->where('username', 'chunice')->update($data);
|
||||
$this->assertEquals(1, $result);
|
||||
}
|
||||
|
||||
public function testFind()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$mustFind = Db::connect($config)->name('user')->where('username', 'chunice_update')->find();
|
||||
$this->assertNotEmpty($mustFind);
|
||||
$mustNotFind = Db::connect($config)->name('user')->where('username', 'chunice')->find();
|
||||
$this->assertEmpty($mustNotFind);
|
||||
}
|
||||
|
||||
public function testInsertAll()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
|
||||
$data = [
|
||||
['username' => 'foo', 'password' => md5('foo'), 'status' => 1, 'create_time' => time()],
|
||||
['username' => 'bar', 'password' => md5('bar'), 'status' => 1, 'create_time' => time()]
|
||||
];
|
||||
|
||||
$insertNum = Db::connect($config)->name('user')->insertAll($data);
|
||||
$this->assertEquals(count($data), $insertNum);
|
||||
}
|
||||
|
||||
public function testSelect()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$mustFound = Db::connect($config)->name('user')->where('status', 1)->select();
|
||||
$this->assertNotEmpty($mustFound);
|
||||
$mustNotFound = Db::connect($config)->name('user')->where('status', 0)->select();
|
||||
$this->assertEmpty($mustNotFound);
|
||||
}
|
||||
|
||||
public function testValue()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$username = Db::connect($config)->name('user')->where('id', 1)->value('username');
|
||||
$this->assertEquals('chunice_update', $username);
|
||||
$usernameNull = Db::connect($config)->name('user')->where('id', 0)->value('username');
|
||||
$this->assertEmpty($usernameNull);
|
||||
}
|
||||
|
||||
public function testColumn()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$username = Db::connect($config)->name('user')->where('status', 1)->column('username');
|
||||
$this->assertNotEmpty($username);
|
||||
$usernameNull = Db::connect($config)->name('user')->where('status', 0)->column('username');
|
||||
$this->assertEmpty($usernameNull);
|
||||
|
||||
}
|
||||
|
||||
public function testInsertGetId()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$id = Db::connect($config)->name('user')->order('id', 'desc')->value('id');
|
||||
|
||||
$data = [
|
||||
'username' => uniqid(),
|
||||
'password' => md5('chunice'),
|
||||
'status' => 1,
|
||||
'create_time' => time()
|
||||
];
|
||||
$lastId = Db::connect($config)->name('user')->insertGetId($data);
|
||||
$this->assertEquals($id + 1, $lastId);
|
||||
|
||||
}
|
||||
|
||||
public function testGetLastInsId()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$data = [
|
||||
'username' => uniqid(),
|
||||
'password' => md5('chunice'),
|
||||
'status' => 1,
|
||||
'create_time' => time()
|
||||
];
|
||||
$lastId = Db::connect($config)->name('user')->insertGetId($data);
|
||||
|
||||
$lastInsId = Db::connect($config)->name('user')->getLastInsID();
|
||||
$this->assertEquals($lastId, $lastInsId);
|
||||
}
|
||||
|
||||
public function testSetField()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
|
||||
$setFieldNum = Db::connect($config)->name('user')->where('id', 1)->setField('username', 'chunice_setField');
|
||||
$this->assertEquals(1, $setFieldNum);
|
||||
|
||||
$setFieldNum = Db::connect($config)->name('user')->where('id', 1)->setField('username', 'chunice_setField');
|
||||
$this->assertEquals(0, $setFieldNum);
|
||||
}
|
||||
|
||||
public function testSetInc()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$originCreateTime = Db::connect($config)->name('user')->where('id', 1)->value('create_time');
|
||||
Db::connect($config)->name('user')->where('id', 1)->setInc('create_time');
|
||||
$newCreateTime = Db::connect($config)->name('user')->where('id', 1)->value('create_time');
|
||||
$this->assertEquals($originCreateTime + 1, $newCreateTime);
|
||||
|
||||
}
|
||||
|
||||
public function testSetDec()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$originCreateTime = Db::connect($config)->name('user')->where('id', 1)->value('create_time');
|
||||
Db::connect($config)->name('user')->where('id', 1)->setDec('create_time');
|
||||
$newCreateTime = Db::connect($config)->name('user')->where('id', 1)->value('create_time');
|
||||
$this->assertEquals($originCreateTime - 1, $newCreateTime);
|
||||
}
|
||||
|
||||
public function testDelete()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
Db::connect($config)->name('user')->where('id', 1)->delete();
|
||||
$result = Db::connect($config)->name('user')->where('id', 1)->find();
|
||||
$this->assertEmpty($result);
|
||||
}
|
||||
|
||||
public function testChunk()
|
||||
{
|
||||
// todo 暂未想到测试方法
|
||||
}
|
||||
|
||||
public function testCache()
|
||||
{
|
||||
$config = $this->getConfig();
|
||||
$result = Db::connect($config)->name('user')->where('id', 1)->cache('key', 60)->select();
|
||||
$cache = \think\Cache::get('key');
|
||||
$this->assertEquals($result, $cache);
|
||||
|
||||
$updateCache = Db::connect($config)->name('user')->cache('key')->find(2);
|
||||
$this->assertNotEquals($cache, $updateCache);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user