Added Connection::query wrapper

nkt · May 5, 2014 · f0b5559 · f0b5559
1 parent 1adac3f
commit f0b5559
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 1 deletion.
diff --git a/src/Connection.php b/src/Connection.php
@@ -85,9 +85,19 @@ public function prepare($sql, $driverOptions = [])
         return parent::prepare($sql, $driverOptions);
     }
 
+    /**
+     * @param string $sql
+     * @param array  $parameters
+     *
+     * @return Query
+     */
+    public function query($sql, array $parameters = [])
+    {
+        return $this->prepare($sql)->execute($parameters);
+    }
+
     /**
      * @return static
-     * @throws Exception
      */
     public function beginTransaction()
     {

diff --git a/tests/ConnectionTest.php b/tests/ConnectionTest.php
@@ -81,6 +81,19 @@ public function testParserSkipRepeatedTypes()
         $this->assertAttributeSame(['sex' => \PDO::PARAM_BOOL], 'types', $stmt);
     }
 
+    public function testQuery()
+    {
+        $stmt = $this->connection->query('SELECT * FROM users');
+
+        $this->assertInstanceOf('Flame\\Query', $stmt);
+        $this->assertSame(3, $stmt->columnCount());
+
+        $stmt = $this->connection->query('SELECT * FROM users WHERE id = i:id', ['id' => 1]);
+
+        $this->assertAttributeSame(['id'], 'placeholders', $stmt);
+        $this->assertAttributeSame(['id' => \PDO::PARAM_INT], 'types', $stmt);
+    }
+
     public function testSelect()
     {
         $select = $this->connection->select('id', 'name', 'count');