CRM-17860 - CiviUnitTestCase - Maintain headless schema automatically

[civicrm-core.git] / tests / phpunit / CiviTest / CiviTestPdoUtils.php

<?php
// vim: set si ai expandtab tabstop=4 shiftwidth=4 softtabstop=4:

/**
 *  File for the Utils class
 *
 *  (PHP 5)
 *
 * @author Walt Haas <walt@dharmatech.org> (801) 534-1262
 * @copyright Copyright CiviCRM LLC (C) 2009
 * @license   http://www.fsf.org/licensing/licenses/agpl-3.0.html
 *              GNU Affero General Public License version 3
 * @version   $Id: Utils.php 40328 2012-05-11 23:06:13Z allen $
 * @package   CiviCRM
 *
 *   This file is part of CiviCRM
 *
 *   CiviCRM is free software; you can redistribute it and/or
 *   modify it under the terms of the GNU Affero General Public License
 *   as published by the Free Software Foundation; either version 3 of
 *   the License, or (at your option) any later version.
 *
 *   CiviCRM is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *   GNU Affero General Public License for more details.
 *
 *   You should have received a copy of the GNU Affero General Public
 *   License along with this program.  If not, see
 *   <http://www.gnu.org/licenses/>.
 */

/**
 *  Utility functions
 * @package   CiviCRM
 */
class CiviTestPdoUtils {

  /**
   *  PDO for the database.
   * @var PDO
   */
  public $pdo;

  public $dbName;

  /**
   *  Construct an object for this database.
   */
  public function __construct($dsn) {
    require_once "DB.php";
    $dsninfo = DB::parseDSN($dsn);
    $host = $dsninfo['hostspec'];
    $port = @$dsninfo['port'];
    $user = $dsninfo['username'];
    $pass = $dsninfo['password'];
    $this->dbName = $dsninfo['database'];

    try {
      $this->pdo = new PDO("mysql:host={$host}" . ($port ? ";port=$port" : ""),
        $user, $pass,
        array(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => TRUE)
      );
    }
    catch (PDOException$e) {
      echo "Can't connect to MySQL server:" . PHP_EOL . $e->getMessage() . PHP_EOL;
      exit(1);
    }
  }

  /**
   * Prepare and execute a query.
   *
   * If the query fails, output a diagnostic message
   * @param string $query
   *   Query to run
   * @return bool
   */
  public function do_query($query) {
    // echo "do_query($query)\n";
    // $stmt = $this->pdo->query( $query, PDO::FETCH_ASSOC );
    // echo "PDO returned";
    // var_dump($stmt);
    $string = preg_replace("/^#[^\n]*$/m", "\n", $query);
    $string = preg_replace("/^(--[^-]).*/m", "\n", $string);

    $queries = preg_split('/;\s*$/m', $string);
    foreach ($queries as $query) {
      $query = trim($query);
      if (!empty($query)) {
        $result = $this->pdo->query($query);
        if ($this->pdo->errorCode() == 0) {
          continue;
        }
        else {
          var_dump($result);
          var_dump($this->pdo->errorInfo());
          // die( "Cannot execute $query: " . $this->pdo->errorInfo() );
        }
      }
    }

    /*******
     * if ( $this->pdo->errorCode() == 0 ) {
     * //echo "returning the PDOStmt\n";
     * return $stmt;
     * }
     *
     * //  operation failed, so output description of where and why
     * $errorInfo = $this->pdo->errorInfo();
     * echo "Oops, can't do query:\n    {$query}\n    in "
     * . basename( __FILE__) . " line " . __LINE__.":\n    "
     * . $errorInfo[0] . ": " . $errorInfo[2] . "\n    Call stack:\n";
     * $backtrace = debug_backtrace();
     * $dir_name  = dirname( __FILE__ );
     * $cwd_len   = strlen( $dir_name ) + 1;
     * foreach ($backtrace as $frame ) {
     * echo "      ";
     * if ( array_key_exists( 'class', $frame ) ) {
     * echo " class {$frame['class']}";
     * if ( array_key_exists( 'function', $frame ) ) {
     * echo " method {$frame['function']}";
     * }
     * }
     * else {
     * if ( array_key_exists( 'function', $frame ) ) {
     * echo " function {$frame['function']}";
     * }
     * }
     * if ( array_key_exists( 'file', $frame ) ) {
     * echo " file ". substr( $frame['file'], $cwd_len );
     * }
     * if ( array_key_exists( 'line', $frame ) ) {
     * echo " line {$frame['line']}";
     * }
     * echo "\n";
     * }
     ******/
    return TRUE;
  }

}
// class Utils

// -- set Emacs parameters --
// Local variables:
// mode: php;
// tab-width: 4
// c-basic-offset: 4
// c-hanging-comment-ender-p: nil
// indent-tabs-mode: nil
// End: