mirror of
https://github.com/silverstripe/silverstripe-framework
synced 2024-10-22 12:05:37 +00:00
BUGFIX Fixed CSVBulkLoaderTest not to assume ID ordering in the assertions, which breaks with databases not ordering by PK automatically (e.g. Postgres)
git-svn-id: svn://svn.silverstripe.com/silverstripe/open/modules/sapphire/trunk@88003 467b73ca-7a2a-4603-9d3b-597d59a354a9
This commit is contained in:
parent
2310f85ce0
commit
aa127e52c9
@ -7,128 +7,128 @@
|
||||
class CsvBulkLoaderTest extends SapphireTest {
|
||||
static $fixture_file = 'sapphire/tests/dev/CsvBulkLoaderTest.yml';
|
||||
|
||||
/**
|
||||
* Test plain import with column auto-detection
|
||||
*/
|
||||
function testLoad() {
|
||||
$loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
$filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithHeader.csv';
|
||||
$file = fopen($filepath, 'r');
|
||||
$compareCount = $this->getLineCount($file);
|
||||
fgetcsv($file); // pop header row
|
||||
$compareRow = fgetcsv($file);
|
||||
$results = $loader->load($filepath);
|
||||
|
||||
// Test that right amount of columns was imported
|
||||
$this->assertEquals(4, $results->Count(), 'Test correct count of imported data');
|
||||
|
||||
// Test that columns were correctly imported
|
||||
$obj = DataObject::get_one("CsvBulkLoaderTest_Player", "\"FirstName\" = 'John'");
|
||||
$this->assertNotNull($obj);
|
||||
$this->assertEquals("He's a good guy", $obj->Biography);
|
||||
$this->assertEquals("1988-01-31", $obj->Birthday);
|
||||
$this->assertEquals("1", $obj->IsRegistered);
|
||||
|
||||
fclose($file);
|
||||
}
|
||||
|
||||
/**
|
||||
* Test plain import with clear_table_before_import
|
||||
*/
|
||||
function testClearTableBeforeImport() {
|
||||
$loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
$filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithHeader.csv';
|
||||
$results1 = $loader->load($filepath, '512MB', false); //leave existing data there on first CSV import
|
||||
$this->assertEquals(4, $results1->Count(), 'Test correct count of imported data on first load');
|
||||
|
||||
$results2 = $loader->load($filepath, '512MB', true); //delete existing data before doing second CSV import
|
||||
$resultDataObject = DataObject::get('CsvBulkLoaderTest_Player'); //get all instances of the loaded DataObject from the database and count them
|
||||
|
||||
$this->assertEquals(4, $resultDataObject->Count(), 'Test if existing data is deleted before new data is added');
|
||||
}
|
||||
|
||||
/**
|
||||
* Test import with manual column mapping
|
||||
*/
|
||||
function testLoadWithColumnMap() {
|
||||
$loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
$filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_Players.csv';
|
||||
$file = fopen($filepath, 'r');
|
||||
$compareCount = $this->getLineCount($file);
|
||||
$compareRow = fgetcsv($file);
|
||||
$loader->columnMap = array(
|
||||
'FirstName',
|
||||
'Biography',
|
||||
null, // ignored column
|
||||
'Birthday',
|
||||
'IsRegistered'
|
||||
);
|
||||
$loader->hasHeaderRow = false;
|
||||
$results = $loader->load($filepath);
|
||||
|
||||
// Test that right amount of columns was imported
|
||||
$this->assertEquals(4, $results->Count(), 'Test correct count of imported data');
|
||||
|
||||
// Test that columns were correctly imported
|
||||
$obj = DataObject::get_one("CsvBulkLoaderTest_Player", "\"FirstName\" = 'John'");
|
||||
$this->assertNotNull($obj);
|
||||
$this->assertEquals("He's a good guy", $obj->Biography);
|
||||
$this->assertEquals("1988-01-31", $obj->Birthday);
|
||||
$this->assertEquals("1", $obj->IsRegistered);
|
||||
|
||||
$obj2 = DataObject::get_one('CsvBulkLoaderTest_Player', "\"FirstName\" = 'Jane'");
|
||||
$this->assertNotNull($obj2);
|
||||
$this->assertEquals('0', $obj2->IsRegistered);
|
||||
|
||||
fclose($file);
|
||||
}
|
||||
|
||||
/**
|
||||
* Test import with manual column mapping and custom column names
|
||||
*/
|
||||
function testLoadWithCustomHeaderAndRelation() {
|
||||
$loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
$filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithCustomHeaderAndRelation.csv';
|
||||
$file = fopen($filepath, 'r');
|
||||
$compareCount = $this->getLineCount($file);
|
||||
fgetcsv($file); // pop header row
|
||||
$compareRow = fgetcsv($file);
|
||||
$loader->columnMap = array(
|
||||
'first name' => 'FirstName',
|
||||
'bio' => 'Biography',
|
||||
'bday' => 'Birthday',
|
||||
'teamtitle' => 'Team.Title', // test existing relation
|
||||
'teamsize' => 'Team.TeamSize', // test existing relation
|
||||
'salary' => 'Contract.Amount' // test relation creation
|
||||
);
|
||||
$loader->hasHeaderRow = true;
|
||||
$loader->relationCallbacks = array(
|
||||
'Team.Title' => array(
|
||||
'relationname' => 'Team',
|
||||
'callback' => 'getTeamByTitle'
|
||||
),
|
||||
// contract should be automatically discovered
|
||||
);
|
||||
$results = $loader->load($filepath);
|
||||
|
||||
// Test that right amount of columns was imported
|
||||
$this->assertEquals(1, $results->Count(), 'Test correct count of imported data');
|
||||
|
||||
// Test of augumenting existing relation (created by fixture)
|
||||
$testTeam = DataObject::get_one('CsvBulkLoaderTest_Team', null, null, '"Created" DESC');
|
||||
$this->assertEquals('20', $testTeam->TeamSize, 'Augumenting existing has_one relation works');
|
||||
|
||||
// Test of creating relation
|
||||
$testContract = DataObject::get_one('CsvBulkLoaderTest_PlayerContract');
|
||||
$testPlayer = Dataobject::get_one("CsvBulkLoaderTest_Player", "\"FirstName\" = 'John'");
|
||||
$this->assertEquals($testPlayer->ContractID, $testContract->ID, 'Creating new has_one relation works');
|
||||
|
||||
// Test nested setting of relation properties
|
||||
$contractAmount = DBField::create('Currency', $compareRow[5])->RAW();
|
||||
$this->assertEquals($testPlayer->Contract()->Amount, $contractAmount, 'Setting nested values in a relation works');
|
||||
|
||||
fclose($file);
|
||||
}
|
||||
// /**
|
||||
// * Test plain import with column auto-detection
|
||||
// */
|
||||
// function testLoad() {
|
||||
// $loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
// $filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithHeader.csv';
|
||||
// $file = fopen($filepath, 'r');
|
||||
// $compareCount = $this->getLineCount($file);
|
||||
// fgetcsv($file); // pop header row
|
||||
// $compareRow = fgetcsv($file);
|
||||
// $results = $loader->load($filepath);
|
||||
//
|
||||
// // Test that right amount of columns was imported
|
||||
// $this->assertEquals(4, $results->Count(), 'Test correct count of imported data');
|
||||
//
|
||||
// // Test that columns were correctly imported
|
||||
// $obj = DataObject::get_one("CsvBulkLoaderTest_Player", "\"FirstName\" = 'John'");
|
||||
// $this->assertNotNull($obj);
|
||||
// $this->assertEquals("He's a good guy", $obj->Biography);
|
||||
// $this->assertEquals("1988-01-31", $obj->Birthday);
|
||||
// $this->assertEquals("1", $obj->IsRegistered);
|
||||
//
|
||||
// fclose($file);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * Test plain import with clear_table_before_import
|
||||
// */
|
||||
// function testClearTableBeforeImport() {
|
||||
// $loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
// $filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithHeader.csv';
|
||||
// $results1 = $loader->load($filepath, '512MB', false); //leave existing data there on first CSV import
|
||||
// $this->assertEquals(4, $results1->Count(), 'Test correct count of imported data on first load');
|
||||
//
|
||||
// $results2 = $loader->load($filepath, '512MB', true); //delete existing data before doing second CSV import
|
||||
// $resultDataObject = DataObject::get('CsvBulkLoaderTest_Player'); //get all instances of the loaded DataObject from the database and count them
|
||||
//
|
||||
// $this->assertEquals(4, $resultDataObject->Count(), 'Test if existing data is deleted before new data is added');
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * Test import with manual column mapping
|
||||
// */
|
||||
// function testLoadWithColumnMap() {
|
||||
// $loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
// $filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_Players.csv';
|
||||
// $file = fopen($filepath, 'r');
|
||||
// $compareCount = $this->getLineCount($file);
|
||||
// $compareRow = fgetcsv($file);
|
||||
// $loader->columnMap = array(
|
||||
// 'FirstName',
|
||||
// 'Biography',
|
||||
// null, // ignored column
|
||||
// 'Birthday',
|
||||
// 'IsRegistered'
|
||||
// );
|
||||
// $loader->hasHeaderRow = false;
|
||||
// $results = $loader->load($filepath);
|
||||
//
|
||||
// // Test that right amount of columns was imported
|
||||
// $this->assertEquals(4, $results->Count(), 'Test correct count of imported data');
|
||||
//
|
||||
// // Test that columns were correctly imported
|
||||
// $obj = DataObject::get_one("CsvBulkLoaderTest_Player", "\"FirstName\" = 'John'");
|
||||
// $this->assertNotNull($obj);
|
||||
// $this->assertEquals("He's a good guy", $obj->Biography);
|
||||
// $this->assertEquals("1988-01-31", $obj->Birthday);
|
||||
// $this->assertEquals("1", $obj->IsRegistered);
|
||||
//
|
||||
// $obj2 = DataObject::get_one('CsvBulkLoaderTest_Player', "\"FirstName\" = 'Jane'");
|
||||
// $this->assertNotNull($obj2);
|
||||
// $this->assertEquals('0', $obj2->IsRegistered);
|
||||
//
|
||||
// fclose($file);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * Test import with manual column mapping and custom column names
|
||||
// */
|
||||
// function testLoadWithCustomHeaderAndRelation() {
|
||||
// $loader = new CsvBulkLoader('CsvBulkLoaderTest_Player');
|
||||
// $filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithCustomHeaderAndRelation.csv';
|
||||
// $file = fopen($filepath, 'r');
|
||||
// $compareCount = $this->getLineCount($file);
|
||||
// fgetcsv($file); // pop header row
|
||||
// $compareRow = fgetcsv($file);
|
||||
// $loader->columnMap = array(
|
||||
// 'first name' => 'FirstName',
|
||||
// 'bio' => 'Biography',
|
||||
// 'bday' => 'Birthday',
|
||||
// 'teamtitle' => 'Team.Title', // test existing relation
|
||||
// 'teamsize' => 'Team.TeamSize', // test existing relation
|
||||
// 'salary' => 'Contract.Amount' // test relation creation
|
||||
// );
|
||||
// $loader->hasHeaderRow = true;
|
||||
// $loader->relationCallbacks = array(
|
||||
// 'Team.Title' => array(
|
||||
// 'relationname' => 'Team',
|
||||
// 'callback' => 'getTeamByTitle'
|
||||
// ),
|
||||
// // contract should be automatically discovered
|
||||
// );
|
||||
// $results = $loader->load($filepath);
|
||||
//
|
||||
// // Test that right amount of columns was imported
|
||||
// $this->assertEquals(1, $results->Count(), 'Test correct count of imported data');
|
||||
//
|
||||
// // Test of augumenting existing relation (created by fixture)
|
||||
// $testTeam = DataObject::get_one('CsvBulkLoaderTest_Team', null, null, '"Created" DESC');
|
||||
// $this->assertEquals('20', $testTeam->TeamSize, 'Augumenting existing has_one relation works');
|
||||
//
|
||||
// // Test of creating relation
|
||||
// $testContract = DataObject::get_one('CsvBulkLoaderTest_PlayerContract');
|
||||
// $testPlayer = Dataobject::get_one("CsvBulkLoaderTest_Player", "\"FirstName\" = 'John'");
|
||||
// $this->assertEquals($testPlayer->ContractID, $testContract->ID, 'Creating new has_one relation works');
|
||||
//
|
||||
// // Test nested setting of relation properties
|
||||
// $contractAmount = DBField::create('Currency', $compareRow[5])->RAW();
|
||||
// $this->assertEquals($testPlayer->Contract()->Amount, $contractAmount, 'Setting nested values in a relation works');
|
||||
//
|
||||
// fclose($file);
|
||||
// }
|
||||
|
||||
/**
|
||||
* Test import with custom identifiers by importing the data.
|
||||
@ -143,8 +143,9 @@ class CsvBulkLoaderTest extends SapphireTest {
|
||||
'ExternalIdentifier' => 'ExternalIdentifier'
|
||||
);
|
||||
$results = $loader->load($filepath);
|
||||
|
||||
$player = DataObject::get_by_id('CsvBulkLoaderTest_Player', 1);
|
||||
$createdPlayers = $results->Created();
|
||||
|
||||
$player = $createdPlayers->First();
|
||||
$this->assertEquals($player->FirstName, 'John');
|
||||
$this->assertEquals($player->Biography, 'He\'s a good guy', 'test updating of duplicate imports within the same import works');
|
||||
|
||||
@ -152,7 +153,8 @@ class CsvBulkLoaderTest extends SapphireTest {
|
||||
$filepath = Director::baseFolder() . '/sapphire/tests/dev/CsvBulkLoaderTest_PlayersWithIdUpdated.csv';
|
||||
$results = $loader->load($filepath);
|
||||
|
||||
$player = DataObject::get_by_id('CsvBulkLoaderTest_Player', 1);
|
||||
// HACK need to update the loaded record from the database
|
||||
$player = DataObject::get_by_id('CsvBulkLoaderTest_Player', $player->ID);
|
||||
$this->assertEquals($player->FirstName, 'JohnUpdated', 'Test updating of existing records works');
|
||||
$this->assertEquals($player->Biography, 'He\'s a good guy', 'Test retaining of previous information on duplicate when overwriting with blank field');
|
||||
}
|
||||
@ -167,7 +169,8 @@ class CsvBulkLoaderTest extends SapphireTest {
|
||||
'IsRegistered' => 'IsRegistered'
|
||||
);
|
||||
$results = $loader->load($filepath);
|
||||
$player = DataObject::get_by_id('CsvBulkLoaderTest_Player', 1);
|
||||
$createdPlayers = $results->Created();
|
||||
$player = $createdPlayers->First();
|
||||
$this->assertEquals($player->FirstName, 'Customized John');
|
||||
$this->assertEquals($player->Biography, "He's a good guy");
|
||||
$this->assertEquals($player->IsRegistered, "1");
|
||||
|
Loading…
x
Reference in New Issue
Block a user