Merge pull request #17 from rwifeng/batch

add batch ops

Author: xushiwei

qiniu/rs.php

@@ -176,5 +176,47 @@ function Qiniu_RS_Copy($self, $bucketSrc, $keySrc, $bucketDest, $keyDest) // =>
 	return Qiniu_Client_CallNoRet($self, $QINIU_RS_HOST . $uri);
 }
 
+
 // ----------------------------------------------------------
+//batch
+
+function Qiniu_RS_Batch($self, $ops) // => ($data, $error)
+{
+	global $QINIU_RS_HOST;
+	$url = $QINIU_RS_HOST . '/batch';
+	$params = 'op=' . implode('&op=', $ops);
+	return Qiniu_Client_CallWithForm($self, $url, $params);
+}
+
+function Qiniu_RS_BatchStat($self, $entryPaths)
+{
+	foreach ($entryPaths as $entryPath) {
+		$params[] = Qiniu_RS_URIStat($entryPath->bucket, $entryPath->key);
+	}
+	return Qiniu_RS_Batch($self,$params);
+}
+
+function Qiniu_RS_BatchDelete($self, $entryPaths)
+{
+	foreach ($entryPaths as $entryPath) {
+		$params[] = Qiniu_RS_URIDelete($entryPath->bucket, $entryPath->key);
+	}
+	return Qiniu_RS_Batch($self, $params);
+}
+
+function Qiniu_RS_BatchMove($self, $entryPairs)
+{
+	foreach ($entryPairs as $entryPair) {
+		$params[] = Qiniu_RS_URIMove($entryPair->src->bucket, $entryPair->src->key, $entryPair->dest->bucket, $entryPair->dest->key);
+	}
+	return Qiniu_RS_Batch($self, $params);
+}
+
+function Qiniu_RS_BatchCopy($self, $entryPairs)
+{
+	foreach ($entryPairs as $entryPair) {
+		$params[] = Qiniu_RS_URICopy($entryPair->src->bucket, $entryPair->src->key, $entryPair->dest->bucket, $entryPair->dest->key);
+	}
+	return Qiniu_RS_Batch($self, $params);
+}
 

tests/RsTest.php

@@ -43,5 +43,45 @@ public function testDeleteMoveCopy()
 		$err = Qiniu_RS_Delete($this->client, $this->bucket, $key2);
 		$this->assertNotNull($err, "delete key2 false");
 	}
+
+	public function testBatchStat()
+	{
+		$key2 = 'testOp2' . getTid();
+		Qiniu_RS_Delete($this->client, $this->bucket, $key2);
+		$entries = array(new Qiniu_RS_EntryPath($this->bucket, $this->key), new Qiniu_RS_EntryPath($this->bucket, $key2));
+		list($ret, $err) = Qiniu_RS_BatchStat($this->client, $entries);
+		$this->assertNotNull($err);
+		$this->assertEquals($ret[0]['code'], 200);
+		$this->assertEquals($ret[1]['code'], 612);
+	}
+
+	public function testBatchDeleteMoveCopy()
+	{
+		$key2 = 'testOp2' . getTid();
+		$key3 = 'testOp3' . getTid();
+		$key4 = 'testOp4' . getTid();
+		$e1 = new Qiniu_RS_EntryPath($this->bucket, $this->key);
+		$e2 = new Qiniu_RS_EntryPath($this->bucket, $key2);
+		$e3 = new Qiniu_RS_EntryPath($this->bucket, $key3);
+		$e4 = new Qiniu_RS_EntryPath($this->bucket, $key4);
+		Qiniu_RS_BatchDelete($this->client, array($e2, $e3,$e4));
+
+		$entryPairs = array(new Qiniu_RS_EntryPathPair($e1, $e2), new Qiniu_RS_EntryPathPair($e1, $e3));
+		list($ret, $err) = Qiniu_RS_BatchCopy($this->client, $entryPairs);
+		$this->assertNull($err);
+		$this->assertEquals($ret[0]['code'], 200);
+		$this->assertEquals($ret[1]['code'], 200);
+
+		list($ret, $err) = Qiniu_RS_BatchMove($this->client, array(new Qiniu_RS_EntryPathPair($e2, $e4)));
+		$this->assertNull($err);
+		$this->assertEquals($ret[0]['code'], 200);
+
+		list($ret, $err) = Qiniu_RS_BatchDelete($this->client, array($e3, $e4));
+		$this->assertNull($err);
+		$this->assertEquals($ret[0]['code'], 200);
+		$this->assertEquals($ret[1]['code'], 200);
+
+		Qiniu_RS_BatchDelete($this->client, array($e2, $e3, $e4));
+	}
 }