mirror of
https://github.com/e107inc/e107.git
synced 2025-10-13 14:04:51 +02:00
579 lines
10 KiB
PHP
579 lines
10 KiB
PHP
<?php
|
|
/**
|
|
* e107 website system
|
|
*
|
|
* Copyright (C) 2008-2018 e107 Inc (e107.org)
|
|
* Released under the terms and conditions of the
|
|
* GNU General Public License (http://www.gnu.org/licenses/gpl.txt)
|
|
*
|
|
*/
|
|
|
|
|
|
class e_db_mysqlTest extends \Codeception\Test\Unit
|
|
{
|
|
|
|
/** @var e_db_mysql */
|
|
protected $db;
|
|
|
|
protected function _before()
|
|
{
|
|
try
|
|
{
|
|
$this->db = $this->make('e_db_mysql');
|
|
}
|
|
catch (Exception $e)
|
|
{
|
|
$this->fail("Couldn't load e_db_mysql object");
|
|
}
|
|
|
|
$this->db->__construct();
|
|
|
|
}
|
|
|
|
public function testGetPDO()
|
|
{
|
|
$result = $this->db->getPDO();
|
|
$this->assertTrue($result);
|
|
}
|
|
/*
|
|
public function testGetMode()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Connect()
|
|
{
|
|
|
|
}*/
|
|
|
|
/**
|
|
* TODO
|
|
*/
|
|
public function testConnect()
|
|
{
|
|
try
|
|
{
|
|
$class = $this->make('e_db_mysql');
|
|
}
|
|
catch (Exception $e)
|
|
{
|
|
$this->assertTrue(false, "Couldn't load e_db_mysql object");
|
|
}
|
|
|
|
if(is_object($class))
|
|
{
|
|
$this->assertTrue(true);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Test primary methods against a secondary database (ensures mysqlPrefix is working correctly)
|
|
* TODO Split into separate methods? Order needs to be respected.
|
|
*/
|
|
public function testSecondaryDatabase()
|
|
{
|
|
$xql = e107::getDb('newdb');
|
|
$config = e107::getMySQLConfig();
|
|
|
|
$database = 'e107_tests_tmp';
|
|
$table = 'test';
|
|
|
|
// cleanup
|
|
$xql->gen("DROP DATABASE `".$database."`");
|
|
|
|
// create database
|
|
if($xql->gen("CREATE DATABASE ".$database." CHARACTER SET `utf8`"))
|
|
{
|
|
$xql->gen("GRANT ALL ON `".$database."`.* TO ".$config['mySQLuser']."@'".$config['mySQLserver']."';");
|
|
$xql->gen("FLUSH PRIVILEGES;");
|
|
}
|
|
else
|
|
{
|
|
$this->fail("Failed to create secondary database");
|
|
}
|
|
|
|
// use new database
|
|
$use = $xql->database($database,MPREFIX,true);
|
|
|
|
if($use === false)
|
|
{
|
|
$this->fail("Failed to select new database");
|
|
}
|
|
|
|
$create = "CREATE TABLE `".$database."`.".MPREFIX.$table." (
|
|
`test_id` int(4) NOT NULL AUTO_INCREMENT,
|
|
`test_var` varchar(255) NOT NULL,
|
|
PRIMARY KEY (`test_id`)
|
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
|
|
";
|
|
|
|
// create secondary database
|
|
if(!$xql->gen($create))
|
|
{
|
|
$this->fail("Failed to create table in secondary database");
|
|
}
|
|
|
|
|
|
// Insert
|
|
$arr = array('test_id'=>0, 'test_var'=>'Example insert');
|
|
if(!$xql->insert($table, $arr))
|
|
{
|
|
$err = $xql->getLastErrorText();
|
|
$this->fail("Failed to insert into secondary database: ".$err);
|
|
}
|
|
|
|
// Copy Row.
|
|
if(!$copied = $xql->db_CopyRow($table, '*', "test_id = 1"))
|
|
{
|
|
$err = $xql->getLastErrorText();
|
|
$this->fail("Failed to copy row into secondary database table: ".$err);
|
|
}
|
|
|
|
|
|
// Select
|
|
if(!$xql->select($table,'*','test_id !=0'))
|
|
{
|
|
$err = $xql->getLastErrorText();
|
|
$this->fail("Failed to select from secondary database: ".$err);
|
|
}
|
|
|
|
|
|
// fetch
|
|
$row = $xql->fetch();
|
|
$this->assertNotEmpty($row['test_var'], "Failed to fetch from secondary database");
|
|
$this->assertEquals('Example insert',$row['test_var'], $xql->getLastErrorText());
|
|
|
|
|
|
// update
|
|
$upd = array('test_var' => "Updated insert",'WHERE' => "test_id = 1");
|
|
if(!$xql->update($table,$upd))
|
|
{
|
|
$err = $xql->getLastErrorText();
|
|
$this->fail("Failed to update secondary database table: ".$err);
|
|
}
|
|
|
|
// update (legacy)
|
|
$upd2 = $xql->update($table, "test_var = 'Updated legacy' WHERE test_id = 1");
|
|
$this->assertNotEmpty($upd2, "UPDATE (legacy) failed on secondary database table: ".$xql->getLastErrorText());
|
|
|
|
|
|
// primary database retrieve
|
|
$username = e107::getDb()->retrieve('user','user_name', 'user_id = 1');
|
|
$this->assertNotEmpty($username, "Lost connection with primary database.");
|
|
|
|
|
|
// count
|
|
$count = $xql->count($table, "(*)", "test_id = 1");
|
|
$this->assertNotEmpty($count, "COUNT failed on secondary database table: ".$xql->getLastErrorText());
|
|
|
|
// delete
|
|
if(!$xql->delete($table, "test_id = 1"))
|
|
{
|
|
$err = $xql->getLastErrorText();
|
|
$this->fail("Failed to delete secondary database table row: ".$err);
|
|
}
|
|
|
|
// Truncate & isEmpty
|
|
$xql->truncate($table);
|
|
$empty = $xql->isEmpty($table);
|
|
$this->assertTrue($empty,"isEmpty() or truncate() failed");
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/*
|
|
public function testGetServerInfo()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDatabase()
|
|
{
|
|
|
|
}
|
|
|
|
public function testGetConfig()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Mark_Time()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Show_Performance()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Write_log()
|
|
{
|
|
|
|
}
|
|
*/
|
|
public function testDb_Query()
|
|
{
|
|
|
|
|
|
$userp = "3, 'Display Name', 'Username', '', 'password-hash', '', 'email@address.com', '', '', 0, ".time().", 0, 0, 0, 0, 0, '127.0.0.1', 0, '', 0, 1, '', '', '0', '', ".time().", ''";
|
|
$this->db->db_Query("REPLACE INTO ".MPREFIX."user VALUES ({$userp})" );
|
|
|
|
$res = $this->db->db_Query("SELECT user_email FROM ".MPREFIX."user WHERE user_id = 3");
|
|
$result = $res->fetch();
|
|
$this->assertEquals('email@address.com', $result['user_email']);
|
|
|
|
}
|
|
|
|
/*
|
|
public function testRetrieve()
|
|
{
|
|
|
|
}
|
|
|
|
public function testSelect()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Select()
|
|
{
|
|
|
|
}
|
|
*/
|
|
public function testInsert()
|
|
{
|
|
$actual = $this->db->insert('tmp', array('tmp_ip' => '127.0.0.1', 'tmp_time' => '12345435', 'tmp_info' => 'Insert test'));
|
|
$this->assertEquals(1, $actual, 'Unable to add record to table #tmp');
|
|
|
|
$expected = array(
|
|
'tmp_ip' => '127.0.0.1',
|
|
'tmp_time' => '12345435',
|
|
'tmp_info' => 'Insert test'
|
|
);
|
|
$actual = $this->db->retrieve('tmp', '*','tmp_ip = "127.0.0.1" AND tmp_time = 12345435');
|
|
$this->assertEquals($expected, $actual, 'Inserted content doesn\'t match the retrieved content');
|
|
}
|
|
/*
|
|
public function testLastInsertId()
|
|
{
|
|
|
|
}
|
|
|
|
public function testFoundRows()
|
|
{
|
|
|
|
}
|
|
|
|
public function testRowCount()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Insert()
|
|
{
|
|
|
|
}
|
|
|
|
public function testReplace()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Replace()
|
|
{
|
|
|
|
}
|
|
*/
|
|
public function testUpdate()
|
|
{
|
|
$db = $this->db;
|
|
|
|
$db->delete('tmp');
|
|
|
|
// Test 1
|
|
$expected = $db->update('tmp', array('tmp_ip' => '127.0.0.1', 'tmp_time' => time(), 'tmp_info' => 'Update test 1', 'WHERE' => 'tmp_ip="127.0.0.1"'));
|
|
$this->assertEmpty($expected, "Test 1 update() failed (not empty {$expected})");
|
|
|
|
$actual = 1;
|
|
// Test 2
|
|
$db->insert('tmp', array('tmp_ip' => '127.0.0.1', 'tmp_time' => time(), 'tmp_info' => 'test 2'));
|
|
$expected = $db->update('tmp', array('tmp_ip' => '127.0.0.1', 'tmp_time' => time(), 'tmp_info' => 'Update test 2a', 'WHERE' => 'tmp_ip="127.0.0.1"'));
|
|
$this->assertEquals($expected, $actual, "Test 2 update() failed ({$actual} != {$expected}");
|
|
|
|
// Test 3
|
|
$expected = $db->update('tmp', 'tmp_ip = "127.0.0.1", tmp_time = tmp_time + 1, tmp_info = "Update test 3" WHERE tmp_ip="127.0.0.1"');
|
|
$this->assertEquals($expected, $actual, "Test 3 update() failed ({$actual} != {$expected}");
|
|
|
|
}
|
|
/*
|
|
public function testDb_Update()
|
|
{
|
|
|
|
}
|
|
|
|
public function test_getTypes()
|
|
{
|
|
|
|
}
|
|
|
|
public function test_getFieldValue()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_UpdateArray()
|
|
{
|
|
|
|
}
|
|
|
|
public function testTruncate()
|
|
{
|
|
|
|
}
|
|
|
|
public function testFetch()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Fetch()
|
|
{
|
|
|
|
}
|
|
|
|
public function testCount()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Count()
|
|
{
|
|
|
|
}
|
|
|
|
public function testClose()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Close()
|
|
{
|
|
|
|
}
|
|
*/
|
|
public function testDelete()
|
|
{
|
|
// make sure the table is empty
|
|
$actual = $this->db->delete('tmp');
|
|
$this->assertNotEmpty($actual, 'Unable to empty the table.');
|
|
|
|
// Insert some records
|
|
$this->db->insert('tmp', array('tmp_ip' => '127.0.0.1', 'tmp_time' => time(), 'tmp_info' => 'Delete test 1'));
|
|
$this->db->insert('tmp', array('tmp_ip' => '127.0.0.2', 'tmp_time' => time(), 'tmp_info' => 'Delete test 2'));
|
|
$this->db->insert('tmp', array('tmp_ip' => '127.0.0.3', 'tmp_time' => time(), 'tmp_info' => 'Delete test 3'));
|
|
|
|
|
|
// Delete 1 record
|
|
$expected = 1;
|
|
$actual = $this->db->delete('tmp', 'tmp_ip="127.0.0.1"');
|
|
$this->assertEquals($expected, $actual, 'Unable to delete 1 records.');
|
|
|
|
// Delete all remaining (2) records
|
|
$expected = 2;
|
|
$actual = $this->db->delete('tmp');
|
|
$this->assertEquals($expected, $actual, 'Unable to delete the remaining records.');
|
|
|
|
// Delete from an table that doesn't exist
|
|
$actual = $this->db->delete('tmp_unknown_table');
|
|
$this->assertFalse($actual, 'Trying to delete records from an invalid table should return FALSE!');
|
|
}
|
|
/*
|
|
public function testDb_Delete()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Rows()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_SetErrorReporting()
|
|
{
|
|
|
|
}
|
|
|
|
public function testGen()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Select_gen()
|
|
{
|
|
|
|
}
|
|
|
|
public function testMl_check()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_IsLang()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_getList()
|
|
{
|
|
|
|
}
|
|
|
|
public function testRows()
|
|
{
|
|
|
|
}
|
|
|
|
public function testMax()
|
|
{
|
|
|
|
}
|
|
|
|
public function testSelectTree()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_QueryCount()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Query_all()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_FieldList()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Field()
|
|
{
|
|
|
|
}
|
|
|
|
public function testColumnCount()
|
|
{
|
|
|
|
}
|
|
|
|
public function testField()
|
|
{
|
|
|
|
}
|
|
|
|
public function testEscape()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Table_exists()
|
|
{
|
|
|
|
}
|
|
|
|
public function testIsTable()
|
|
{
|
|
|
|
}
|
|
|
|
public function testIsEmpty()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_ResetTableList()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_TableList()
|
|
{
|
|
|
|
}
|
|
|
|
public function testTables()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_CopyRow()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_CopyTable()
|
|
{
|
|
|
|
}
|
|
*/
|
|
public function testBackup()
|
|
{
|
|
$opts = array(
|
|
'gzip' => false,
|
|
'nologs' => false,
|
|
'droptable' => false,
|
|
);
|
|
|
|
$result = $this->db->backup('user,core_media_cat', null, $opts);
|
|
|
|
$tmp = file_get_contents($result);
|
|
|
|
$this->assertNotContains("DROP TABLE IF EXISTS `e107_user`;", $tmp);
|
|
$this->assertContains("CREATE TABLE `e107_user` (", $tmp);
|
|
$this->assertContains("INSERT INTO `e107_user` VALUES (1", $tmp);
|
|
$this->assertContains("CREATE TABLE `e107_core_media_cat`", $tmp);
|
|
|
|
|
|
}
|
|
/*
|
|
public function testDbError()
|
|
{
|
|
|
|
}
|
|
|
|
public function testGetLastErrorNumber()
|
|
{
|
|
|
|
}
|
|
|
|
public function testGetLastErrorText()
|
|
{
|
|
|
|
}
|
|
|
|
public function testResetLastError()
|
|
{
|
|
|
|
}
|
|
|
|
public function testGetLastQuery()
|
|
{
|
|
|
|
}
|
|
|
|
public function testDb_Set_Charset()
|
|
{
|
|
|
|
}
|
|
|
|
public function testGetFieldDefs()
|
|
{
|
|
|
|
}*/
|
|
}
|