1: <?php
2:
3: global $db;
4: $db = get_db_connection(DB_CONNSTR, DB_USERNAME, DB_PASSWORD);
5:
6: function connect_queue_db() {
7: return get_db_connection(QUEUE_DB_CONNSTR, QUEUE_DB_USERNAME, QUEUE_DB_PASSWORD);
8: }
9:
10: function get_db_connection($connstr, $username, $password) {
11: try {
12: if (defined('DEBUG') && DEBUG) {
13: require_once 'loggedPDO/PDO.php';
14: require_once 'loggedPDO/Log_firebugJSON.php';
15:
16: if (PHP_SAPI == 'cli') {
17: $logtype = 'console';
18: } else {
19: if (in_array('Content-type: application/json', headers_list())) {
20: $logtype = 'console';
21: } else {
22: $logtype = 'firebugJSON';
23: }
24: }
25: $logger = Log::factory($logtype, '', 'PDO');
26: $db = new \LoggedPDO\PDO($connstr, $username, $password, null, $logger);
27:
28: } else {
29: $db = new PDO($connstr, $username, $password, array(PDO::ATTR_PERSISTENT => true, PDO::ATTR_EMULATE_PREPARES => false));
30: }
31:
32: $db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
33:
34: return $db;
35: } catch (\PDOException $e) {
36: print "Error!: " . $e->getMessage() . "<br/>";
37: die();
38: }
39: }
40:
41: ?>
42: