56 $this->agent = $params[
'agent'] ??
'';
57 $this->deprecationLogger = $params[
'deprecationLogger'] ??
static function ( $msg ) {
58 trigger_error( $msg, E_USER_DEPRECATED );
60 $this->csProvider = $params[
'criticalSectionProvider'] ??
null;
61 $this->profiler = $params[
'profiler'] ??
null;
62 $this->tracer = $params[
'tracer'] ??
new NoopTracer();
63 $this->cliMode = $params[
'cliMode'] ?? ( PHP_SAPI ===
'cli' || PHP_SAPI ===
'phpdbg' );
64 $this->debugSql = $params[
'debugSql'] ??
false;
121 public function create( $type, $params = [], $connect = Database::NEW_CONNECTED ) {
122 $class = $this->
getClass( $type, $params[
'driver'] ??
null );
124 if ( class_exists( $class ) && is_subclass_of( $class, IDatabase::class ) ) {
135 'serverName' =>
null,
136 'topologyRole' =>
null,
140 'logger' => $params[
'logger'] ??
new NullLogger(),
141 'errorLogger' => $params[
'errorLogger'] ??
static function ( Throwable $e ) {
142 trigger_error( get_class( $e ) .
': ' . $e->getMessage(), E_USER_WARNING );
146 $params[
'flags'] ??= 0;
147 if ( $this->debugSql ) {
152 'flags' => $this->initConnectionFlags( $params[
'flags'] ),
153 'cliMode' => $this->cliMode,
154 'agent' => $this->agent,
155 'profiler' => $this->profiler,
156 'deprecationLogger' => $this->deprecationLogger,
157 'criticalSectionProvider' => $this->csProvider,
158 'tracer' => $this->tracer,
162 $conn =
new $class( array_merge( $params, $overrides ) );
163 if ( $connect === Database::NEW_CONNECTED ) {
164 $conn->initConnection();
200 protected function getClass( $dbType, $driver =
null ) {
207 static $builtinTypes = [
208 'mysql' => [
'mysqli' => DatabaseMySQL::class ],
209 'sqlite' => DatabaseSqlite::class,
210 'postgres' => DatabasePostgres::class,
213 $dbType = strtolower( $dbType );
215 if ( !isset( $builtinTypes[$dbType] ) ) {
217 return 'Database' . ucfirst( $dbType );
221 $possibleDrivers = $builtinTypes[$dbType];
222 if ( is_string( $possibleDrivers ) ) {
223 $class = $possibleDrivers;
224 } elseif ( (
string)$driver !==
'' ) {
225 if ( !isset( $possibleDrivers[$driver] ) ) {
226 throw new InvalidArgumentException( __METHOD__ .
227 " type '$dbType' does not support driver '{$driver}'" );
230 $class = $possibleDrivers[$driver];
232 foreach ( $possibleDrivers as $posDriver => $possibleClass ) {
233 if ( extension_loaded( $posDriver ) ) {
234 $class = $possibleClass;
240 if ( $class ===
false ) {
241 throw new InvalidArgumentException( __METHOD__ .
242 " no viable database extension found for type '$dbType'" );