UserRepo.php

<?php
class UserRepo {
    /**
    * CuUser Repository
    */

    const TABLE_NAME = '%suser';
    private $dbh;
    private $creditUnion;
    private $logger;

    /**
     * @param resource  $dbh            Database handle
     * @param object    $logger         Logger to log
     * @param String    $creditUnion
     */
    public function __construct($dbh, $logger, String $creditUnion) {
        $this->dbh = $dbh;
        $this->logger = $logger;
        $this->creditUnion = $creditUnion;
    }

    protected function TableName($creditUnion) {
        return sprintf(static::TABLE_NAME, $creditUnion);
    }

    /**
     * Return user.
     *
     * @param   string   $username    User to retrieve
     * @return  array|bool
     */
    public function Read($username) {
      $sql = "SELECT  user_id,
                  TRIM(user_name) AS user_name,
                  TRIM(passwd) AS passwd,
                  forcechange AS fchange,
                  COALESCE(forceremain, 0) AS fremain,
                  failedremain,
                  pwchange AS pchange,
                  LOWER(TRIM(email)) AS email,
                  TRIM(confidence) As confidence,
                  group_id AS cuuser_group_id,
                  TRIM(lastlogin) AS llog,
                  TRIM(failedlogin) AS flog,
                  COALESCE(msg_tx, 0) AS msg_tx,
                  userflags,
                  COALESCE(challenge_quest_id, 0) AS savecqid,
                  mfaquest,
                  TRIM(primary_account) As primary_account
              FROM    %s
              WHERE   LOWER(user_name) = '" . strtolower(prep_save($username)) ."'";

        $sql = sprintf($sql, $this->TableName($this->creditUnion));

        $query = db_query($sql, $this->dbh);

        if (!$query) {
          $error = db_last_error();
          $this->logger->error('Could not read table ' . $this->TableName($this->creditUnion) . ". Error: $error");
          return false;
        }
        $rows = db_fetch_all($query);
        if (!$rows) {
          return [];
        }
        return $rows[0];
    }

    /**
     * Create
     *
     * @param   array   $data       Array of data to be inserted
     *                                  [
     *                                      'column_name' => 'my new value',
     *                                  ]
     *                               An empty array or no valid columns will return a False
     * @return  bool
     *
     * @throws Exception
     */
    public function Create($data) {
    }
    /**
     * Update
     *
     * @param   array $identifiers User identifiers
     * @param   array $data Array of data to be updated
     *                                      [
     *                                          'column_name' => 'my new value',
     *                                      ]
     *                                   An empty array or no valid columns will return a False
     * @return bool
     * @throws Exception
     */
    public function Update($identifiers, $data) {
        if (empty($identifiers)) {
            throw new Exception(static::class . ': Did not pass an identifier to update');
        }
        if (empty($data)) {
            throw new Exception(static::class . ': Did not pass any valid columns to update in table ' . $this->TableName($this->creditUnion));
        }
        $meta = db_meta_data($this->dbh, $this->TableName($this->creditUnion));
        list($set, $values) = $this->BuildSetColumns($data, $meta);
        if (empty($set)) {
            throw new Exception(static::class . ': Did not pass any valid columns to update in table ' . $this->TableName($this->creditUnion) );
        }
        $key = '';
        $index = count($values) + 1;
        foreach ($identifiers as $value) {
            $key .= "\$$index,";
            $index++;
        }
        $key = rtrim($key, ',');
        $sql = <<< SQL
UPDATE %s
$set
WHERE user_name IN ($key);
SQL;
        $sql = sprintf($sql, $this->TableName($this->creditUnion) );
        $query = db_query_params($sql, array_merge($values, $identifiers), $this->dbh);
        if (!$query) {
            $error = db_last_error();
            $this->logger->error('Failed updating identifier [' . implode(',', $identifiers) . ": $error");
            return false;
        }
        return true;
    }

    /**
     * Delete feature gate
     *
     * @param   array   $keys       Identifiers
     * @return  bool|int
     *
     * @throws Exception
     */
    public function Delete($keys) {
    }

    /**
     * Simple helper to collect the set values for update
     *
     * @param   array   $data   Array of columns and values
     * @param   array   $meta   Meta information about the table structure
     * @return  array
     */
    private function BuildSetColumns($data, $meta) {
        $result = 'SET ';
        $values = [];
        $index = 1;
        foreach ($data as $column => $value) {
            $type = $meta[$column]['type'];
            $result .= "$column = \$$index,\n";
            $index++;
            $values[] = $this->ColumnByType($value, $type);
        }
        return [rtrim($result, ",\n"), $values];
    }

    /**
     * Simple helper to collect the column & value strings for inserts
     *
     * @param   array   $data   Array of columns and values
     * @param   array   $meta   Meta information about the table structure
     * @return  array
     */
    private function BuildInsertColumns($data, $meta) {
        $columns = [];
        $values = [];
        $place = [];
        $count = 1;
        foreach ($data as $column => $value) {
            if (!array_key_exists($column, $meta)) {
                $this->logger->debug("Tried to insert invalid column: $column, into table " . static::TABLE_NAME);
                continue;
            }
            $type = $meta[$column]['type'];
            $columns[] = $column;
            $place[] = "\$$count";
            $values[] = $this->ColumnByType($value, $type);
            $count++;
        }
        return [
            implode(',', $columns),
            implode(',', $place),
            $values,
        ];
    }

    /**
     * Simple helper to create a database value based on type
     *
     * @param   string  $value  Column value
     * @param   string  $type   Column type
     * @return  string
     */
    private function ColumnByType($value, $type) {
        switch (true) {
            case strpos($type, 'int') !== false:
                return intval($value);
                break;
            case strpos($type, 'double') !== false:
            case 'numeric' === $type:
                return floatval($value);
                break;
            case strpos($type, 'char') !== false:
            case 'text' === $type:
                return $value;
                break;
            case strpos($type, 'timestamp') !== false:
            case 'date' === $type:
                return $value;
                break;
            case strpos($type, 'bool') !== false:
                return $value ? 'true' : 'false';
                break;
            default:
                return $value;
        }
    }
}