(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 * . */ /** * Utility functions * @package CiviCRM */ class Utils { /** * PDO for the database * @var PDO */ public $pdo; /** * Construct an object for this database * @param $host * @param $port * @param $user * @param $pass */ public function __construct($host, $port, $user, $pass) { 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: