Merge pull request #85 from pfwd/83-query-builder-find-all-by

Adding where clause

Author: pfwd

src/DB/QueryBuilder.php

@@ -86,4 +86,37 @@ public static function findAll(string $table)
  {
  return "SELECT * FROM `".$table."`";
  }
+
+ /**
+ * @param array $conditions
+ * @return string
+ */
+ public static function where(array $conditions = []) {
+ $sql ='';
+
+ $total = count($conditions);
+ $num = 0;
+ foreach($conditions as $field => $value) {
+ $num ++;
+ $sql.='`'.$field.'` =:'.$value;
+ if($num < $total) {
+ $sql.=' AND ';
+ }
+
+ }
+
+ return $sql;
+ }
+
+ /**
+ * @param string $table
+ * @param array $where
+ * @return string
+ */
+ public static function findAllBy(string $table, array $where = [])
+ {
+ $sql = "SELECT * FROM `".$table."` WHERE " .self::where($where);
+
+ return $sql;
+ }
 }

src/Repository/Type/InvoiceItemRepository.php

@@ -69,15 +69,21 @@ public function findAll(): array
 
  }
 
+ /**
+ * @param int $id
+ * @return array
+ */
  public function findAllByInvoiceID(int $id):array
  {
  $results = [];
- $sql = QueryBuilder::findAllBy('invoice_item');
+ $sql = QueryBuilder::findAllBy('invoice_item', [
+ 'invoice_id' => 'id'
+ ]);
 
  $dbCon = $this->connection->open();
  $statement = $dbCon->prepare($sql);
  $statement->execute([
- 'invoice_id' => $id
+ 'id' => $id
  ]);
  $statement->execute();
  $rows = $statement->fetchAll();
@@ -87,7 +93,7 @@ public function findAllByInvoiceID(int $id):array
  $results[] = InvoiceItemHydrator::hydrate($row);
  }
  }
-
+ return $results;
  }
 
  /**

tests/unit/DB/QueryBuilderTest.php

@@ -192,6 +192,22 @@ public function testFindAll()
  $this->assertSame($expected, $sql);
  }
 
+ /**
+ * @group entity
+ * @group db
+ * @group db-query-builder
+ * @group db-query-builder-find-all-by
+ */
+ public function testFindAllBy()
+ {
+ $sql = QueryBuilder::findAllBy('status', [
+ 'name' => 'name',
+ 'internal_name' => 'internal_name'
+ ]);
+ $expected = "SELECT * FROM `status` WHERE `name` =:name AND `internal_name` =:internal_name";
+ $this->assertSame($expected, $sql);
+ }
+
  protected function _before()
  {
  }