+++ /dev/null
-<?php
-
-namespace RedBeanPHP;
-
-use RedBeanPHP\Adapter\DBAdapter as DBAdapter;
-use RedBeanPHP\QueryWriter as QueryWriter;
-use RedBeanPHP\RedException as RedException;
-use RedBeanPHP\RedException\SQL as SQLException;
-
-/**
- * Association Manager.
- * Manages simple bean associations.
- *
- * @file RedBeanPHP/AssociationManager.php
- * @author Gabor de Mooij and the RedBeanPHP Community
- * @license BSD/GPLv2
- *
- * @copyright
- * (c) G.J.G.T. (Gabor) de Mooij and the RedBeanPHP Community.
- * This source file is subject to the BSD/GPLv2 License that is bundled
- * with this source code in the file license.txt.
- */
-class AssociationManager extends Observable
-{
- /**
- * @var OODB
- */
- protected $oodb;
-
- /**
- * @var DBAdapter
- */
- protected $adapter;
-
- /**
- * @var QueryWriter
- */
- protected $writer;
-
- /**
- * Handles exceptions. Suppresses exceptions caused by missing structures.
- *
- * @param \Exception $exception exception to handle
- *
- * @return void
- */
- private function handleException( \Exception $exception )
- {
- if ( $this->oodb->isFrozen() || !$this->writer->sqlStateIn( $exception->getSQLState(),
- array(
- QueryWriter::C_SQLSTATE_NO_SUCH_TABLE,
- QueryWriter::C_SQLSTATE_NO_SUCH_COLUMN )
- )
- ) {
- throw $exception;
- }
- }
-
- /**
- * Internal method.
- * Returns the many-to-many related rows of table $type for bean $bean using additional SQL in $sql and
- * $bindings bindings. If $getLinks is TRUE, link rows are returned instead.
- *
- * @param OODBBean $bean reference bean instance
- * @param string $type target bean type
- * @param string $sql additional SQL snippet
- * @param array $bindings bindings for query
- *
- * @return array
- */
- private function relatedRows( $bean, $type, $sql = '', $bindings = array() )
- {
- $ids = array( $bean->id );
- $sourceType = $bean->getMeta( 'type' );
- try {
- return $this->writer->queryRecordRelated( $sourceType, $type, $ids, $sql, $bindings );
- } catch ( SQLException $exception ) {
- $this->handleException( $exception );
- return array();
- }
- }
-
- /**
- * Associates a pair of beans. This method associates two beans, no matter
- * what types. Accepts a base bean that contains data for the linking record.
- * This method is used by associate. This method also accepts a base bean to be used
- * as the template for the link record in the database.
- *
- * @param OODBBean $bean1 first bean
- * @param OODBBean $bean2 second bean
- * @param OODBBean $bean base bean (association record)
- *
- * @return mixed
- */
- protected function associateBeans( OODBBean $bean1, OODBBean $bean2, OODBBean $bean )
- {
- $type = $bean->getMeta( 'type' );
- $property1 = $bean1->getMeta( 'type' ) . '_id';
- $property2 = $bean2->getMeta( 'type' ) . '_id';
-
- if ( $property1 == $property2 ) {
- $property2 = $bean2->getMeta( 'type' ) . '2_id';
- }
-
- $this->oodb->store( $bean1 );
- $this->oodb->store( $bean2 );
-
- $bean->setMeta( "cast.$property1", "id" );
- $bean->setMeta( "cast.$property2", "id" );
- $bean->setMeta( 'sys.buildcommand.unique', array( $property1, $property2 ) );
-
- $bean->$property1 = $bean1->id;
- $bean->$property2 = $bean2->id;
-
- $results = array();
-
- try {
- $id = $this->oodb->store( $bean );
- $results[] = $id;
- } catch ( SQLException $exception ) {
- if ( !$this->writer->sqlStateIn( $exception->getSQLState(),
- array( QueryWriter::C_SQLSTATE_INTEGRITY_CONSTRAINT_VIOLATION ) )
- ) {
- throw $exception;
- }
- }
-
- return $results;
- }
-
- /**
- * Constructor
- *
- * @param ToolBox $tools toolbox
- */
- public function __construct( ToolBox $tools )
- {
- $this->oodb = $tools->getRedBean();
- $this->adapter = $tools->getDatabaseAdapter();
- $this->writer = $tools->getWriter();
- $this->toolbox = $tools;
- }
-
- /**
- * Creates a table name based on a types array.
- * Manages the get the correct name for the linking table for the
- * types provided.
- *
- * @param array $types 2 types as strings
- *
- * @return string
- */
- public function getTable( $types )
- {
- return $this->writer->getAssocTable( $types );
- }
-
- /**
- * Associates two beans in a many-to-many relation.
- * This method will associate two beans and store the connection between the
- * two in a link table. Instead of two single beans this method also accepts
- * two sets of beans. Returns the ID or the IDs of the linking beans.
- *
- * @param OODBBean|array $beans1 one or more beans to form the association
- * @param OODBBean|array $beans2 one or more beans to form the association
- *
- * @return array
- */
- public function associate( $beans1, $beans2 )
- {
- if ( !is_array( $beans1 ) ) {
- $beans1 = array( $beans1 );
- }
-
- if ( !is_array( $beans2 ) ) {
- $beans2 = array( $beans2 );
- }
-
- $results = array();
- foreach ( $beans1 as $bean1 ) {
- foreach ( $beans2 as $bean2 ) {
- $table = $this->getTable( array( $bean1->getMeta( 'type' ), $bean2->getMeta( 'type' ) ) );
- $bean = $this->oodb->dispense( $table );
- $results[] = $this->associateBeans( $bean1, $bean2, $bean );
- }
- }
-
- return ( count( $results ) > 1 ) ? $results : reset( $results );
- }
-
- /**
- * Counts the number of related beans in an N-M relation.
- * This method returns the number of beans of type $type associated
- * with reference bean(s) $bean. The query can be tuned using an
- * SQL snippet for additional filtering.
- *
- * @param OODBBean|array $bean a bean object or an array of beans
- * @param string $type type of bean you're interested in
- * @param string $sql SQL snippet (optional)
- * @param array $bindings bindings for your SQL string
- *
- * @return integer
- */
- public function relatedCount( $bean, $type, $sql = NULL, $bindings = array() )
- {
- if ( !( $bean instanceof OODBBean ) ) {
- throw new RedException(
- 'Expected array or OODBBean but got:' . gettype( $bean )
- );
- }
-
- if ( !$bean->id ) {
- return 0;
- }
-
- $beanType = $bean->getMeta( 'type' );
-
- try {
- return $this->writer->queryRecordCountRelated( $beanType, $type, $bean->id, $sql, $bindings );
- } catch ( SQLException $exception ) {
- $this->handleException( $exception );
-
- return 0;
- }
- }
-
- /**
- * Breaks the association between two beans. This method unassociates two beans. If the
- * method succeeds the beans will no longer form an association. In the database
- * this means that the association record will be removed. This method uses the
- * OODB trash() method to remove the association links, thus giving FUSE models the
- * opportunity to hook-in additional business logic. If the $fast parameter is
- * set to boolean TRUE this method will remove the beans without their consent,
- * bypassing FUSE. This can be used to improve performance.
- *
- * @param OODBBean $bean1 first bean in target association
- * @param OODBBean $bean2 second bean in target association
- * @param boolean $fast if TRUE, removes the entries by query without FUSE
- *
- * @return void
- */
- public function unassociate( $beans1, $beans2, $fast = NULL )
- {
- $beans1 = ( !is_array( $beans1 ) ) ? array( $beans1 ) : $beans1;
- $beans2 = ( !is_array( $beans2 ) ) ? array( $beans2 ) : $beans2;
-
- foreach ( $beans1 as $bean1 ) {
- foreach ( $beans2 as $bean2 ) {
- try {
- $this->oodb->store( $bean1 );
- $this->oodb->store( $bean2 );
-
- $type1 = $bean1->getMeta( 'type' );
- $type2 = $bean2->getMeta( 'type' );
-
- $row = $this->writer->queryRecordLink( $type1, $type2, $bean1->id, $bean2->id );
- $linkType = $this->getTable( array( $type1, $type2 ) );
-
- if ( $fast ) {
- $this->writer->deleteRecord( $linkType, array( 'id' => $row['id'] ) );
-
- return;
- }
-
- $beans = $this->oodb->convertToBeans( $linkType, array( $row ) );
-
- if ( count( $beans ) > 0 ) {
- $bean = reset( $beans );
- $this->oodb->trash( $bean );
- }
- } catch ( SQLException $exception ) {
- $this->handleException( $exception );
- }
- }
- }
- }
-
- /**
- * Removes all relations for a bean. This method breaks every connection between
- * a certain bean $bean and every other bean of type $type. Warning: this method
- * is really fast because it uses a direct SQL query however it does not inform the
- * models about this. If you want to notify FUSE models about deletion use a foreach-loop
- * with unassociate() instead. (that might be slower though)
- *
- * @param OODBBean $bean reference bean
- * @param string $type type of beans that need to be unassociated
- *
- * @return void
- */
- public function clearRelations( OODBBean $bean, $type )
- {
- $this->oodb->store( $bean );
- try {
- $this->writer->deleteRelations( $bean->getMeta( 'type' ), $type, $bean->id );
- } catch ( SQLException $exception ) {
- $this->handleException( $exception );
- }
- }
-
- /**
- * Returns all the beans associated with $bean.
- * This method will return an array containing all the beans that have
- * been associated once with the associate() function and are still
- * associated with the bean specified. The type parameter indicates the
- * type of beans you are looking for. You can also pass some extra SQL and
- * values for that SQL to filter your results after fetching the
- * related beans.
- *
- * Don't try to make use of subqueries, a subquery using IN() seems to
- * be slower than two queries!
- *
- * Since 3.2, you can now also pass an array of beans instead just one
- * bean as the first parameter.
- *
- * @param OODBBean|array $bean the bean you have
- * @param string $type the type of beans you want
- * @param string $sql SQL snippet for extra filtering
- * @param array $bindings values to be inserted in SQL slots
- *
- * @return array
- */
- public function related( $bean, $type, $sql = '', $bindings = array() )
- {
- $sql = $this->writer->glueSQLCondition( $sql );
- $rows = $this->relatedRows( $bean, $type, $sql, $bindings );
- $links = array();
-
- foreach ( $rows as $key => $row ) {
- if ( !isset( $links[$row['id']] ) ) $links[$row['id']] = array();
- $links[$row['id']][] = $row['linked_by'];
- unset( $rows[$key]['linked_by'] );
- }
-
- $beans = $this->oodb->convertToBeans( $type, $rows );
- foreach ( $beans as $bean ) $bean->setMeta( 'sys.belongs-to', $links[$bean->id] );
-
- return $beans;
- }
-}
projects / yaffs-website / blobdiff