<?php

namespace RedUNIT\Base;

use RedUNIT\Base as Base;
use RedBeanPHP\Facade as R;

/**
 * Writecache
 *
 * The Query Writer Cache tries to avoid unnecessary queries
 * by using cache markers. This means repeatingly fetching the
 * same parent bean for instance (in loop) won't hurt performance.
 * The Query Writer Cache gets emptied if the chain of markers
 * gets broken. All 'non destructive' queries are marked, as long
 * as no other queries have been executed we can safely assume
 * nothing in the database has changed for the current request.
 * You might want to turn this form of caching off in long running
 * PHP processes.
 *
 * @file    RedUNIT/Base/Writecache.php
 * @desc    Tests the Query Writer cache implemented in the
 * @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 Writecache extends Base
{

	/**
	 * What drivers should be loaded for this test pack?
	 */
	public function getTargetDrivers()
	{
		return array( 'mysql', 'pgsql', 'sqlite', 'CUBRID' );
	}

	/**
	 * Test whether cache size remains constant (per type).
	 * Avoiding potential memory leaks. (Issue #424).
	 *
	 * @return void
	 */
	public function testCacheSize()
	{
		R::nuke();
		R::useWriterCache( TRUE );
		$writer = R::getWriter();
		$bean = R::dispense( 'bean' );
		$bean->prop = 1;
		R::store( $bean );
		$writer->flushCache( 20 );
		$count = $writer->flushCache();
		asrt( $count, 0 );
		R::find( 'bean', ' prop < ? ', array( 1 ) );
		$count = $writer->flushCache();
		asrt( $count, 2 );
		R::find( 'bean', ' prop < ? ', array( 2 ) );
		$count = $writer->flushCache();
		asrt( $count, 5 );
		R::find( 'bean', ' prop < ? ', array( 2 ) );
		$count = $writer->flushCache();
		asrt( $count, 5 );
		for( $i = 0; $i < 40; $i ++ ) {
			R::find( 'bean', ' prop < ? ', array( $i ) );
		}
		$count = $writer->flushCache();
		asrt( $count, 85 );
		for( $i = 0; $i < 120; $i ++ ) {
			R::find( 'bean', ' prop < ? ', array( $i ) );
		}
		$count = $writer->flushCache( 1 );
		asrt( $count, 85 );
		for( $i = 0; $i < 20; $i ++ ) {
			R::find( 'bean', ' prop < ? ', array( $i ) );
		}
		$count = $writer->flushCache( 20 );
		asrt( $count, 9 );
	}

	/**
	 * When using fetchAs(), Query Cache does not recognize objects
	 * that have been previously fetched, see issue #400.
	 */
	public function testCachingAndFetchAs()
	{
		testpack( 'Testing whether you can cache multiple records of the same type' );
		R::debug( true, 1 );
		$logger = R::getDatabaseAdapter()->getDatabase()->getLogger();
		R::nuke();
		$coauthor1 = R::dispense( 'author' );
		$coauthor1->name = 'John';
		$book = R::dispense( 'book' );
		$book->title = 'a Funny Tale';
		$book->coauthor = $coauthor1;
		$id = R::store( $book );
		$coauthor = R::dispense( 'author' );
		$coauthor->name = 'Pete';
		$book = R::dispense( 'book' );
		$book->title = 'a Funny Tale 2';
		$book->coauthor = $coauthor;
		$id = R::store( $book );
		$book = R::dispense( 'book' );
		$book->title = 'a Funny Tale 3';
		$book->coauthor = $coauthor1;
		$id = R::store( $book );
		$books = R::find( 'book' );
		$logger->clear();
		$authors = array();
		$authorsByName = array();
		foreach($books as $book) {
			$coAuthor = $book->with( ' ORDER BY title ASC ' )
				->fetchAs( 'author' )->coauthor;
			$authors[] = $coAuthor->name;
			$authorsByName[ $coAuthor->name ] = $coAuthor;
		}
		asrt( count( $logger->grep( 'SELECT' ) ), 2 ); //must be 2! 3 if cache does not work!
		asrt( count( $authors ), 3 );
		asrt( isset( $authorsByName[ 'John' ] ), TRUE );
		asrt( isset( $authorsByName[ 'Pete' ] ), TRUE );
		$logger->clear();
		$authors = array();
		$authorsByName = array();
		foreach($books as $book) {
			$coAuthor = $book->with( ' ORDER BY title DESC ' )
				->fetchAs( 'author' )->coauthor;
			$authors[] = $coAuthor->name;
			$authorsByName[ $coAuthor->name ] = $coAuthor;
		}
		asrt( count( $logger->grep( 'SELECT' ) ), 0 ); //must be 0!
		asrt( count( $authors ), 3 );
		asrt( isset( $authorsByName[ 'John' ] ), TRUE );
		asrt( isset( $authorsByName[ 'Pete' ] ), TRUE );
	}

	/**
	 * Test effects of cache.
	 *
	 * @return void
	 */
	public function testCachingEffects()
	{
		testpack( 'Testing WriteCache Query Writer Cache' );
		R::setNarrowFieldMode( FALSE );
		R::useWriterCache( FALSE );
		R::debug( TRUE, 1 );
		$logger = R::getDatabaseAdapter()->getDatabase()->getLogger();
		$book = R::dispense( 'book' )->setAttr( 'title', 'ABC' );
		$book->ownPage[] = R::dispense( 'page' );
		$id = R::store( $book );
		// Test load cache -- without
		$logger->clear();
		$book = R::load( 'book', $id );
		$book = R::load( 'book', $id );
		asrt( count( $logger->grep( 'SELECT' ) ), 2 );
		// With cache
		R::useWriterCache( TRUE );
		$logger->clear();
		$book = R::load( 'book', $id );
		$book = R::load( 'book', $id );
		asrt( count( $logger->grep( 'SELECT' ) ), 1 );
		R::useWriterCache( FALSE );
		// Test find cache
		$logger->clear();
		$book = R::find( 'book' );
		$book = R::find( 'book' );
		asrt( count( $logger->grep( 'SELECT' ) ), 2 );
		// With cache
		R::getWriter()->setUseCache( TRUE );
		$logger->clear();
		$book = R::find( 'book' );
		$book = R::find( 'book' );
		asrt( count( $logger->grep( 'SELECT' ) ), 1 );
		R::getWriter()->setUseCache( FALSE );
		// Test combinations
		$logger->clear();
		$book = R::findOne( 'book', ' id = ? ', array( $id ) );
		$book->ownPage;
		R::batch( 'book', array( $id ) );
		$book = R::findOne( 'book', ' id = ? ', array( $id ) );
		$book->ownPage;
		R::batch( 'book', array( $id ) );
		asrt( count( $logger->grep( 'SELECT' ) ), 6 );
		// With cache
		R::getWriter()->setUseCache( TRUE );
		$logger->clear();
		R::batch( 'book', array( $id ) );
		$book = R::findOne( 'book', ' id = ? ', array( $id ) );
		$book->ownPage;
		$book = R::findOne( 'book', ' id = ? ', array( $id ) );
		$book->ownPage;
		asrt( count( $logger->grep( 'SELECT' ) ), 3 );
		R::getWriter()->setUseCache( FALSE );
		// Test auto flush
		$logger->clear();
		$book = R::findOne( 'book' );
		$book->name = 'X';
		R::store( $book );
		$book = R::findOne( 'book' );
		asrt( count( $logger->grep( 'SELECT *' ) ), 2 );
		// With cache
		R::getWriter()->setUseCache( TRUE );
		$logger->clear();
		$book = R::findOne( 'book' );
		$book->name = 'Y';
		// Will flush
		R::store( $book );
		$book = R::findOne( 'book' );
		// Now the same, auto flushed
		asrt( count( $logger->grep( 'SELECT *' ) ), 2 );
		R::getWriter()->setUseCache( FALSE );
		// Test whether delete flushes as well (because uses selectRecord - might be a gotcha!)
		R::store( R::dispense( 'garbage' ) );
		$garbage = R::findOne( 'garbage' );
		$logger->clear();
		$book = R::findOne( 'book' );
		R::trash( $garbage );
		$book = R::findOne( 'book' );
		asrt( count( $logger->grep( 'SELECT *' ) ), 2 );
		R::store( R::dispense( 'garbage' ) );
		$garbage = R::findOne( 'garbage' );
		// With cache
		R::getWriter()->setUseCache( TRUE );
		$logger->clear();
		$book = R::findOne( 'book' );
		R::trash( $garbage );
		$book = R::findOne( 'book' );
		// Now the same, auto flushed
		asrt( count( $logger->grep( 'SELECT *' ) ), 2 );
		R::getWriter()->setUseCache( FALSE );
		R::store( R::dispense( 'garbage' ) );
		$garbage = R::findOne( 'garbage' );
		// With cache
		R::getWriter()->setUseCache( TRUE );
		$logger->clear();
		$book = R::findOne( 'book' );
		R::getWriter()->queryRecord( 'garbage', array( 'id' => array( $garbage->id ) ) );
		$book = R::findOne( 'book' );
		// Now the same, auto flushed
		asrt( count( $logger->grep( 'SELECT *' ) ), 2 );
		$page = R::dispense('page');
		$book->sharedPage[] = $page;
		R::store( $book );
		$logger->clear();
		$link = R::getWriter()->queryRecordLink( 'book', 'page', $book->id, $page->id );
		asrt( count( $logger->grep( 'SELECT' ) ), 1 );
		$link = R::getWriter()->queryRecordLink( 'book', 'page', $book->id, $page->id );
		asrt( count( $logger->grep( 'SELECT' ) ), 1 );
		R::getWriter()->setUseCache( FALSE );
		$link = R::getWriter()->queryRecordLink( 'book', 'page', $book->id, $page->id );
		asrt( count( $logger->grep( 'SELECT' ) ), 2 );
		R::getWriter()->setUseCache( TRUE );
		R::setNarrowFieldMode( TRUE );
	}

	/**
	 * Try to fool the cache :)
	 *
	 * @return void
	 */
	public function testRegressions()
	{
		testpack( 'Testing possible regressions: Try to fool the cache' );
		$str = 'SELECT * FROM ' . R::getWriter()->esc( 'bean', TRUE ) . ' WHERE ( ' . R::getWriter()->esc( 'id', TRUE ) . '  IN ( 1)  ) ';
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id = R::store( $bean );
		$bean = R::load( 'bean', $id );
		$bean->title = 'xxx';
		R::store( $bean );
		// Fire exact same query so cache may think no other query has been fired
		R::exec( $str );
		$bean = R::load( 'bean', $id );
		asrt( $bean->title, 'xxx' );
	}

	/**
	 * Test keep-cache comment.
	 *
	 * @return void
	 */
	public function testKeepCacheCommentInSQL()
	{
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id = R::store( $bean );
		$bean = R::load( 'bean', $id );
		$bean->title = 'xxx';
		R::store( $bean );
		// Causes flush even though it contains -- keep-cache (not at the end, not intended)
		R::findOne( 'bean', ' title = ? ', array( '-- keep-cache' ) );
		$bean = R::load( 'bean', $id );
		asrt( $bean->title, 'xxx' );
	}

	/**
	 *
	 * Same as above.. test keep cache.
	 *
	 * @return void
	 */
	public function testInstructNoDrop()
	{
		$str = 'SELECT * FROM ' . R::getWriter()->esc( 'bean', TRUE ) . ' -- keep-cache';
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id = R::store( $bean );
		$bean = R::load( 'bean', $id );
		$bean->title = 'xxx';
		R::store( $bean );
		R::exec( $str );
		$bean = R::load( 'bean', $id );
		asrt( $bean->title, 'abc' );
		R::nuke();
		// Now INSTRUCT the cache to not drop the cache CASE 2
		$str = 'SELECT * FROM ' . R::getWriter()->esc( 'bean', TRUE ) . ' -- keep-cache';
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id = R::store( $bean );
		$bean = R::load( 'bean', $id );
		$bean->title = 'xxx';
		R::store( $bean );
		R::findOne( 'bean', ' title = ? ', array( 'cache' ) );
		$bean = R::load( 'bean', $id );
		asrt( $bean->title, 'xxx' );
	}

	/**
	 * Can we confuse the cache?
	 *
	 * @return void
	 */
	public function testConfusionRegression()
	{
		testpack( 'Testing possible confusion regression' );
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id1 = R::store( $bean );
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc2';
		$id2 = R::store( $bean );
		$bean = R::load( 'bean', $id1 );
		asrt( $bean->title, 'abc' );
		$bean = R::load( 'bean', $id2 );
		asrt( $bean->title, 'abc2' );
	}

	/**
	 * Test Ghost beans....
	 *
	 * @return void
	 */
	public function testGhostBeans()
	{
		testpack( 'Testing ghost beans' );
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id1 = R::store( $bean );
		R::trash( $bean );
		$bean = R::load( 'bean', $id1 );
		asrt( (int) $bean->id, 0 );
	}

	/**
	 * Test explicit flush.
	 *
	 * @return void
	 */
	public function testExplicitCacheFlush()
	{
		testpack( 'Test cache flush (explicit)' );
		R::setNarrowFieldMode( FALSE );
		R::debug( true, 1 );
		$logger = R::getDatabaseAdapter()->getDatabase()->getLogger();
		$bean = R::dispense( 'bean' );
		$bean->title = 'abc';
		$id1 = R::store( $bean );
		$logger->clear();
		$bean = R::load( 'bean', $id1 );
		asrt( $bean->title, 'abc' );
		asrt( count( $logger->grep( 'SELECT *' ) ), 1 );
		$bean = R::load( 'bean', $id1 );
		asrt( count( $logger->grep( 'SELECT *' ) ), 1 );
		R::getWriter()->flushCache();
		$bean = R::load( 'bean', $id1 );
		asrt( count( $logger->grep( 'SELECT *' ) ), 2 );
		R::getWriter()->flushCache();
		R::getWriter()->setUseCache( FALSE );
		R::setNarrowFieldMode( TRUE );
	}
}