--- /dev/null
+<?php
+
+namespace RedUNIT\Base;
+
+use RedUNIT\Base as Base;
+use RedBeanPHP\Facade as R;
+use RedBeanPHP\Observer as Observer;
+use RedBeanPHP\OODBBean as OODBBean;
+use RedBeanPHP\Adapter as Adapter;
+use RedBeanPHP\QueryWriter\AQueryWriter as AQueryWriter;
+
+/**
+ * Foreignkeys
+ *
+ * Tests whether foreign keys are correctly generated and whether
+ * depending beans are correctly removed. Also tests auto resolving
+ * types inferred by inspecting foreign keys.
+ *
+ * @file RedUNIT/Base/Foreignkeys.php
+ * @desc Tests foreign key handling and dynamic foreign keys with
+ * @author Gabor de Mooij and the RedBeanPHP Community
+ * @license New BSD/GPLv2
+ *
+ * (c) G.J.G.T. (Gabor) de Mooij and the RedBeanPHP Community.
+ * This source file is subject to the New BSD/GPLv2 License that is bundled
+ * with this source code in the file license.txt.
+ */
+class Foreignkeys extends Base implements Observer
+{
+ /**
+ * To log the queries
+ *
+ * @var array
+ */
+ private $queries = array();
+
+ /**
+ * Test whether aliases are not used if not necessary:
+ * when using fetchAs() or R::aliases().
+ *
+ * @return void
+ */
+ public function testAutoResolvAvoid()
+ {
+ R::setAutoResolve( TRUE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->cover = $page;
+ R::store( $book );
+ $book = $book->fresh();
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ $book->cover;
+ asrt( $book->getMeta('sys.autoresolved.cover'), 'page' );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->cover = $page;
+ R::store( $book );
+ $book = $book->fresh();
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ $book->fetchAs('page')->cover;
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ R::nuke();
+ R::aliases( array( 'cover' => 'page' ) );
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->cover = $page;
+ R::store( $book );
+ $book = $book->fresh();
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ $cover = $book->cover;
+ asrt( ( $cover instanceof OODBBean ), TRUE );
+ asrt( $cover->getMeta( 'type' ), 'page' );
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ R::aliases( array() );
+ R::nuke();
+ R::setAutoResolve( FALSE );
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->cover = $page;
+ R::store( $book );
+ $book = $book->fresh();
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ $book->cover;
+ asrt( $book->getMeta('sys.autoresolved.cover'), NULL );
+ R::setAutoResolve( TRUE );
+ }
+
+ /**
+ * Test whether unique constraints are properly created using
+ * reflection.
+ *
+ * @return void
+ */
+ public function testUniqueInspect()
+ {
+ $writer = R::getWriter();
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $category = R::dispense( 'category' );
+ $book->sharedCategory[] = $category;
+ R::store( $book );
+ asrt( count( get_uniques_for_type('book_category') ), 1 );
+ asrt( are_cols_in_unique( 'book_category', array( 'book_id', 'category_id' ) ), TRUE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $category = R::dispense( 'category' );
+ $book->via( 'library' )->sharedCategory[] = $category;
+ R::store( $book );
+ asrt( count( get_uniques_for_type('book_category') ), 0 );
+ asrt( are_cols_in_unique( 'book_category', array( 'book_id', 'category_id' ) ), FALSE );
+ asrt( count( get_uniques_for_type('library') ), 1 );
+ asrt( are_cols_in_unique( 'library', array( 'book_id', 'category_id' ) ), TRUE );
+ AQueryWriter::clearRenames();
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $category = R::dispense( 'category' );
+ $book->sharedCategory[] = $category;
+ R::store( $book );
+ asrt( count( get_uniques_for_type('book_category') ), 1 );
+ asrt( are_cols_in_unique( 'book_category', array( 'book_id', 'category_id' ) ), TRUE );
+ asrt( count( get_uniques_for_type('library') ), 0 );
+ asrt( are_cols_in_unique( 'library', array( 'book_id', 'category_id' ) ), FALSE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $book2 = R::dispense( 'book' );
+ $book->sharedBook[] = $book2;
+ R::store( $book );
+ asrt( count( get_uniques_for_type('book_book') ), 1 );
+ asrt( are_cols_in_unique( 'book_book', array( 'book_id', 'book2_id' ) ), TRUE );
+ try {
+ $result = R::getWriter()->addUniqueConstraint( 'nonexistant', array( 'a', 'b' ) );
+ } catch( \Exception $e ) {
+ print_r( $e ); exit;
+ }
+ pass(); //dont crash!
+ asrt( $result, FALSE );
+ }
+
+ /**
+ * Tests foreign keys but checks using ProxyWriter.
+ *
+ * @return void
+ */
+ public function testFKInspect()
+ {
+ $faultyWriter = new \FaultyWriter( R::getDatabaseAdapter() );
+ try {
+ $null = \ProxyWriter::callMethod( $faultyWriter, 'getForeignKeyForTypeProperty', 'test', 'test' );
+ pass();
+ } catch( \Exception $e ) {
+ fail();
+ }
+ asrt( is_null( $null ), TRUE );
+ $writer = R::getWriter();
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->xownPage[] = $page;
+ R::store( $book );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'book_id' );
+ asrt( is_array( $keys ), TRUE );
+ asrt( $keys['on_delete'], 'CASCADE' );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'id' );
+ asrt( is_null( $keys ), TRUE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->ownPage[] = $page;
+ R::store( $book );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'book_id' );
+ asrt( is_array( $keys ), TRUE );
+ asrt( $keys['on_delete'], 'SET NULL' );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'id' );
+ asrt( is_null( $keys ), TRUE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->alias('magazine')->xownPage[] = $page;
+ R::store( $book );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'magazine_id' );
+ asrt( is_array( $keys ), TRUE );
+ asrt( $keys['on_delete'], 'CASCADE' );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'book_id' );
+ asrt( is_null( $keys ), TRUE );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'page', 'id' );
+ asrt( is_null( $keys ), TRUE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $page = R::dispense( 'page' );
+ $book->cover= $page;
+ R::store( $book );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'book', 'cover_id' );
+ asrt( is_array( $keys ), TRUE );
+ asrt( $keys['on_delete'], 'SET NULL' );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'book', 'page_id' );
+ asrt( is_null( $keys ), TRUE );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'book', 'id' );
+ asrt( is_null( $keys ), TRUE );
+ R::nuke();
+ $book = R::dispense( 'book' );
+ $category = R::dispense( 'category' );
+ $book->sharedTag[] = $category;
+ R::store( $book );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'book_category', 'book_id' );
+ asrt( is_array( $keys ), TRUE );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'book_category', 'category_id' );
+ asrt( is_array( $keys ), TRUE );
+ $keys = \ProxyWriter::callMethod( $writer, 'getForeignKeyForTypeProperty', 'book_category', 'id' );
+ asrt( is_null( $keys ), TRUE );
+ }
+
+ /**
+ * Test dependencies.
+ *
+ * @return void
+ */
+ public function testDependency()
+ {
+ $can = $this->createBeanInCan( FALSE );
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ // Bean stays
+ asrt( R::count( 'bean' ), 1 );
+ }
+
+ /**
+ * Test dependencies (variation).
+ *
+ * @return void
+ */
+ public function testDependency2()
+ {
+ $can = $this->createBeanInCan( TRUE );
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ // Bean gone
+ asrt( R::count( 'bean' ), 0 );
+
+ $can = $this->createBeanInCan( FALSE );
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ // Bean stays, constraint removed
+ asrt( R::count( 'bean' ), 0 );
+
+ //need to recreate table to get rid of constraint!
+ R::nuke();
+
+ $can = $this->createBeanInCan( FALSE );
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ // Bean stays, constraint removed
+ asrt( R::count( 'bean' ), 1 );
+
+ }
+
+ /**
+ * Tests dependencies (variation).
+ *
+ * @return void
+ */
+ public function testDependency3()
+ {
+ R::nuke();
+
+ $can = $this->createCanForBean();
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ asrt( R::count( 'bean' ), 1 );
+ }
+
+ /**
+ * Tests dependencies (variation).
+ *
+ * @return void
+ */
+ public function testDependency4()
+ {
+ R::nuke();
+
+ $can = $this->createBeanInCan( TRUE );
+
+ R::store( $can );
+
+ R::trash( $can );
+
+ $can = $this->createCanForBean();
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ asrt( R::count( 'bean' ), 0 );
+
+ $can = $this->createBeanInCan( TRUE );
+
+ R::store( $can );
+
+ R::trash( $can );
+
+ $can = $this->createCanForBean();
+
+ asrt( R::count( 'bean' ), 1 );
+
+ R::trash( $can );
+
+ asrt( R::count( 'bean' ), 0 );
+ }
+
+ /**
+ * Issue #171
+ * The index name argument is not unique in processEmbeddedBean etc.
+ *
+ * @return void
+ */
+ public function testIssue171()
+ {
+ R::getDatabaseAdapter()->addEventListener( 'sql_exec', $this );
+
+ $account = R::dispense( 'account' );
+ $user = R::dispense( 'user' );
+ $player = R::dispense( 'player' );
+
+ $account->ownUser[] = $user;
+
+ R::store( $account );
+
+ asrt( strpos( implode( ',', $this->queries ), 'index_foreignkey_user_account' ) !== FALSE, TRUE );
+
+ $this->queries = array();
+
+ $account->ownPlayer[] = $player;
+
+ R::store( $account );
+
+ asrt( strpos( implode( ',', $this->queries ), 'index_foreignkey_player_accou' ) !== FALSE, TRUE );
+ }
+
+ /**
+ * Tests whether foreign keys are created correctly for certain
+ * relations.
+ *
+ * @return void
+ */
+ public function testCreationOfForeignKeys()
+ {
+ $this->queries = array();
+
+ $account = R::dispense( 'account' );
+ $user = R::dispense( 'user' );
+ $player = R::dispense( 'player' );
+
+ $user->account = $account;
+
+ R::store( $user );
+
+ asrt( strpos( implode( ',', $this->queries ), 'index_foreignkey_user_account' ) !== FALSE, TRUE );
+
+ $this->queries = array();
+
+ $player->account = $account;
+
+ R::store( $player );
+
+ asrt( strpos( implode( ',', $this->queries ), 'index_foreignkey_player_accou' ) !== FALSE, TRUE );
+ }
+
+ /**
+ * Test helper method.
+ * Creates a bean in a can. The bean will get a reference
+ * to the can and can be made dependent.
+ *
+ * @return OODBBean $can
+ */
+ private function createBeanInCan( $isExcl )
+ {
+ $can = R::dispense( 'can' );
+ $bean = R::dispense( 'bean' );
+
+ $can->name = 'bakedbeans';
+ $bean->taste = 'salty';
+
+ if ($isExcl) {
+ $can->xownBean[] = $bean;
+ } else {
+ $can->ownBean[] = $bean;
+ }
+
+ R::store( $can );
+
+ return $can;
+ }
+
+ /**
+ * Test helper method.
+ * Creates a bean in a can beginning with the bean. The bean will get a reference
+ * to the can and can be made dependent.
+ *
+ * @return OODBBean $can
+ */
+ private function createCanForBean()
+ {
+ $can = R::dispense( 'can' );
+ $bean = R::dispense( 'bean' );
+
+ $bean->can = $can;
+
+ R::store( $bean );
+
+ return $can;
+ }
+
+ /**
+ * Log queries
+ *
+ * @param string $event
+ * @param Adapter $info
+ */
+ public function onEvent( $event, $info )
+ {
+ $this->queries[] = $info->getSQL();
+ }
+}
projects / yaffs-website / blobdiff