minsql concept

minsql.php

<?php
namespace noodlehaus\minsql;

# create pdo conn, or get last used, or null
function connect(...$args) {

  static $pdo = null;

  if (!count($args))
    return $pdo;

  $pdo = new PDO(...$args);

  if (PDO::ATTR_DRIVER_NAME !== 'mysql') {
    return trigger_error(
      "noodlehaus\minsql only works with MySQL.",
      E_USER_ERROR
    );
  }

  return $pdo;
}

# executes a query, and returns the statement
function query($sql_or_pdo, ...$args) {

  $sql = null;
  $pdo = null;

  if ($sql_or_pdo instanceof PDO) {
    $pdo = $sql_or_pdo;
    $sql = array_shift($args);
  } else {
    $pdo = connect();
    $sql = $sql_or_pdo;
  }

  $sql = $pdo->prepare($sql);
  $sql->execute($args);

  return $sql;
}

# returns all rows from the statement
function all(PDOStatement $sql) {
  $all = $sql->fetchAll(PDO::FETCH_ASSOC);
  $sql->closeCursor();
  return $all;
}

# returns next row from the statement
function row(PDOStatement $sql) {
  $row = $sql->fetch(PDO::FETCH_ASSOC);
  ($row === false) && $sql->closeCursor();
  return $row;
}