Added MassInsert

Author: rkrx

composer.json

@@ -10,7 +10,8 @@
 		"php": ">= 5.4"
 	},
 	"require-dev": {
-		"phpunit/phpunit": "~4.0"
+		"phpunit/phpunit": "~4.0",
+		"phake/phake": "1.0.5"
 	},
 	"autoload": {
 		"psr-4": {

src/Builder/Insert.php

@@ -9,26 +9,26 @@ class Insert extends InsertUpdateStatement {
 	 * @var array
 	 */
 	private $fields = array();
-
 	/**
 	 * @var array
 	 */
 	private $update = array();
-
 	/**
 	 * @var string
 	 */
 	private $table = null;
-
 	/**
 	 * @var string
 	 */
 	private $keyField = null;
-
 	/**
 	 * @var bool
 	 */
 	private $ignore = false;
+	/**
+	 * @var Select
+	 */
+	private $from = null;
 
 	/**
 	 * @param string $table
@@ -172,6 +172,15 @@ public function addOrUpdateAll(array $data) {
 		return $this;
 	}
 
+	/**
+	 * @param Select $select
+	 * @return $this
+	 */
+	public function from(Select $select) {
+		$this->from = $select;
+		return $this;
+	}
+
 	/**
 	 * @throws Exception
 	 * @return string
@@ -181,16 +190,6 @@ public function __toString() {
 			throw new Exception('Specify a table-name');
 		}
 
-		$fields = $this->fields;
-		$tableFields = $this->db()->getTableFields($this->table);
-
-		$insertData = $this->buildFieldList($fields, $tableFields);
-		$updateData = $this->buildUpdate();
-
-		if (empty($insertData)) {
-			throw new Exception('No field-data found');
-		}
-
 		$tableName = (new AliasReplacer($this->db()->getAliasRegistry()))->replace($this->table);
 
 		$queryArr = array();
@@ -212,7 +211,6 @@ public function __toString() {
 			}
 
 			$queryArr[] = "SET\n{$insertData}\n";
-
 		}
 
 		$updateData = $this->buildUpdate();

src/Builder/Select.php

@@ -1,8 +1,6 @@
 <?php
 namespace Kir\MySQL\Builder;
 
-use Kir\MySQL\Tools\AliasReplacer;
-
 class Select extends Statement {
 	/**
 	 * @var string[]

tests/Builder/InsertTest.php

@@ -3,10 +3,20 @@
 
 use Kir\MySQL\Builder\InsertTest\TestInsert;
 use Kir\MySQL\Builder\SelectTest\TestSelect;
+use Kir\MySQL\Database;
+use Kir\MySQL\Tools\AliasRegistry;
+use Phake;
 
 class InsertTest extends \PHPUnit_Framework_TestCase {
-	public function testAlias() {
-		$query = TestInsert::create()
+	public function XtestAlias() {
+		$reg = new AliasRegistry();
+		$reg->add('travis', 'travis_test.');
+
+		$db = Phake::mock(Database::class);
+		Phake::when($db)->__call('getTableFields', ['travis_test.test1'])->thenReturn([]);
+		Phake::when($db)->__call('getAliasRegistry', [])->thenReturn($reg);
+
+		$query = (new TestInsert($db))
 		->into('travis#test1')
 		->addExpr('last_update=NOW()')
 		->asString();
@@ -17,16 +27,15 @@ public function testAlias() {
 	public function testMassInsert() {
 		$select = TestSelect::create()
 		->fields(['a' => 'b'])
-		->from('oi', 'orders#items')
+		->from('oi', 'travis#test1')
 		->where('1!=2');
 
 		$query = TestInsert::create()
-		->into('orders#items')
+		->into('travis#test2')
 		->from($select)
 		->updateExpr('a = VALUES(a)')
-		->debug()
 		->asString();
 
-		$this->assertEquals('', $query);
+		$this->assertEquals('INSERT INTO travis_test.test2 (a) SELECT b AS `a` FROM travis_test.test1 oi WHERE (1!=2) ON DUPLICATE KEY UPDATE a = VALUES(a) ;', $query);
 	}
 }