|  |  |  | <?php
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | namespace yiiunit\extensions\redis;
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | use yii\redis\ActiveQuery;
 | 
					
						
							|  |  |  | use yiiunit\data\ar\redis\ActiveRecord;
 | 
					
						
							|  |  |  | use yiiunit\data\ar\redis\Customer;
 | 
					
						
							|  |  |  | use yiiunit\data\ar\redis\OrderItem;
 | 
					
						
							|  |  |  | use yiiunit\data\ar\redis\Order;
 | 
					
						
							|  |  |  | use yiiunit\data\ar\redis\Item;
 | 
					
						
							|  |  |  | use yiiunit\framework\ar\ActiveRecordTestTrait;
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | /**
 | 
					
						
							|  |  |  |  * @group redis
 | 
					
						
							|  |  |  |  */
 | 
					
						
							|  |  |  | class ActiveRecordTest extends RedisTestCase
 | 
					
						
							|  |  |  | {
 | 
					
						
							|  |  |  | 	use ActiveRecordTestTrait;
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function callCustomerFind($q = null)	 { return Customer::find($q); }
 | 
					
						
							|  |  |  | 	public function callOrderFind($q = null)     { return Order::find($q); }
 | 
					
						
							|  |  |  | 	public function callOrderItemFind($q = null) { return OrderItem::find($q); }
 | 
					
						
							|  |  |  | 	public function callItemFind($q = null)      { return Item::find($q); }
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function getCustomerClass() { return Customer::className(); }
 | 
					
						
							|  |  |  | 	public function getItemClass() { return Item::className(); }
 | 
					
						
							|  |  |  | 	public function getOrderClass() { return Order::className(); }
 | 
					
						
							|  |  |  | 	public function getOrderItemClass() { return OrderItem::className(); }
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function setUp()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		parent::setUp();
 | 
					
						
							|  |  |  | 		ActiveRecord::$db = $this->getConnection();
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customer = new Customer();
 | 
					
						
							|  |  |  | 		$customer->setAttributes(['email' => 'user1@example.com', 'name' => 'user1', 'address' => 'address1', 'status' => 1], false);
 | 
					
						
							|  |  |  | 		$customer->save(false);
 | 
					
						
							|  |  |  | 		$customer = new Customer();
 | 
					
						
							|  |  |  | 		$customer->setAttributes(['email' => 'user2@example.com', 'name' => 'user2', 'address' => 'address2', 'status' => 1], false);
 | 
					
						
							|  |  |  | 		$customer->save(false);
 | 
					
						
							|  |  |  | 		$customer = new Customer();
 | 
					
						
							|  |  |  | 		$customer->setAttributes(['email' => 'user3@example.com', 'name' => 'user3', 'address' => 'address3', 'status' => 2], false);
 | 
					
						
							|  |  |  | 		$customer->save(false);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | //		INSERT INTO tbl_category (name) VALUES ('Books');
 | 
					
						
							|  |  |  | //		INSERT INTO tbl_category (name) VALUES ('Movies');
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$item = new Item();
 | 
					
						
							|  |  |  | 		$item->setAttributes(['name' => 'Agile Web Application Development with Yii1.1 and PHP5', 'category_id' => 1], false);
 | 
					
						
							|  |  |  | 		$item->save(false);
 | 
					
						
							|  |  |  | 		$item = new Item();
 | 
					
						
							|  |  |  | 		$item->setAttributes(['name' => 'Yii 1.1 Application Development Cookbook', 'category_id' => 1], false);
 | 
					
						
							|  |  |  | 		$item->save(false);
 | 
					
						
							|  |  |  | 		$item = new Item();
 | 
					
						
							|  |  |  | 		$item->setAttributes(['name' => 'Ice Age', 'category_id' => 2], false);
 | 
					
						
							|  |  |  | 		$item->save(false);
 | 
					
						
							|  |  |  | 		$item = new Item();
 | 
					
						
							|  |  |  | 		$item->setAttributes(['name' => 'Toy Story', 'category_id' => 2], false);
 | 
					
						
							|  |  |  | 		$item->save(false);
 | 
					
						
							|  |  |  | 		$item = new Item();
 | 
					
						
							|  |  |  | 		$item->setAttributes(['name' => 'Cars', 'category_id' => 2], false);
 | 
					
						
							|  |  |  | 		$item->save(false);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$order = new Order();
 | 
					
						
							|  |  |  | 		$order->setAttributes(['customer_id' => 1, 'create_time' => 1325282384, 'total' => 110.0], false);
 | 
					
						
							|  |  |  | 		$order->save(false);
 | 
					
						
							|  |  |  | 		$order = new Order();
 | 
					
						
							|  |  |  | 		$order->setAttributes(['customer_id' => 2, 'create_time' => 1325334482, 'total' => 33.0], false);
 | 
					
						
							|  |  |  | 		$order->save(false);
 | 
					
						
							|  |  |  | 		$order = new Order();
 | 
					
						
							|  |  |  | 		$order->setAttributes(['customer_id' => 2, 'create_time' => 1325502201, 'total' => 40.0], false);
 | 
					
						
							|  |  |  | 		$order->save(false);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$orderItem = new OrderItem();
 | 
					
						
							|  |  |  | 		$orderItem->setAttributes(['order_id' => 1, 'item_id' => 1, 'quantity' => 1, 'subtotal' => 30.0], false);
 | 
					
						
							|  |  |  | 		$orderItem->save(false);
 | 
					
						
							|  |  |  | 		$orderItem = new OrderItem();
 | 
					
						
							|  |  |  | 		$orderItem->setAttributes(['order_id' => 1, 'item_id' => 2, 'quantity' => 2, 'subtotal' => 40.0], false);
 | 
					
						
							|  |  |  | 		$orderItem->save(false);
 | 
					
						
							|  |  |  | 		$orderItem = new OrderItem();
 | 
					
						
							|  |  |  | 		$orderItem->setAttributes(['order_id' => 2, 'item_id' => 4, 'quantity' => 1, 'subtotal' => 10.0], false);
 | 
					
						
							|  |  |  | 		$orderItem->save(false);
 | 
					
						
							|  |  |  | 		$orderItem = new OrderItem();
 | 
					
						
							|  |  |  | 		$orderItem->setAttributes(['order_id' => 2, 'item_id' => 5, 'quantity' => 1, 'subtotal' => 15.0], false);
 | 
					
						
							|  |  |  | 		$orderItem->save(false);
 | 
					
						
							|  |  |  | 		$orderItem = new OrderItem();
 | 
					
						
							|  |  |  | 		$orderItem->setAttributes(['order_id' => 2, 'item_id' => 3, 'quantity' => 1, 'subtotal' => 8.0], false);
 | 
					
						
							|  |  |  | 		$orderItem->save(false);
 | 
					
						
							|  |  |  | 		$orderItem = new OrderItem();
 | 
					
						
							|  |  |  | 		$orderItem->setAttributes(['order_id' => 3, 'item_id' => 2, 'quantity' => 1, 'subtotal' => 40.0], false);
 | 
					
						
							|  |  |  | 		$orderItem->save(false);
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindNullValues()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		// https://github.com/yiisoft/yii2/issues/1311
 | 
					
						
							|  |  |  | 		$this->markTestSkipped('Redis does not store/find null values correctly.');
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testBooleanAttribute()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		// https://github.com/yiisoft/yii2/issues/1311
 | 
					
						
							|  |  |  | 		$this->markTestSkipped('Redis does not store/find boolean values correctly.');
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindEagerViaRelationPreserveOrder()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		$this->markTestSkipped('Redis does not support orderBy.');
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindEagerViaRelationPreserveOrderB()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		$this->markTestSkipped('Redis does not support orderBy.');
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testSatisticalFind()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		// find count, sum, average, min, max, scalar
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, Customer::find()->count());
 | 
					
						
							|  |  |  | 		$this->assertEquals(6, Customer::find()->sum('id'));
 | 
					
						
							|  |  |  | 		$this->assertEquals(2, Customer::find()->average('id'));
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, Customer::find()->min('id'));
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, Customer::find()->max('id'));
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$this->assertEquals(6, OrderItem::find()->count());
 | 
					
						
							|  |  |  | 		$this->assertEquals(7, OrderItem::find()->sum('quantity'));
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testfindIndexBy()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		$customerClass = $this->getCustomerClass();
 | 
					
						
							|  |  |  | 		/** @var TestCase|ActiveRecordTestTrait $this */
 | 
					
						
							|  |  |  | 		// indexBy
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()->indexBy('name')/*->orderBy('id')*/->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, count($customers));
 | 
					
						
							|  |  |  | 		$this->assertTrue($customers['user1'] instanceof $customerClass);
 | 
					
						
							|  |  |  | 		$this->assertTrue($customers['user2'] instanceof $customerClass);
 | 
					
						
							|  |  |  | 		$this->assertTrue($customers['user3'] instanceof $customerClass);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		// indexBy callable
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()->indexBy(function ($customer) {
 | 
					
						
							|  |  |  | 			return $customer->id . '-' . $customer->name;
 | 
					
						
							|  |  |  | 		})/*->orderBy('id')*/->all(); // TODO this test is duplicated because of missing orderBy support in redis
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, count($customers));
 | 
					
						
							|  |  |  | 		$this->assertTrue($customers['1-user1'] instanceof $customerClass);
 | 
					
						
							|  |  |  | 		$this->assertTrue($customers['2-user2'] instanceof $customerClass);
 | 
					
						
							|  |  |  | 		$this->assertTrue($customers['3-user3'] instanceof $customerClass);
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindLimit()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		// TODO this test is duplicated because of missing orderBy support in redis
 | 
					
						
							|  |  |  | 		/** @var TestCase|ActiveRecordTestTrait $this */
 | 
					
						
							|  |  |  | 		// all()
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, count($customers));
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()/*->orderBy('id')*/->limit(1)->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, count($customers));
 | 
					
						
							|  |  |  | 		$this->assertEquals('user1', $customers[0]->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()/*->orderBy('id')*/->limit(1)->offset(1)->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, count($customers));
 | 
					
						
							|  |  |  | 		$this->assertEquals('user2', $customers[0]->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()/*->orderBy('id')*/->limit(1)->offset(2)->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, count($customers));
 | 
					
						
							|  |  |  | 		$this->assertEquals('user3', $customers[0]->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()/*->orderBy('id')*/->limit(2)->offset(1)->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(2, count($customers));
 | 
					
						
							|  |  |  | 		$this->assertEquals('user2', $customers[0]->name);
 | 
					
						
							|  |  |  | 		$this->assertEquals('user3', $customers[1]->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customers = $this->callCustomerFind()->limit(2)->offset(3)->all();
 | 
					
						
							|  |  |  | 		$this->assertEquals(0, count($customers));
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		// one()
 | 
					
						
							|  |  |  | 		$customer = $this->callCustomerFind()/*->orderBy('id')*/->one();
 | 
					
						
							|  |  |  | 		$this->assertEquals('user1', $customer->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customer = $this->callCustomerFind()/*->orderBy('id')*/->offset(0)->one();
 | 
					
						
							|  |  |  | 		$this->assertEquals('user1', $customer->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customer = $this->callCustomerFind()/*->orderBy('id')*/->offset(1)->one();
 | 
					
						
							|  |  |  | 		$this->assertEquals('user2', $customer->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customer = $this->callCustomerFind()/*->orderBy('id')*/->offset(2)->one();
 | 
					
						
							|  |  |  | 		$this->assertEquals('user3', $customer->name);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$customer = $this->callCustomerFind()->offset(3)->one();
 | 
					
						
							|  |  |  | 		$this->assertNull($customer);
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindEagerViaRelation()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		/** @var TestCase|ActiveRecordTestTrait $this */
 | 
					
						
							|  |  |  | 		$orders = $this->callOrderFind()->with('items')/*->orderBy('id')*/->all(); // TODO this test is duplicated because of missing orderBy support in redis
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, count($orders));
 | 
					
						
							|  |  |  | 		$order = $orders[0];
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, $order->id);
 | 
					
						
							|  |  |  | 		$this->assertEquals(2, count($order->items));
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, $order->items[0]->id);
 | 
					
						
							|  |  |  | 		$this->assertEquals(2, $order->items[1]->id);
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindCount()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		$this->assertEquals(3, Customer::find()->count());
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, Customer::find()->limit(1)->count());
 | 
					
						
							|  |  |  | 		$this->assertEquals(2, Customer::find()->limit(2)->count());
 | 
					
						
							|  |  |  | 		$this->assertEquals(1, Customer::find()->offset(2)->limit(2)->count());
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testFindColumn()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		$this->assertEquals(['user1', 'user2', 'user3'], Customer::find()->column('name'));
 | 
					
						
							|  |  |  | //		TODO $this->assertEquals(['user3', 'user2', 'user1'], Customer::find()->orderBy(['name' => SORT_DESC])->column('name'));
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	// TODO test serial column incr
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	public function testUpdatePk()
 | 
					
						
							|  |  |  | 	{
 | 
					
						
							|  |  |  | 		// updateCounters
 | 
					
						
							|  |  |  | 		$pk = ['order_id' => 2, 'item_id' => 4];
 | 
					
						
							|  |  |  | 		$orderItem = OrderItem::find($pk);
 | 
					
						
							|  |  |  | 		$this->assertEquals(2, $orderItem->order_id);
 | 
					
						
							|  |  |  | 		$this->assertEquals(4, $orderItem->item_id);
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$orderItem->order_id = 2;
 | 
					
						
							|  |  |  | 		$orderItem->item_id = 10;
 | 
					
						
							|  |  |  | 		$orderItem->save();
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		$this->assertNull(OrderItem::find($pk));
 | 
					
						
							|  |  |  | 		$this->assertNotNull(OrderItem::find(['order_id' => 2, 'item_id' => 10]));
 | 
					
						
							|  |  |  | 	}
 | 
					
						
							|  |  |  | }
 |