prepare($sql); if ($stmt->execute()) { return $stmt->fetchAll(PDO::FETCH_ASSOC); } return false; } /** * Return selected row from posts table * * @param int $id * @return array */ function post_find($id) { $db = option('db_conn'); $sql = <<prepare($sql); $stmt->bindValue(':id', $id, PDO::PARAM_INT); if ($stmt->execute() && $row = $stmt->fetch(PDO::FETCH_ASSOC)) { return $row; } return null; } /** * Insert a new row in posts table * Return row's id * * @param array $data * @return int or false */ function post_create($data) { $db = option('db_conn'); $sql = <<prepare($sql); $stmt->bindValue(':title', $data['title'], PDO::PARAM_STR); $stmt->bindValue(':body', $data['body'], PDO::PARAM_STR); if ($stmt->execute()) { return $db->lastInsertId(); } return false; } /** * Update a row in posts table * * @param int $post_id * @param array $data * @return true or false */ function post_update($post_id, $data) { $db = option('db_conn'); $sql = <<prepare($sql); $stmt->bindValue(':id', $post_id, PDO::PARAM_INT); $stmt->bindValue(':title', $data['title'], PDO::PARAM_STR); $stmt->bindValue(':body', $data['body'], PDO::PARAM_STR); return $stmt->execute(); } /** * Delete a row in posts table * * @param int $post_id * @return true or false */ function post_destroy($post_id) { $db = option('db_conn'); $sql = <<prepare($sql); $stmt->bindValue(':id', $post_id, PDO::PARAM_INT); return $stmt->execute(); } ?>