updated query method

README.md

@@ -73,6 +73,7 @@ Select data
 
 ```php
 $db->query('SELECT * FROM songs')->all()
+$db->query('SELECT * FROM songs WHERE id = ?', [1])->one()
 ```
 
 
@@ -120,11 +121,18 @@ $db->query('SELECT * FROM songs')->all()
 ```php
  $db->query($sql, $params = [])
 ```
-#### Get total nunmber of rows
+#### Get total nunmber of affected rows
 
 ```php
- $db->getNumRows()
+ $db->getAffectedRows()
 ```
+
+#### Get last insert id
+
+```php
+ $db->lastInsertId()
+```
+
 #### Get single record as an array
 
 ```php

src/Db.php

@@ -139,7 +139,7 @@ private function initConnecton()
  * @param string $table
  * @param array $data
  * 
- * @return Db
+ * @return int|bool
  */
  public function insert($table, $data = [])
  {
@@ -152,7 +152,21 @@ public function insert($table, $data = [])
  $value_placeholder = rtrim($value_placeholder, ', ');
  $sql = "INSERT INTO $table ( `" . implode('`,`', $columns ) ."` ) VALUES( $value_placeholder )";
 
- return $this->query($sql, $values);
+ if( $this->_runQuery($sql, $values) ) {
+ return $this->lastInsertId();
+ }
+
+ return false;
+ }
+
+ /**
+ * Get last insert id
+ * 
+ * @return int
+ */
+ public function lastInsertId()
+ {
+ return $this->stmt->insert_id;
  }
 
  /**
@@ -162,7 +176,7 @@ public function insert($table, $data = [])
  * @param array $data
  * @param array $conditions
  * 
- * @return Db
+ * @return int|bool
  */
  public function update($table, $data = [], $conditions = [], $glue = 'AND')
  {
@@ -179,15 +193,19 @@ public function update($table, $data = [], $conditions = [], $glue = 'AND')
  foreach($conditions as $key => $value) {
  $where_clause .= '`' . $key . '`' . ' = ' . '? ' . $glue;
  }
-
  $where_clause = rtrim($where_clause, " $glue");
  } else {
  $where_clause = 1;
  }
 
  $sql = "UPDATE $table SET $update_columns WHERE $where_clause";
+ $final_params = array_merge( array_values($data), array_values($conditions));
 
- return $this->query($sql, array_merge( array_values($data), array_values($conditions)));
+ if( $this->_runQuery($sql, $final_params) ) {
+ return $this->getAffectedRows();
+ }
+
+ return false;
  }
 
  /**
@@ -196,7 +214,7 @@ public function update($table, $data = [], $conditions = [], $glue = 'AND')
  * @param string $table
  * @param array $conditions
  * 
- * @return Db
+ * @return int|bool
  */
  public function delete($table, $conditions=[], $glue = 'AND')
  {
@@ -213,7 +231,11 @@ public function delete($table, $conditions=[], $glue = 'AND')
 
  $sql = "DELETE FROM $table WHERE $where_clause";
 
- return $this->query($sql, array_values($conditions));
+ if( $this->_runQuery($sql, array_values($conditions)) ) {
+ return $this->getAffectedRows();
+ }
+
+ return false;
  }
 
  /**
@@ -251,8 +273,26 @@ public function deleteUsingOr($table, $conditions=[])
  public function query($sql, $params = [])
  {
  $this->sql = $sql;
+ if($this->_runQuery($this->sql, $params)) {
+ return $this;
+ } else {
+ throw new DbErrorException("DB error :: " . $this->stmt->error);
+ }
+ }
+
+ /**
+ * Run the actual query
+ * 
+ * @param string $sql
+ * @param array $params
+ * 
+ * @return bool
+ * @throws DbErrorException
+ */
+ private function _runQuery($sql, $params)
+ {
  try {
- $this->stmt = $this->con->prepare($this->sql);
+ $this->stmt = $this->con->prepare($sql);
  if($this->stmt === false) {
  throw new DbErrorException('DB error :: ' . $this->con->error );
  }
@@ -279,18 +319,18 @@ public function query($sql, $params = [])
 
  if($this->stmt->execute()) {
  $this->query_result = $this->stmt->get_result();
- return $this;
+ return true;
  } else {
  throw new DbErrorException("DB error :: " . $this->stmt->error);
  }
  }
 
  /**
- * Get total nunmber of rows
+ * Get total nunmber of rows affected rows
  * 
  * @return int
  */
- public function getNumRows() 
+ public function getAffectedRows() 
  {
  if( $this->stmt == null ) {
  return 0;