CuAdminRepo.php

<?php
class CuAdminRepo {
    /**
    * CuAdmin Repository
    */

    const TABLE_NAME = 'cuadmin';
    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 cuadmin.
     *
     * @return  array|bool
     */
    public function Read($creditUnion) {

      $query = "SELECT COALESCE(flagset, 0) as flagset,
        COALESCE(flagset2, 0) as flagset2,
        COALESCE(flagset3, 0) as flagset3,
        livewait,
        TRIM(lastupdate) as lastupdate,
        min_chlng_qst,
        pname,
        COALESCE(histdays, 0) as fhdays,
        COALESCE(gracelimit, 0) as grace,
        trmemomaxlen,
        TRIM(cu) as cu
        FROM %s
        WHERE LOWER(cu) = '". strtolower(prep_save($creditUnion)) ."'";

      $query = sprintf($query, static::TABLE_NAME);
      $sth = db_query($query, $this->dbh);
      $rows = db_fetch_all($sth);

      if (!$rows) {
        throw new Exception('CuAdmin: Problem getting credit union settings!');;
      }
      // $admininfo = $rows[0];
      // $this->admininfo = $admininfo;
      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 cu 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;
        }
    }
}