]>
Commit | Line | Data |
---|---|---|
59c06b17 CS |
1 | <?php if ( ! defined('BASEPATH')) exit('No direct script access allowed'); |
2 | /** | |
3 | * CodeIgniter | |
4 | * | |
5 | * An open source application development framework for PHP 5.1.6 or newer | |
6 | * | |
7 | * @package CodeIgniter | |
8 | * @author ExpressionEngine Dev Team | |
9 | * @copyright Copyright (c) 2008 - 2011, EllisLab, Inc. | |
10 | * @license http://codeigniter.com/user_guide/license.html | |
11 | * @link http://codeigniter.com | |
12 | * @since Version 1.0 | |
13 | * @filesource | |
14 | */ | |
15 | ||
16 | // ------------------------------------------------------------------------ | |
17 | ||
18 | /** | |
19 | * Initialize the database | |
20 | * | |
21 | * @category Database | |
22 | * @author ExpressionEngine Dev Team | |
23 | * @link http://codeigniter.com/user_guide/database/ | |
24 | * @param string | |
25 | * @param bool Determines if active record should be used or not | |
26 | */ | |
27 | function &DB($params = '', $active_record_override = NULL) | |
28 | { | |
29 | // Load the DB config file if a DSN string wasn't passed | |
30 | if (is_string($params) AND strpos($params, '://') === FALSE) | |
31 | { | |
32 | // Is the config file in the environment folder? | |
33 | if ( ! defined('ENVIRONMENT') OR ! file_exists($file_path = APPPATH.'config/'.ENVIRONMENT.'/database.php')) | |
34 | { | |
35 | if ( ! file_exists($file_path = APPPATH.'config/database.php')) | |
36 | { | |
37 | show_error('The configuration file database.php does not exist.'); | |
38 | } | |
39 | } | |
40 | ||
41 | include($file_path); | |
42 | ||
43 | if ( ! isset($db) OR count($db) == 0) | |
44 | { | |
45 | show_error('No database connection settings were found in the database config file.'); | |
46 | } | |
47 | ||
48 | if ($params != '') | |
49 | { | |
50 | $active_group = $params; | |
51 | } | |
52 | ||
53 | if ( ! isset($active_group) OR ! isset($db[$active_group])) | |
54 | { | |
55 | show_error('You have specified an invalid database connection group.'); | |
56 | } | |
57 | ||
58 | $params = $db[$active_group]; | |
59 | } | |
60 | elseif (is_string($params)) | |
61 | { | |
62 | ||
63 | /* parse the URL from the DSN string | |
64 | * Database settings can be passed as discreet | |
65 | * parameters or as a data source name in the first | |
66 | * parameter. DSNs must have this prototype: | |
67 | * $dsn = 'driver://username:password@hostname/database'; | |
68 | */ | |
69 | ||
70 | if (($dns = @parse_url($params)) === FALSE) | |
71 | { | |
72 | show_error('Invalid DB Connection String'); | |
73 | } | |
74 | ||
75 | $params = array( | |
76 | 'dbdriver' => $dns['scheme'], | |
77 | 'hostname' => (isset($dns['host'])) ? rawurldecode($dns['host']) : '', | |
78 | 'username' => (isset($dns['user'])) ? rawurldecode($dns['user']) : '', | |
79 | 'password' => (isset($dns['pass'])) ? rawurldecode($dns['pass']) : '', | |
80 | 'database' => (isset($dns['path'])) ? rawurldecode(substr($dns['path'], 1)) : '' | |
81 | ); | |
82 | ||
83 | // were additional config items set? | |
84 | if (isset($dns['query'])) | |
85 | { | |
86 | parse_str($dns['query'], $extra); | |
87 | ||
88 | foreach ($extra as $key => $val) | |
89 | { | |
90 | // booleans please | |
91 | if (strtoupper($val) == "TRUE") | |
92 | { | |
93 | $val = TRUE; | |
94 | } | |
95 | elseif (strtoupper($val) == "FALSE") | |
96 | { | |
97 | $val = FALSE; | |
98 | } | |
99 | ||
100 | $params[$key] = $val; | |
101 | } | |
102 | } | |
103 | } | |
104 | ||
105 | // No DB specified yet? Beat them senseless... | |
106 | if ( ! isset($params['dbdriver']) OR $params['dbdriver'] == '') | |
107 | { | |
108 | show_error('You have not selected a database type to connect to.'); | |
109 | } | |
110 | ||
111 | // Load the DB classes. Note: Since the active record class is optional | |
112 | // we need to dynamically create a class that extends proper parent class | |
113 | // based on whether we're using the active record class or not. | |
114 | // Kudos to Paul for discovering this clever use of eval() | |
115 | ||
116 | if ($active_record_override !== NULL) | |
117 | { | |
118 | $active_record = $active_record_override; | |
119 | } | |
120 | ||
121 | require_once(BASEPATH.'database/DB_driver.php'); | |
122 | ||
123 | if ( ! isset($active_record) OR $active_record == TRUE) | |
124 | { | |
125 | require_once(BASEPATH.'database/DB_active_rec.php'); | |
126 | ||
127 | if ( ! class_exists('CI_DB')) | |
128 | { | |
129 | eval('class CI_DB extends CI_DB_active_record { }'); | |
130 | } | |
131 | } | |
132 | else | |
133 | { | |
134 | if ( ! class_exists('CI_DB')) | |
135 | { | |
136 | eval('class CI_DB extends CI_DB_driver { }'); | |
137 | } | |
138 | } | |
139 | ||
140 | require_once(BASEPATH.'database/drivers/'.$params['dbdriver'].'/'.$params['dbdriver'].'_driver.php'); | |
141 | ||
142 | // Instantiate the DB adapter | |
143 | $driver = 'CI_DB_'.$params['dbdriver'].'_driver'; | |
144 | $DB = new $driver($params); | |
145 | ||
146 | if ($DB->autoinit == TRUE) | |
147 | { | |
148 | $DB->initialize(); | |
149 | } | |
150 | ||
151 | if (isset($params['stricton']) && $params['stricton'] == TRUE) | |
152 | { | |
153 | $DB->query('SET SESSION sql_mode="STRICT_ALL_TABLES"'); | |
154 | } | |
155 | ||
156 | return $DB; | |
157 | } | |
158 | ||
159 | ||
160 | ||
161 | /* End of file DB.php */ | |
162 | /* Location: ./system/database/DB.php */ |