Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <?php
- // Uncomment line to check for debug, if issue with extention.
- // echo defined('PDO::ATTR_DRIVER_NAME') ? "PDO loaded" : "PDO unavailable";
- class Database{
- public $isConn;
- protected $datab;
- // connection to db
- public function __construct($username = "*****", $password = "*****", $host = "localhost", $dbname = "mukeshdak", $options = [])
- {
- // by default assume successful connection.
- $this->isConn = TRUE;
- try {
- $this->datab = new PDO("mysql:host={$host};dbname={$dbname};charset=utf8", $username, $password, $options);
- $this->datab->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
- $this->datab->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
- }
- catch (PDOException $e)
- {
- throw new Exception($e->getMessage());
- }
- }
- // disconnect from db
- public function Disconnect()
- {
- $this->datab = NULL;
- $this->isConn = FALSE;
- }
- // get row
- public function getRow($query, $params = [])
- {
- try {
- $stmt = $this->datab->prepare($query);
- $stmt->execute($params);
- return $stmt->fetch();
- } catch (PDOException $e) {
- throw new Exception($e->getMessage());
- }
- }
- // get rows
- public function getRows($query, $params = [])
- {
- try {
- $stmt = $this->datab->prepare($query);
- $stmt->execute($params);
- return $stmt->fetchAll();
- } catch (PDOException $e) {
- throw new Exception($e->getMessage());
- }
- }
- // insert row
- public function insertRow($query, $params = [])
- {
- try {
- $stmt = $this->datab->prepare($query);
- $stmt->execute($params);
- return TRUE;
- } catch (PDOException $e) {
- throw new Exception($e->getMessage());
- }
- }
- // update row
- public function updateRow($query, $params = [])
- {
- $this->insertRow($query, $params);
- }
- // delete row
- public function deleteRow($query, $params = [])
- {
- $this->insertRow($query, $params);
- }
- public function die_r($value)
- {
- echo "<pre>";
- print_r($value);
- echo "</pre>";
- die();
- }
- }
- $db = new Database;
- $row = $db->getrow("SELECT * from boiler WHERE id=?", ["4"]);
- $db->die_r($row);
- // other example uses.
- // $getRow = $db->getRow("SELECT * FROM users WHERE username = ?", ["admin"]);
- // $getRows = $db->getRows("SELECT * FROM users");
- // $insertRow = $db->insertRow("INSERT INTO users(username, password, email) VALUE(?, ?, ?)", ["Arthur", "102030", "arthur@localhost"]);
- // $updateRow = $db->updateRow("UPDATE users SET username = ?, password = ? WHERE id = ?", ["ArthurMann", "a123456", "7"]);
- // $deleteRow = $db->deleteRow("DELETE FROM users WHERE id = ?", [8]);
- // $db->Disconnect();
- ?>
Advertisement
Add Comment
Please, Sign In to add comment