library/sql.inc

   1 <?php
   2 /**
   3  * Sql functions/classes for OpenEMR.
   4  *
   5  * Includes classes and functions that OpenEMR uses
   6  * to interact with SQL.
   7  *
   8  * @package   OpenEMR
   9  * @link      http://www.open-emr.org
  10  * @author    Brady Miller <brady.g.miller@gmail.com>
  11  * @author    Kevin Yeh <kevin.y@integralemr.com>
  12  * @copyright Copyright (c) 2019 Brady Miller <brady.g.miller@gmail.com>
  13  * @copyright Copyright (c) 2013 Kevin Yeh <kevin.y@integralemr.com>
  14  * @copyright Copyright (c) 2013 OEMR <www.oemr.org>
  15  * @license   https://github.com/openemr/openemr/blob/master/LICENSE GNU General Public License 3
  16  */
  17
  18
  19 require_once(dirname(__FILE__) . "/sqlconf.php");
  20 require_once(dirname(__FILE__) . "/../vendor/adodb/adodb-php/adodb.inc.php");
  21 require_once(dirname(__FILE__) . "/../vendor/adodb/adodb-php/drivers/adodb-mysqli.inc.php");
  22 require_once(dirname(__FILE__) . "/ADODB_mysqli_log.php");
  23
  24 if (!defined('ADODB_FETCH_ASSOC')) {
  25     define('ADODB_FETCH_ASSOC', 2);
  26 }
  27
  28 $database = NewADOConnection("mysqli_log"); // Use the subclassed driver which logs execute events
  29 // Below optionFlags flag is telling the mysql connection to ensure local_infile setting,
  30 // which is needed to import data in the Administration->Other->External Data Loads feature.
  31 // (Note the MYSQLI_READ_DEFAULT_GROUP is just to keep the current setting hard-coded in adodb)
  32 $database->optionFlags = array(array(MYSQLI_READ_DEFAULT_GROUP,0), array(MYSQLI_OPT_LOCAL_INFILE,1));
  33 // Set mysql to use ssl, if applicable.
  34 // Can support basic encryption by including just the mysql-ca pem (this is mandatory for ssl)
  35 // Can also support client based certificate if also include mysql-cert and mysql-key (this is optional for ssl)
  36 if (file_exists($GLOBALS['OE_SITE_DIR'] . "/documents/certificates/mysql-ca")) {
  37     if (defined('MYSQLI_CLIENT_SSL')) {
  38         $database->clientFlags = MYSQLI_CLIENT_SSL;
  39     }
  40 }
  41 $database->port = $port;
  42 $database->PConnect($host, $login, $pass, $dbase);
  43 $GLOBALS['adodb']['db'] = $database;
  44 $GLOBALS['dbh'] = $database->_connectionID;
  45
  46 // Modified 5/2009 by BM for UTF-8 project ---------
  47 if (!$disable_utf8_flag) {
  48     $success_flag = $database->ExecuteNoLog("SET NAMES 'utf8'");
  49     if (!$success_flag) {
  50         error_log("PHP custom error: from openemr library/sql.inc  - Unable to set up UTF8 encoding with mysql database: " . errorLogEscape(getSqlLastError()), 0);
  51     }
  52 }
  53
  54 // Turn off STRICT SQL
  55 $sql_strict_set_success = $database->ExecuteNoLog("SET sql_mode = ''");
  56 if (!$sql_strict_set_success) {
  57     error_log("Unable to set strict sql setting: " . errorLogEscape(getSqlLastError()), 0);
  58 }
  59
  60 // set up associations in adodb calls (not sure why above define
  61 //  command does not work)
  62 $GLOBALS['adodb']['db']->SetFetchMode(ADODB_FETCH_ASSOC);
  63
  64 if ($GLOBALS['debug_ssl_mysql_connection']) {
  65     error_log("CHECK SSL CIPHER IN MAIN ADODB: " . errorLogEscape(print_r($GLOBALS['adodb']['db']->ExecuteNoLog("SHOW STATUS LIKE 'Ssl_cipher';")->fields, true)));
  66 }
  67
  68 //fmg: This makes the login screen informative when no connection can be made
  69 if (!$GLOBALS['dbh']) {
  70   //try to be more helpful
  71     if ($host == "localhost") {
  72         echo "Check that mysqld is running.<p>";
  73     } else {
  74         echo "Check that you can ping the server " . text($host) . ".<p>";
  75     }//if local
  76     HelpfulDie("Could not connect to server!", getSqlLastError());
  77     exit;
  78 }//if no connection
  79
  80 /**
  81 * Standard sql query in OpenEMR.
  82 *
  83 * Function that will allow use of the adodb binding
  84 * feature to prevent sql-injection. Will continue to
  85 * be compatible with previous function calls that do
  86 * not use binding.
  87 * It will return a recordset object.
  88 * The sqlFetchArray() function should be used to
  89 * utilize the return object.
  90 *
  91 * @param  string  $statement  query
  92 * @param  array   $binds      binded variables array (optional)
  93 * @return recordset
  94 */
  95 function sqlStatement($statement, $binds = false)
  96 {
  97     // Below line is to avoid a nasty bug in windows.
  98     if (empty($binds)) {
  99         $binds = false;
 100     }
 101
 102     // Use adodb Execute with binding and return a recordset.
 103     //   Note that the auditSQLEvent function is embedded
 104     //    in the Execute command.
 105     $recordset = $GLOBALS['adodb']['db']->Execute($statement, $binds);
 106     if ($recordset === false) {
 107         HelpfulDie("query failed: $statement", getSqlLastError());
 108     }
 109
 110     return $recordset;
 111 }
 112
 113 /**
 114 * Specialized sql query in OpenEMR that skips auditing.
 115 *
 116 * Function that will allow use of the adodb binding
 117 * feature to prevent sql-injection. Will continue to
 118 * be compatible with previous function calls that do
 119 * not use binding. It is equivalent to the
 120 * sqlStatement() function, EXCEPT it skips the
 121 * audit engine. This function should only be used
 122 * in very special situations.
 123 * It will return a recordset object.
 124 * The sqlFetchArray() function should be used to
 125 * utilize the return object.
 126 *
 127 * @param  string  $statement  query
 128 * @param  array   $binds      binded variables array (optional)
 129 * @return recordset
 130 */
 131 function sqlStatementNoLog($statement, $binds = false)
 132 {
 133     // Below line is to avoid a nasty bug in windows.
 134     if (empty($binds)) {
 135         $binds = false;
 136     }
 137
 138     // Use adodb ExecuteNoLog with binding and return a recordset.
 139     $recordset = $GLOBALS['adodb']['db']->ExecuteNoLog($statement, $binds);
 140     if ($recordset === false) {
 141         HelpfulDie("query failed: $statement", getSqlLastError());
 142     }
 143
 144     return $recordset;
 145 }
 146
 147 /**
 148 * sqlStatement() function wrapper for CDR engine in OpenEMR.
 149 * Allows option to turn on/off auditing specifically for the
 150 * CDR engine.
 151 *
 152 * @param  string  $statement  query
 153 * @param  array   $binds      binded variables array (optional)
 154 * @return recordset/resource
 155 */
 156 function sqlStatementCdrEngine($statement, $binds = false)
 157 {
 158     // Below line is to avoid a nasty bug in windows.
 159     if (empty($binds)) {
 160         $binds = false;
 161     }
 162
 163     if ($GLOBALS['audit_events_cdr']) {
 164         return sqlStatement($statement, $binds);
 165     } else {
 166         return sqlStatementNoLog($statement, $binds);
 167     }
 168 }
 169
 170 /**
 171 * Returns a row (as an array) from a sql recordset.
 172 *
 173 * Function that will allow use of the adodb binding
 174 * feature to prevent sql-injection.
 175 * It will act upon the object returned from the
 176 * sqlStatement() function (and sqlQ() function).
 177 *
 178 * @param recordset $r
 179 * @return array
 180 */
 181 function sqlFetchArray($r)
 182 {
 183     //treat as an adodb recordset
 184     if ($r === false) {
 185         return false;
 186     }
 187
 188     if ($r->EOF) {
 189         return false;
 190     }
 191
 192     //ensure it's an object (ie. is set)
 193     if (!is_object($r)) {
 194         return false;
 195     }
 196
 197     return $r->FetchRow();
 198 }
 199
 200
 201 /**
 202  * Wrapper for ADODB getAssoc
 203  *
 204  * @see http://adodb.org/dokuwiki/doku.php?id=v5:reference:connection:getassoc
 205  *
 206  * @param string $sql
 207  * @param string[] $bindvars
 208  * @param boolean $forceArray
 209  * @param boolean $first2Cols
 210  * @return array
 211  */
 212 function sqlGetAssoc($sql, $bindvars = false, $forceArray = false, $first2Cols = false)
 213 {
 214
 215     return $GLOBALS['adodb']['db']->getAssoc($sql, $bindvars, $forceArray, $first2Cols);
 216 }
 217
 218 /**
 219 * Standard sql insert query in OpenEMR.
 220 *  Only use this function if you need to have the
 221 *  id returned. If doing an insert query and do
 222 *  not need the id returned, then use the
 223 *  sqlStatement function instead.
 224 *
 225 * Function that will allow use of the adodb binding
 226 * feature to prevent sql-injection. This function
 227 * is specialized for insert function and will return
 228 * the last id generated from the insert.
 229 *
 230 * @param  string   $statement  query
 231 * @param  array    $binds      binded variables array (optional)
 232 * @return integer  Last id generated from the sql insert command
 233 */
 234 function sqlInsert($statement, $binds = false)
 235 {
 236     // Below line is to avoid a nasty bug in windows.
 237     if (empty($binds)) {
 238         $binds = false;
 239     }
 240
 241     //Run a adodb execute
 242     // Note the auditSQLEvent function is embedded in the
 243     //   Execute function.
 244     $recordset = $GLOBALS['adodb']['db']->Execute($statement, $binds, true);
 245     if ($recordset === false) {
 246         HelpfulDie("insert failed: $statement", getSqlLastError());
 247     }
 248
 249     // Return the correct last id generated using function
 250     //   that is safe with the audit engine.
 251     return $GLOBALS['lastidado'] > 0 ? $GLOBALS['lastidado'] : $GLOBALS['adodb']['db']->Insert_ID();
 252 }
 253
 254 /**
 255 * Specialized sql query in OpenEMR that only returns
 256 * the first row of query results as an associative array.
 257 *
 258 * Function that will allow use of the adodb binding
 259 * feature to prevent sql-injection.
 260 *
 261 * @param  string  $statement  query
 262 * @param  array   $binds      binded variables array (optional)
 263 * @return array
 264 */
 265 function sqlQuery($statement, $binds = false)
 266 {
 267     // Below line is to avoid a nasty bug in windows.
 268     if (empty($binds)) {
 269         $binds = false;
 270     }
 271
 272     $recordset = $GLOBALS['adodb']['db']->Execute($statement, $binds);
 273
 274     if ($recordset === false) {
 275         HelpfulDie("query failed: $statement", getSqlLastError());
 276     }
 277
 278     if ($recordset->EOF) {
 279         return false;
 280     }
 281
 282     $rez = $recordset->FetchRow();
 283     if ($rez == false) {
 284         return false;
 285     }
 286
 287     return $rez;
 288 }
 289
 290 /**
 291 * Specialized sql query in OpenEMR that bypasses the auditing engine
 292 * and only returns the first row of query results as an associative array.
 293 *
 294 * Function that will allow use of the adodb binding
 295 * feature to prevent sql-injection. It is equivalent to the
 296 * sqlQuery() function, EXCEPT it skips the
 297 * audit engine. This function should only be used
 298 * in very special situations.
 299 *
 300 * @param  string  $statement  query
 301 * @param  array   $binds      binded variables array (optional)
 302 * @return array
 303 */
 304 function sqlQueryNoLog($statement, $binds = false)
 305 {
 306     // Below line is to avoid a nasty bug in windows.
 307     if (empty($binds)) {
 308         $binds = false;
 309     }
 310
 311     $recordset = $GLOBALS['adodb']['db']->ExecuteNoLog($statement, $binds);
 312
 313     if ($recordset === false) {
 314         HelpfulDie("query failed: $statement", getSqlLastError());
 315     }
 316
 317     if ($recordset->EOF) {
 318         return false;
 319     }
 320
 321     $rez = $recordset->FetchRow();
 322     if ($rez == false) {
 323         return false;
 324     }
 325
 326     return $rez;
 327 }
 328
 329 /**
 330 * Specialized sql query in OpenEMR that ignores sql errors, bypasses the
 331 * auditing engine and only returns the first row of query results as an
 332 * associative array.
 333 *
 334 * Function that will allow use of the adodb binding
 335 * feature to prevent sql-injection. It is equivalent to the
 336 * sqlQuery() function, EXCEPT it skips the
 337 * audit engine and ignores erros. This function should only be used
 338 * in very special situations.
 339 *
 340 * @param  string  $statement  query
 341 * @param  array   $binds      binded variables array (optional)
 342 * @return array
 343 */
 344 function sqlQueryNoLogIgnoreError($statement, $binds = false)
 345 {
 346     // Below line is to avoid a nasty bug in windows.
 347     if (empty($binds)) {
 348         $binds = false;
 349     }
 350
 351     $recordset = $GLOBALS['adodb']['db']->ExecuteNoLog($statement, $binds);
 352
 353     if ($recordset === false) {
 354         // ignore the error and return FALSE
 355         return false;
 356     }
 357
 358     if ($recordset->EOF) {
 359         return false;
 360     }
 361
 362     $rez = $recordset->FetchRow();
 363     if ($rez == false) {
 364         return false;
 365     }
 366
 367     return $rez;
 368 }
 369
 370 /**
 371 * sqlQuery() function wrapper for CDR engine in OpenEMR.
 372 * Allows option to turn on/off auditing specifically for the
 373 * CDR engine.
 374 *
 375 * @param  string  $statement  query
 376 * @param  array   $binds      binded variables array (optional)
 377 * @return array
 378 */
 379 function sqlQueryCdrEngine($statement, $binds = false)
 380 {
 381     // Below line is to avoid a nasty bug in windows.
 382     if (empty($binds)) {
 383         $binds = false;
 384     }
 385
 386     if ($GLOBALS['audit_events_cdr']) {
 387         return sqlQuery($statement, $binds);
 388     } else {
 389         return sqlQueryNoLog($statement, $binds);
 390     }
 391 }
 392
 393 /**
 394 * Specialized sql query in OpenEMR that skips auditing.
 395 *
 396 * This function should only be used in very special situations.
 397 *
 398 * @param  string  $statement  query
 399 */
 400 function sqlInsertClean_audit($statement)
 401 {
 402
 403     $ret = $GLOBALS['adodb']['db']->ExecuteNoLog($statement);
 404     if ($ret === false) {
 405         HelpfulDie("insert failed: $statement", getSqlLastError());
 406     }
 407 }
 408
 409 /**
 410 * Function that will safely return the last error,
 411 * and accounts for the audit engine.
 412 *
 413 * @param   string  $mode either adodb(default) or native_mysql
 414 * @return  string        last mysql error
 415 */
 416 function getSqlLastError()
 417 {
 418     return !empty($GLOBALS['last_mysql_error']) ? $GLOBALS['last_mysql_error'] : $GLOBALS['adodb']['db']->ErrorMsg();
 419 }
 420
 421 /**
 422  * Function that will safely return the last error no,
 423  * and accounts for the audit engine.
 424  *
 425  * @param   string  $mode either adodb(default) or native_mysql
 426  * @return  string        last mysql error no
 427  */
 428 function getSqlLastErrorNo()
 429 {
 430     return !empty($GLOBALS['last_mysql_error_no']) ? $GLOBALS['last_mysql_error_no'] : $GLOBALS['adodb']['db']->ErrorNo();
 431 }
 432
 433 /**
 434 * Function that will return an array listing
 435 * of columns that exist in a table.
 436 *
 437 * @param   string  $table sql table
 438 * @return  array
 439 */
 440 function sqlListFields($table)
 441 {
 442     $sql = "SHOW COLUMNS FROM ". add_escape_custom($table);
 443     $resource = sqlQ($sql);
 444     $field_list = array();
 445     while ($row = sqlFetchArray($resource)) {
 446         $field_list[] = $row['Field'];
 447     }
 448
 449     return $field_list;
 450 }
 451
 452 /**
 453 * Returns the number of sql rows
 454 *
 455 * @param recordset $r
 456 * @return integer Number of rows
 457 */
 458 function sqlNumRows($r)
 459 {
 460     return $r->RecordCount();
 461 }
 462
 463 /**
 464 * Error function for OpenEMR sql functions
 465 *
 466 * @param string $statement
 467 * @param string $sqlerr
 468 */
 469 function HelpfulDie($statement, $sqlerr = '')
 470 {
 471
 472     echo "<h2><font color='red'>" . xlt('Query Error') . "</font></h2>";
 473
 474     if (!$GLOBALS['sql_string_no_show_screen']) {
 475         echo "<p><font color='red'>ERROR:</font> " . text($statement) . "</p>";
 476     }
 477
 478     $logMsg="SQL Error with statement:".$statement;
 479
 480     if ($sqlerr) {
 481         if (!$GLOBALS['sql_string_no_show_screen']) {
 482              echo "<p>Error: <font color='red'>" . text($sqlerr) . "</font></p>";
 483         }
 484
 485         $logMsg.="--".$sqlerr;
 486     }//if error
 487
 488     $backtrace = debug_backtrace();
 489
 490     if (!$GLOBALS['sql_string_no_show_screen']) {
 491         for ($level = 1; $level < count($backtrace); $level++) {
 492             $info = $backtrace[$level];
 493             echo "<br>" . text($info["file"] . " at " . $info["line"] . ":" . $info["function"]);
 494             if ($level > 1) {
 495                 echo "(" . text(implode(",", $info["args"])) . ")";
 496             }
 497         }
 498     }
 499
 500     $logMsg.="==>".$backtrace[1]["file"]." at ".$backtrace[1]["line"].":".$backtrace[1]["function"];
 501
 502     error_log(errorLogEscape($logMsg));
 503
 504     exit;
 505 }
 506
 507 /**
 508 * @todo document use of the generate_id function
 509 */
 510 function generate_id()
 511 {
 512     $database = $GLOBALS['adodb']['db'];
 513     return $database->GenID("sequences");
 514 }
 515
 516 /**
 517 * Deprecated function. Standard sql query in OpenEMR.
 518 *
 519 * Function that will allow use of the adodb binding
 520 * feature to prevent sql-injection. Will continue to
 521 * be compatible with previous function calls that do
 522 * not use binding.
 523 * It will return a recordset object.
 524 * The sqlFetchArray() function should be used to
 525 * utilize the return object.
 526 *
 527 * @deprecated
 528 * @param  string  $statement  query
 529 * @param  array   $binds      binded variables array (optional)
 530 * @return recordset
 531 */
 532 function sqlQ($statement, $binds = false)
 533 {
 534     // Below line is to avoid a nasty bug in windows.
 535     if (empty($binds)) {
 536         $binds = false;
 537     }
 538
 539     $recordset = $GLOBALS['adodb']['db']->Execute($statement, $binds) or
 540     HelpfulDie("query failed: $statement", getSqlLastError());
 541     return $recordset;
 542 }
 543
 544
 545 /**
 546 * Sql close connection function (deprecated)
 547 *
 548 * No longer needed since PHP does this automatically.
 549 *
 550 * @deprecated
 551 * @return boolean
 552 */
 553 function sqlClose()
 554 {
 555   //----------Close our mysql connection
 556     $closed = $GLOBALS['adodb']['db']->close or
 557     HelpfulDie("could not disconnect from mysql server link", getSqlLastError());
 558     return $closed;
 559 }
 560
 561 /**
 562 * Very simple wrapper function and not necessary (deprecated)
 563 *
 564 * Do not use.
 565 *
 566 * @deprecated
 567 * @return connection
 568 */
 569 function get_db()
 570 {
 571     return $GLOBALS['adodb']['db'];
 572 }
 573
 574 /**
 575  * Generic mysql select db function
 576  * Used when converted to mysqli to centralize special circumstances.
 577  * @param string $database
 578  */
 579 function generic_sql_select_db($database, $link = null)
 580 {
 581     if (is_null($link)) {
 582         $link = $GLOBALS['dbh'];
 583     }
 584
 585     mysqli_select_db($link, $database);
 586 }
 587
 588 /**
 589  * Generic mysql affected rows function
 590  * Used when converted to mysqli to centralize special circumstances.
 591  *
 592  */
 593 function generic_sql_affected_rows()
 594 {
 595     return mysqli_affected_rows($GLOBALS['dbh']);
 596 }
 597
 598 /**
 599  * Generic mysql insert id function
 600  * Used when converted to mysqli to centralize special circumstances.
 601  *
 602                  */
 603 function generic_sql_insert_id()
 604 {
 605     return mysqli_insert_id($GLOBALS['dbh']);
 606 }
 607
 608
 609 /**
 610  * Begin a Transaction.
 611  */
 612 function sqlBeginTrans()
 613 {
 614     $GLOBALS['adodb']['db']->BeginTrans();
 615 }
 616
 617
 618 /**
 619  * Commit a transaction
 620  */
 621 function sqlCommitTrans($ok = true)
 622 {
 623     $GLOBALS['adodb']['db']->CommitTrans();
 624 }
 625
 626
 627 /**
 628  * Rollback a transaction
 629  */
 630 function sqlRollbackTrans()
 631 {
 632     $GLOBALS['adodb']['db']->RollbackTrans();
 633 }
 634
 635 /**
 636  * For the 3 functions below:
 637  *
 638  * To support an optional higher level of security, queries that access password
 639  * related information use these functions instead of the standard functions
 640  * provided by sql.inc.
 641  *
 642  * By default, the privQuery and privStatement calls pass-through to
 643  * the existing ADODB instance initialized by sql.inc.
 644  *
 645  * If an additional configuration file is created (secure_sqlconf.php) and saved
 646  * in the sites/<sitename> directory (e.g. sites/default).  The MySQL login
 647  * information defined in that file as $secure_* will be used to create an ADODB
 648  * instance specifically for querying privileged information.
 649  *
 650  * By configuring a server in this way, the default MySQL user can be denied access
 651  * to sensitive tables (currently only "users_secure" would qualify).  Thus
 652  * the likelyhood of unintended modification can be reduced (e.g. through SQL Injection).
 653  *
 654  * Details on how to set this up are included in Documentation/privileged_db/priv_db_HOWTO
 655  *
 656  * The trade off for this additional security is extra complexity in configuration and
 657  * maintenance of the database, hence it is not enabled at install time and must be
 658  * done manually.
 659  *
 660  */
 661 function getPrivDB()
 662 {
 663     if (!isset($GLOBALS['PRIV_DB'])) {
 664         $secure_config=$GLOBALS['OE_SITE_DIR'] . "/secure_sqlconf.php";
 665         if (file_exists($secure_config)) {
 666             require_once($secure_config);
 667             $GLOBALS['PRIV_DB']=NewADOConnection("mysqli_log"); // Use the subclassed driver which logs execute events
 668             // Below optionFlags flag is telling the mysql connection to ensure local_infile setting,
 669             // which is needed to import data in the Administration->Other->External Data Loads feature.
 670             // (Note the MYSQLI_READ_DEFAULT_GROUP is just to keep the current setting hard-coded in adodb)
 671             $GLOBALS['PRIV_DB']->optionFlags = array(array(MYSQLI_READ_DEFAULT_GROUP,0), array(MYSQLI_OPT_LOCAL_INFILE,1));
 672             // Set mysql to use ssl, if applicable.
 673             // Can support basic encryption by including just the mysql-ca pem (this is mandatory for ssl)
 674             // Can also support client based certificate if also include mysql-cert and mysql-key (this is optional for ssl)
 675             if (file_exists($GLOBALS['OE_SITE_DIR'] . "/documents/certificates/mysql-ca")) {
 676                 if (defined('MYSQLI_CLIENT_SSL')) {
 677                     $GLOBALS['PRIV_DB']->clientFlags = MYSQLI_CLIENT_SSL;
 678                 }
 679             }
 680             $GLOBALS['PRIV_DB']->port = $port;
 681             $GLOBALS['PRIV_DB']->PConnect($secure_host, $secure_login, $secure_pass, $secure_dbase);
 682             // set up associations in adodb calls
 683             $GLOBALS['PRIV_DB']->SetFetchMode(ADODB_FETCH_ASSOC);
 684             // debug hook for ssl stuff
 685             if ($GLOBALS['debug_ssl_mysql_connection']) {
 686                 error_log("CHECK SSL CIPHER IN PRIV_DB ADODB: " . errorLogEscape(print_r($GLOBALS[PRIV_DB]->ExecuteNoLog("SHOW STATUS LIKE 'Ssl_cipher';")->fields), true));
 687             }
 688         } else {
 689             $GLOBALS['PRIV_DB']=$GLOBALS['adodb']['db'];
 690         }
 691     }
 692
 693     return $GLOBALS['PRIV_DB'];
 694 }
 695 /**
 696  * mechanism to use "super user" for SQL queries related to password operations
 697  *
 698  * @param type $sql
 699  * @param type $params
 700  * @return type
 701  */
 702 function privStatement($sql, $params = null)
 703 {
 704     if (is_array($params)) {
 705         $recordset = getPrivDB()->ExecuteNoLog($sql, $params);
 706     } else {
 707         $recordset = getPrivDB()->ExecuteNoLog($sql);
 708     }
 709
 710     if ($recordset === false) {
 711         // These error messages are explictly NOT run through xl() because we still
 712         // need them if there is a database problem.
 713         echo "Failure during database access! Check server error log.";
 714         $backtrace=debug_backtrace();
 715
 716         error_log("Executing as user:" . errorLogEscape(getPrivDB()->user) . " Statement failed:" . errorLogEscape($sql) . ":" . errorLogEscape($GLOBALS['last_mysql_error'])
 717             . "==>" . errorLogEscape($backtrace[1]["file"]) . " at " . errorLogEscape($backtrace[1]["line"]) . ":" . errorLogEscape($backtrace[1]["function"]));
 718         exit;
 719     }
 720
 721     return $recordset;
 722 }
 723 /**
 724  *
 725  * Wrapper for privStatement that just returns the first row of a query or FALSE
 726  * if there were no results.
 727  *
 728  * @param type $sql
 729  * @param type $params
 730  * @return boolean
 731  */
 732 function privQuery($sql, $params = null)
 733 {
 734     $recordset=privStatement($sql, $params);
 735     if ($recordset->EOF) {
 736         return false;
 737     }
 738
 739     $rez = $recordset->FetchRow();
 740     if ($rez == false) {
 741         return false;
 742     }
 743
 744     return $rez;
 745 }