55 if ( $p[
'tablePrefix'] ==
'get from global' ) {
58 $p[
'tablePrefix'] = strtoupper( $p[
'tablePrefix'] );
59 parent::__construct( $p );
60 Hooks::run(
'DatabaseOraclePostInit', [ $this ] );
64 if ( $this->opened ) {
65 Wikimedia\suppressWarnings();
67 Wikimedia\restoreWarnings();
94 if ( !function_exists(
'oci_connect' ) ) {
97 "Oracle functions missing, have you compiled PHP with the --with-oci8 option?\n " .
98 "(Note: if you recently installed PHP, you may need to restart your webserver\n " .
111 $this->dbName =
$user;
115 $this->dbName =
$user;
121 if ( !strlen(
$user ) ) { #
e.g. the
class is being loaded
131 Wikimedia\suppressWarnings();
133 $this->conn = oci_pconnect(
137 $this->defaultCharset,
141 $this->conn = oci_new_connect(
145 $this->defaultCharset,
149 $this->conn = oci_connect(
153 $this->defaultCharset,
157 Wikimedia\restoreWarnings();
159 if ( $this->
user != $this->dbName ) {
164 if ( !$this->conn ) {
168 $this->opened =
true;
170 # removed putenv calls because they interfere with the system globaly
171 $this->
doQuery(
'ALTER SESSION SET NLS_TIMESTAMP_FORMAT=\'DD-MM-YYYY HH24:MI:SS.FF6\'' );
172 $this->
doQuery(
'ALTER SESSION SET NLS_TIMESTAMP_TZ_FORMAT=\'DD-MM-YYYY HH24:MI:SS.FF6\'' );
173 $this->
doQuery(
'ALTER SESSION SET NLS_NUMERIC_CHARACTERS=\'.,\'' );
184 return oci_close( $this->conn );
188 return $this->
trxLevel ? OCI_NO_AUTO_COMMIT : OCI_COMMIT_ON_SUCCESS;
194 throw new InvalidArgumentException(
"SQL encoding is invalid\n$sql" );
200 $sql = preg_replace(
'/ as /i',
' ', $sql );
205 $union_unique = ( preg_match(
'/\/\* UNION_UNIQUE \*\/ /', $sql ) != 0 );
212 'EXPLAIN PLAN SET STATEMENT_ID = \'' . $explain_id .
'\' FOR
',
218 Wikimedia\suppressWarnings();
220 $this->mLastResult = $stmt = oci_parse( $this->conn, $sql );
221 if ( $stmt === false ) {
222 $e = oci_error( $this->conn );
223 $this->reportQueryError( $e['message'], $e['code'], $sql, __METHOD__ );
228 if ( !oci_execute( $stmt, $this->execFlags() ) ) {
229 $e = oci_error( $stmt );
230 if ( !$this->ignoreDupValOnIndex || $e['code'] != '1
' ) {
231 $this->reportQueryError( $e['message'], $e['code'], $sql, __METHOD__ );
237 Wikimedia\restoreWarnings();
239 if ( $explain_count > 0 ) {
240 return $this->doQuery( 'SELECT
id, cardinality
"ROWS" FROM plan_table
' .
241 'WHERE statement_id = \
'' . $explain_id .
'\'' );
242 } elseif ( oci_statement_type( $stmt ) ==
'SELECT' ) {
243 return new ORAResult( $this, $stmt, $union_unique );
245 $this->mAffectedRows = oci_num_rows( $stmt );
276 return $res->fetchObject();
288 return $res->fetchRow();
300 return $res->numRows();
312 return $res->numFields();
316 return oci_field_name( $stmt, $n );
320 $res = $this->
query(
"SELECT lastval_pkg.getLastval FROM dual" );
321 $row = $this->fetchRow(
$res );
322 return is_null( $row[0] ) ? null : (int)$row[0];
333 $res->result->seek( $row );
338 if ( $this->conn ===
false ) {
341 $e = oci_error( $this->conn );
344 return $e[
'message'];
348 if ( $this->conn ===
false ) {
351 $e = oci_error( $this->conn );
358 return $this->mAffectedRows;
378 if ( !
count( $a ) ) {
386 if ( in_array(
'IGNORE',
$options ) ) {
387 $this->ignoreDupValOnIndex =
true;
390 if ( !is_array( reset( $a ) ) ) {
394 foreach ( $a
as &$row ) {
395 $this->insertOneRow( $table, $row,
$fname );
399 if ( in_array(
'IGNORE',
$options ) ) {
400 $this->ignoreDupValOnIndex =
false;
407 $col_info = $this->fieldInfoMulti( $table, $col );
408 $col_type = $col_info !=
false ? $col_info->type() :
'CONSTANT';
411 if ( is_numeric( $col ) ) {
416 } elseif ( $includeCol ) {
420 if ( $val ==
'' && $val !== 0 && $col_type !=
'BLOB' && $col_type !=
'CLOB' ) {
424 if ( $val ===
'NULL' ) {
428 if ( $val ===
null ) {
429 if ( $col_info !=
false && $col_info->isNullable() == 0 && $col_info->defaultValue() != null ) {
453 $sql =
"INSERT INTO " . $table .
" (" . implode(
',', array_keys( $row ) ) .
')';
458 foreach ( $row
as $col => &$val ) {
464 if ( $this->isQuotedIdentifier( $val ) ) {
465 $sql .= $this->removeIdentifierQuotes( $val );
468 $sql .= $this->fieldBindStatement( $table, $col, $val );
473 $this->mLastResult = $stmt = oci_parse( $this->conn, $sql );
474 if ( $stmt ===
false ) {
475 $e = oci_error( $this->conn );
476 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
480 foreach ( $row
as $col => &$val ) {
481 $col_info = $this->fieldInfoMulti( $table, $col );
482 $col_type = $col_info !=
false ? $col_info->type() :
'CONSTANT';
484 if ( $val ===
null ) {
486 } elseif ( $col_type !=
'BLOB' && $col_type !=
'CLOB' ) {
487 if ( is_object( $val ) ) {
488 $val = $val->fetch();
492 if ( preg_match(
'/^timestamp.*/i', $col_type ) == 1 && strtolower( $val ) ==
'infinity' ) {
493 $val = $this->getInfinity();
497 if ( oci_bind_by_name( $stmt,
":$col", $val, -1, SQLT_CHR ) ===
false ) {
498 $e = oci_error( $stmt );
499 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
505 $lob[$col] = oci_new_descriptor( $this->conn, OCI_D_LOB );
506 if ( $lob[$col] ===
false ) {
507 $e = oci_error( $stmt );
511 if ( is_object( $val ) ) {
512 $val = $val->fetch();
515 if ( $col_type ==
'BLOB' ) {
516 $lob[$col]->writeTemporary( $val, OCI_TEMP_BLOB );
517 oci_bind_by_name( $stmt,
":$col", $lob[$col], -1, OCI_B_BLOB );
519 $lob[$col]->writeTemporary( $val, OCI_TEMP_CLOB );
520 oci_bind_by_name( $stmt,
":$col", $lob[$col], -1, OCI_B_CLOB );
525 Wikimedia\suppressWarnings();
527 if ( oci_execute( $stmt, $this->execFlags() ) ===
false ) {
528 $e = oci_error( $stmt );
529 if ( !$this->ignoreDupValOnIndex ||
$e[
'code'] !=
'1' ) {
530 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
534 $this->mAffectedRows = oci_num_rows( $stmt );
537 $this->mAffectedRows = oci_num_rows( $stmt );
540 Wikimedia\restoreWarnings();
542 if ( isset( $lob ) ) {
543 foreach ( $lob
as $lob_v ) {
548 if ( !$this->trxLevel ) {
549 oci_commit( $this->conn );
552 return oci_free_statement( $stmt );
556 $insertOptions = [], $selectOptions = [], $selectJoinConds = []
558 $destTable = $this->
tableName( $destTable );
560 $sequenceData = $this->getSequenceData( $destTable );
561 if ( $sequenceData !==
false &&
562 !isset( $varMap[$sequenceData[
'column']] )
564 $varMap[$sequenceData[
'column']] =
'GET_SEQUENCE_VALUE(\'' . $sequenceData[
'sequence'] .
'\')
';
567 // count-alias subselect fields to avoid abigious definition errors
569 foreach ( $varMap as &$val ) {
570 $val = $val . ' field
' . ( $i++ );
573 $selectSql = $this->selectSQLText(
575 array_values( $varMap ),
582 $sql = "INSERT INTO $destTable (" . implode( ',
', array_keys( $varMap ) ) . ')
' . $selectSql;
584 if ( in_array( 'IGNORE
', $insertOptions ) ) {
585 $this->ignoreDupValOnIndex = true;
588 $retval = $this->query( $sql, $fname );
590 if ( in_array( 'IGNORE
', $insertOptions ) ) {
591 $this->ignoreDupValOnIndex = false;
597 public function upsert( $table, array $rows, array $uniqueIndexes, array $set,
600 if ( !count( $rows ) ) {
601 return true; // nothing to do
604 if ( !is_array( reset( $rows ) ) ) {
608 $sequenceData = $this->getSequenceData( $table );
609 if ( $sequenceData !== false ) {
610 // add sequence column to each list of columns, when not set
611 foreach ( $rows as &$row ) {
612 if ( !isset( $row[$sequenceData['column
']] ) ) {
613 $row[$sequenceData['column
']] =
614 $this->addIdentifierQuotes( 'GET_SEQUENCE_VALUE(\
'' .
615 $sequenceData[
'sequence'] .
'\')
' );
620 return parent::upsert( $table, $rows, $uniqueIndexes, $set, $fname );
623 function tableName( $name, $format = 'quoted
' ) {
625 Replace reserved words with better ones
626 Using uppercase because that's the only
way Oracle can handle
634 $name =
'PAGECONTENT';
644 return preg_replace(
'/.*\.(.*)/',
'$1',
$name );
654 if ( $this->sequenceData ==
null ) {
655 $result = $this->doQuery(
"SELECT lower(asq.sequence_name),
656 lower(atc.table_name),
657 lower(atc.column_name)
658 FROM all_sequences asq, all_tab_columns atc
661 '{$this->tablePrefix}MWUSER',
662 '{$this->tablePrefix}USER',
665 atc.column_name || '_SEQ' = '{$this->tablePrefix}' || asq.sequence_name
666 AND asq.sequence_owner = upper('{$this->dbName}')
667 AND atc.owner = upper('{$this->dbName}')" );
669 while ( ( $row =
$result->fetchRow() ) !==
false ) {
670 $this->sequenceData[$row[1]] = [
671 'sequence' => $row[0],
676 $table = strtolower( $this->removeIdentifierQuotes( $this->
tableName( $table ) ) );
678 return ( isset( $this->sequenceData[$table] ) ) ? $this->sequenceData[$table] :
false;
689 $fieldInfoData = $this->fieldInfo( $table, $field );
691 return $fieldInfoData->maxLength();
695 if ( $offset ===
false ) {
699 return "SELECT * FROM ($sql) WHERE rownum >= (1 + $offset) AND rownum < (1 + $limit + $offset)";
703 return new Blob( $b );
707 if ( $b instanceof
Blob ) {
715 $glue =
' UNION ALL ';
717 return 'SELECT * ' . ( $all ?
'' :
'/* UNION_UNIQUE */ ' ) .
718 'FROM (' . implode( $glue, $sqls ) .
')';
722 return $this->lastErrno() ==
'OCI-00060';
728 $temporary = $temporary ?
'TRUE' :
'FALSE';
730 $newName = strtoupper( $newName );
731 $oldName = strtoupper( $oldName );
733 $tabName = substr( $newName, strlen( $this->tablePrefix ) );
734 $oldPrefix = substr( $oldName, 0, strlen( $oldName ) - strlen( $tabName ) );
735 $newPrefix = strtoupper( $this->tablePrefix );
737 return $this->doQuery(
"BEGIN DUPLICATE_TABLE( '$tabName', " .
738 "'$oldPrefix', '$newPrefix', $temporary ); END;" );
743 if ( !empty( $prefix ) ) {
744 $listWhere =
' AND table_name LIKE \'' . strtoupper( $prefix ) .
'%\'';
747 $owner = strtoupper( $this->dbName );
748 $result = $this->doQuery(
"SELECT table_name FROM all_tables " .
749 "WHERE owner='$owner' AND table_name NOT LIKE '%!_IDX\$_' ESCAPE '!' $listWhere" );
753 $endArray[] = strtoupper( $prefix .
'MWUSER' );
754 $endArray[] = strtoupper( $prefix .
'PAGE' );
755 $endArray[] = strtoupper( $prefix .
'IMAGE' );
756 $fixedOrderTabs = $endArray;
757 while ( ( $row =
$result->fetchRow() ) !==
false ) {
758 if ( !in_array( $row[
'table_name'], $fixedOrderTabs ) ) {
759 $endArray[] = $row[
'table_name'];
766 public function dropTable( $tableName, $fName = __METHOD__ ) {
767 $tableName = $this->
tableName( $tableName );
768 if ( !$this->tableExists( $tableName ) ) {
772 return $this->doQuery(
"DROP TABLE $tableName CASCADE CONSTRAINTS PURGE" );
794 return '[{{int:version-db-oracle-url}} Oracle]';
802 $rset = $this->doQuery(
803 'SELECT version FROM product_component_version ' .
804 'WHERE UPPER(product) LIKE \'ORACLE DATABASE%\''
806 $row = $rset->fetchRow();
808 return oci_server_version( $this->conn );
811 return $row[
'version'];
823 $table = strtoupper( $this->removeIdentifierQuotes( $table ) );
824 $index = strtoupper( $index );
825 $owner = strtoupper( $this->dbName );
826 $sql =
"SELECT 1 FROM all_indexes WHERE owner='$owner' AND index_name='{$table}_{$index}'";
827 $res = $this->doQuery( $sql );
829 $count =
$res->numRows();
846 $table = $this->addQuotes( strtoupper( $this->removeIdentifierQuotes( $table ) ) );
847 $owner = $this->addQuotes( strtoupper( $this->dbName ) );
848 $sql =
"SELECT 1 FROM all_tables WHERE owner=$owner AND table_name=$table";
849 $res = $this->doQuery( $sql );
850 if (
$res &&
$res->numRows() > 0 ) {
872 $field = strtoupper( $field );
873 if ( is_array( $table ) ) {
874 $table = array_map( [ $this,
'tableNameInternal' ], $table );
875 $tableWhere =
'IN (';
876 foreach ( $table
as &$singleTable ) {
877 $singleTable = $this->removeIdentifierQuotes( $singleTable );
878 if ( isset( $this->mFieldInfoCache[
"$singleTable.$field"] ) ) {
879 return $this->mFieldInfoCache[
"$singleTable.$field"];
881 $tableWhere .=
'\'' . $singleTable .
'\',
';
883 $tableWhere = rtrim( $tableWhere, ',
' ) . ')
';
885 $table = $this->removeIdentifierQuotes( $this->tableNameInternal( $table ) );
886 if ( isset( $this->mFieldInfoCache["$table.$field"] ) ) {
887 return $this->mFieldInfoCache["$table.$field"];
889 $tableWhere = '= \
'' . $table .
'\'';
892 $fieldInfoStmt = oci_parse(
894 'SELECT * FROM wiki_field_info_full WHERE table_name ' .
895 $tableWhere .
' and column_name = \'' . $field .
'\''
897 if ( oci_execute( $fieldInfoStmt, $this->execFlags() ) ===
false ) {
898 $e = oci_error( $fieldInfoStmt );
899 $this->reportQueryError(
$e[
'message'],
$e[
'code'],
'fieldInfo QUERY', __METHOD__ );
904 if (
$res->numRows() == 0 ) {
905 if ( is_array( $table ) ) {
906 foreach ( $table
as &$singleTable ) {
907 $this->mFieldInfoCache[
"$singleTable.$field"] =
false;
910 $this->mFieldInfoCache[
"$table.$field"] =
false;
912 $fieldInfoTemp =
null;
916 $this->mFieldInfoCache[
"$table.$field"] = $fieldInfoTemp;
920 return $fieldInfoTemp;
930 if ( is_array( $table ) ) {
931 throw new DBUnexpectedError( $this,
'DatabaseOracle::fieldInfo called with table array!' );
934 return $this->fieldInfoMulti( $table, $field );
939 $this->doQuery(
'SET CONSTRAINTS ALL DEFERRED' );
943 if ( $this->trxLevel ) {
944 $ret = oci_commit( $this->conn );
949 $this->doQuery(
'SET CONSTRAINTS ALL IMMEDIATE' );
954 if ( $this->trxLevel ) {
955 oci_rollback( $this->conn );
957 $this->doQuery(
'SET CONSTRAINTS ALL IMMEDIATE' );
963 callable $lineCallback =
null,
964 callable $resultCallback =
null,
965 $fname = __METHOD__, callable $inputCallback =
null
969 $dollarquote =
false;
973 while ( !feof( $fp ) ) {
974 if ( $lineCallback ) {
975 call_user_func( $lineCallback );
977 $line = trim( fgets( $fp, 1024 ) );
978 $sl = strlen(
$line ) - 1;
988 if ( substr(
$line, 0, 8 ) ==
'/*$mw$*/' ) {
989 if ( $dollarquote ) {
990 $dollarquote =
false;
996 } elseif ( !$dollarquote ) {
997 if (
';' ==
$line[$sl] && ( $sl < 2 ||
';' !=
$line[$sl - 1] ) ) {
1009 $cmd = str_replace(
';;',
";", $cmd );
1010 if ( strtolower( substr( $cmd, 0, 6 ) ) ==
'define' ) {
1011 if ( preg_match(
'/^define\s*([^\s=]*)\s*=\s*\'\{\$([^\}]*)\}\'/', $cmd, $defines ) ) {
1012 $replacements[$defines[2]] = $defines[1];
1015 foreach ( $replacements
as $mwVar => $scVar ) {
1016 $cmd = str_replace(
'&' . $scVar .
'.',
'`{$' . $mwVar .
'}`', $cmd );
1019 $cmd = $this->replaceVars( $cmd );
1020 if ( $inputCallback ) {
1021 call_user_func( $inputCallback, $cmd );
1023 $res = $this->doQuery( $cmd );
1024 if ( $resultCallback ) {
1025 call_user_func( $resultCallback,
$res, $this );
1028 if (
false ===
$res ) {
1029 $err = $this->lastError();
1031 return "Query \"{$cmd}\" failed with error code \"$err\".\n";
1044 $this->dbName = $db;
1045 if ( $db ==
null || $db == $this->
user ) {
1048 $sql =
'ALTER SESSION SET CURRENT_SCHEMA=' . strtoupper( $db );
1049 $stmt = oci_parse( $this->conn, $sql );
1050 Wikimedia\suppressWarnings();
1052 Wikimedia\restoreWarnings();
1054 $e = oci_error( $stmt );
1055 if (
$e[
'code'] !=
'1435' ) {
1056 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
1066 return str_replace(
"'",
"''",
$s );
1075 return "'" . $this->strencode(
$s ) .
"'";
1087 return strpos(
$s,
'/*Q*/' ) ===
false ?
$s : substr(
$s, 5 );
1091 return strpos(
$s,
'/*Q*/' ) !==
false;
1097 $col_info = $this->fieldInfoMulti( $table, $col );
1098 $col_type = $col_info !=
false ? $col_info->type() :
'CONSTANT';
1099 if ( $col_type ==
'CLOB' ) {
1100 $col =
'TO_CHAR(' . $col .
')';
1102 } elseif ( $col_type ==
'VARCHAR2' ) {
1109 foreach ( $conds
as $col => $val ) {
1110 if ( is_array( $val ) ) {
1111 $conds2[$col] = $this->wrapConditionsForWhere( $table, $val, $col );
1113 if ( is_numeric( $col ) && $parentCol !=
null ) {
1114 $this->wrapFieldForWhere( $table, $parentCol, $val );
1116 $this->wrapFieldForWhere( $table, $col, $val );
1118 $conds2[$col] = $val;
1128 if ( is_array( $conds ) ) {
1129 $conds = $this->wrapConditionsForWhere( $table, $conds );
1144 $preLimitTail = $postLimitTail =
'';
1149 if ( is_numeric( $key ) ) {
1150 $noKeyOptions[$option] =
true;
1154 $preLimitTail .= $this->makeGroupByWithHaving(
$options );
1156 $preLimitTail .= $this->makeOrderBy(
$options );
1158 if ( isset( $noKeyOptions[
'FOR UPDATE'] ) ) {
1159 $postLimitTail .=
' FOR UPDATE';
1162 if ( isset( $noKeyOptions[
'DISTINCT'] ) || isset( $noKeyOptions[
'DISTINCTROW'] ) ) {
1163 $startOpts .=
'DISTINCT';
1166 if ( isset(
$options[
'USE INDEX'] ) && !is_array(
$options[
'USE INDEX'] ) ) {
1167 $useIndex = $this->useIndexClause(
$options[
'USE INDEX'] );
1172 if ( isset(
$options[
'IGNORE INDEX'] ) && !is_array(
$options[
'IGNORE INDEX'] ) ) {
1173 $ignoreIndex = $this->ignoreIndexClause(
$options[
'IGNORE INDEX'] );
1178 return [ $startOpts, $useIndex, $preLimitTail, $postLimitTail, $ignoreIndex ];
1181 public function delete( $table, $conds,
$fname = __METHOD__ ) {
1184 if ( is_array( $conds ) ) {
1185 $conds = $this->wrapConditionsForWhere( $table, $conds );
1192 $this->update(
'archive', [
'ar_user' => 0 ],
1193 [
'ar_user' => $conds[
'user_id'] ],
$fname );
1194 $this->update(
'ipblocks', [
'ipb_user' => 0 ],
1195 [
'ipb_user' => $conds[
'user_id'] ],
$fname );
1196 $this->update(
'image', [
'img_user' => 0 ],
1197 [
'img_user' => $conds[
'user_id'] ],
$fname );
1198 $this->update(
'oldimage', [
'oi_user' => 0 ],
1199 [
'oi_user' => $conds[
'user_id'] ],
$fname );
1200 $this->update(
'filearchive', [
'fa_deleted_user' => 0 ],
1201 [
'fa_deleted_user' => $conds[
'user_id'] ],
$fname );
1202 $this->update(
'filearchive', [
'fa_user' => 0 ],
1203 [
'fa_user' => $conds[
'user_id'] ],
$fname );
1204 $this->update(
'uploadstash', [
'us_user' => 0 ],
1205 [
'us_user' => $conds[
'user_id'] ],
$fname );
1206 $this->update(
'recentchanges', [
'rc_user' => 0 ],
1207 [
'rc_user' => $conds[
'user_id'] ],
$fname );
1208 $this->update(
'logging', [
'log_user' => 0 ],
1209 [
'log_user' => $conds[
'user_id'] ],
$fname );
1210 } elseif ( $table == $this->
tableName(
'image' ) ) {
1211 $this->update(
'oldimage', [
'oi_name' => 0 ],
1212 [
'oi_name' => $conds[
'img_name'] ],
$fname );
1215 return parent::delete( $table, $conds,
$fname );
1231 $opts = $this->makeUpdateOptions(
$options );
1232 $sql =
"UPDATE $opts $table SET ";
1235 foreach ( $values
as $col => &$val ) {
1236 $sqlSet = $this->fieldBindStatement( $table, $col, $val,
true );
1239 $sqlSet =
', ' . $sqlSet;
1246 if ( $conds !== [] && $conds !==
'*' ) {
1247 $conds = $this->wrapConditionsForWhere( $table, $conds );
1248 $sql .=
' WHERE ' . $this->makeList( $conds,
LIST_AND );
1251 $this->mLastResult = $stmt = oci_parse( $this->conn, $sql );
1252 if ( $stmt ===
false ) {
1253 $e = oci_error( $this->conn );
1254 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
1258 foreach ( $values
as $col => &$val ) {
1259 $col_info = $this->fieldInfoMulti( $table, $col );
1260 $col_type = $col_info !=
false ? $col_info->type() :
'CONSTANT';
1262 if ( $val ===
null ) {
1264 } elseif ( $col_type !=
'BLOB' && $col_type !=
'CLOB' ) {
1265 if ( is_object( $val ) ) {
1266 $val = $val->getData();
1269 if ( preg_match(
'/^timestamp.*/i', $col_type ) == 1 && strtolower( $val ) ==
'infinity' ) {
1270 $val =
'31-12-2030 12:00:00.000000';
1274 if ( oci_bind_by_name( $stmt,
":$col", $val ) ===
false ) {
1275 $e = oci_error( $stmt );
1276 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
1282 $lob[$col] = oci_new_descriptor( $this->conn, OCI_D_LOB );
1283 if ( $lob[$col] ===
false ) {
1284 $e = oci_error( $stmt );
1288 if ( is_object( $val ) ) {
1289 $val = $val->getData();
1292 if ( $col_type ==
'BLOB' ) {
1293 $lob[$col]->writeTemporary( $val );
1294 oci_bind_by_name( $stmt,
":$col", $lob[$col], -1, SQLT_BLOB );
1296 $lob[$col]->writeTemporary( $val );
1297 oci_bind_by_name( $stmt,
":$col", $lob[$col], -1, OCI_B_CLOB );
1302 Wikimedia\suppressWarnings();
1304 if ( oci_execute( $stmt, $this->execFlags() ) ===
false ) {
1305 $e = oci_error( $stmt );
1306 if ( !$this->ignoreDupValOnIndex ||
$e[
'code'] !=
'1' ) {
1307 $this->reportQueryError(
$e[
'message'],
$e[
'code'], $sql, __METHOD__ );
1311 $this->mAffectedRows = oci_num_rows( $stmt );
1314 $this->mAffectedRows = oci_num_rows( $stmt );
1317 Wikimedia\restoreWarnings();
1319 if ( isset( $lob ) ) {
1320 foreach ( $lob
as $lob_v ) {
1325 if ( !$this->trxLevel ) {
1326 oci_commit( $this->conn );
1329 return oci_free_statement( $stmt );
1334 return 'BITNOT(' . $field .
')';
1338 return 'BITAND(' . $fieldLeft .
', ' . $fieldRight .
')';
1341 function bitOr( $fieldLeft, $fieldRight ) {
1342 return 'BITOR(' . $fieldLeft .
', ' . $fieldRight .
')';
1346 return $this->dbName;
1350 return $this->server;
1354 $delim, $table, $field, $conds =
'', $join_conds = []
1356 $fld =
"LISTAGG($field," . $this->addQuotes( $delim ) .
") WITHIN GROUP (ORDER BY $field)";
1358 return '(' . $this->selectSQLText( $table, $fld, $conds,
null, [], $join_conds ) .
')';
1362 $this->assertBuildSubstringParams( $startPosition, $length );
1364 if ( $length !==
null ) {
1367 return 'SUBSTR(' . implode(
',',
$params ) .
')';
1376 return 'CAST ( ' . $field .
' AS VARCHAR2 )';
1380 return '31-12-2030 12:00:00.000000';