4 # Backwards compatibility wrapper for Database.php
6 # I imagine this file will eventually become a backwards
7 # compatibility wrapper around a load balancer object, and
8 # the load balancer will finally call Database, which will
9 # represent a single connection
11 # Note: $wgDatabase has ceased to exist. Destroy all references.
13 # Usually aborts on failure
14 # If errors are explicitly ignored, returns success
15 function wfQuery( $sql, $db, $fname = "" )
18 if ( !is_numeric( $db ) ) {
19 # Someone has tried to call this the old way
20 $wgOut->fatalError( wfMsgNoDB( "wrong_wfQuery_params", $db, $sql ) );
24 return $c->query( $sql, $fname );
30 function wfSingleQuery( $sql, $db, $fname = "" )
32 $res = wfQuery($sql, $db, $fname );
33 $row = wfFetchRow( $res );
39 function &wfGetDB( $db = DB_LAST
)
41 global $wgLoadBalancer;
42 return $wgLoadBalancer->getConnection( $db );
45 # Turns buffering of SQL result sets on (true) or off (false). Default is
46 # "on" and it should not be changed without good reasons.
47 # Returns the previous state.
49 function wfBufferSQLResults( $newstate, $dbi = DB_LAST
)
51 $db =& wfGetDB( $dbi );
52 if ( $db !== false ) {
53 return $db->setBufferResults( $newstate );
59 # Turns on (false) or off (true) the automatic generation and sending
60 # of a "we're sorry, but there has been a database error" page on
61 # database errors. Default is on (false). When turned off, the
62 # code should use wfLastErrno() and wfLastError() to handle the
63 # situation as appropriate.
64 # Returns the previous state.
66 function wfIgnoreSQLErrors( $newstate, $dbi = DB_LAST
)
68 $db =& wfGetDB( $dbi );
69 if ( $db !== false ) {
70 return $db->setIgnoreErrors( $newstate );
76 function wfFreeResult( $res, $dbi = DB_LAST
)
78 $db =& wfGetDB( $dbi );
79 if ( $db !== false ) {
80 $db->freeResult( $res );
87 function wfFetchObject( $res, $dbi = DB_LAST
)
89 $db =& wfGetDB( $dbi );
90 if ( $db !== false ) {
91 return $db->fetchObject( $res, $dbi = DB_LAST
);
97 function wfFetchRow( $res, $dbi = DB_LAST
)
99 $db =& wfGetDB( $dbi );
100 if ( $db !== false ) {
101 return $db->fetchRow ( $res, $dbi = DB_LAST
);
107 function wfNumRows( $res, $dbi = DB_LAST
)
109 $db =& wfGetDB( $dbi );
110 if ( $db !== false ) {
111 return $db->numRows( $res, $dbi = DB_LAST
);
117 function wfNumFields( $res, $dbi = DB_LAST
)
119 $db =& wfGetDB( $dbi );
120 if ( $db !== false ) {
121 return $db->numFields( $res );
127 function wfFieldName( $res, $n, $dbi = DB_LAST
)
129 $db =& wfGetDB( $dbi );
130 if ( $db !== false ) {
131 return $db->fieldName( $res, $n, $dbi = DB_LAST
);
137 function wfInsertId( $dbi = DB_LAST
)
139 $db =& wfGetDB( $dbi );
140 if ( $db !== false ) {
141 return $db->insertId();
147 function wfDataSeek( $res, $row, $dbi = DB_LAST
)
149 $db =& wfGetDB( $dbi );
150 if ( $db !== false ) {
151 return $db->dataSeek( $res, $row );
157 function wfLastErrno( $dbi = DB_LAST
)
159 $db =& wfGetDB( $dbi );
160 if ( $db !== false ) {
161 return $db->lastErrno();
167 function wfLastError( $dbi = DB_LAST
)
169 $db =& wfGetDB( $dbi );
170 if ( $db !== false ) {
171 return $db->lastError();
177 function wfAffectedRows( $dbi = DB_LAST
)
179 $db =& wfGetDB( $dbi );
180 if ( $db !== false ) {
181 return $db->affectedRows();
187 function wfLastDBquery( $dbi = DB_LAST
)
189 $db =& wfGetDB( $dbi );
190 if ( $db !== false ) {
191 return $db->lastQuery();
197 function wfSetSQL( $table, $var, $value, $cond, $dbi = DB_WRITE
)
199 $db =& wfGetDB( $dbi );
200 if ( $db !== false ) {
201 return $db->set( $table, $var, $value, $cond );
207 function wfGetSQL( $table, $var, $cond="", $dbi = DB_LAST
)
209 $db =& wfGetDB( $dbi );
210 if ( $db !== false ) {
211 return $db->getField( $table, $var, $cond );
217 function wfFieldExists( $table, $field, $dbi = DB_LAST
)
219 $db =& wfGetDB( $dbi );
220 if ( $db !== false ) {
221 return $db->fieldExists( $table, $field );
227 function wfIndexExists( $table, $index, $dbi = DB_LAST
)
229 $db =& wfGetDB( $dbi );
230 if ( $db !== false ) {
231 return $db->indexExists( $table, $index );
237 function wfInsertArray( $table, $array, $fname = "wfInsertArray", $dbi = DB_WRITE
)
239 $db =& wfGetDB( $dbi );
240 if ( $db !== false ) {
241 return $db->insertArray( $table, $array, $fname );
247 function wfGetArray( $table, $vars, $conds, $fname = "wfGetArray", $dbi = DB_LAST
)
249 $db =& wfGetDB( $dbi );
250 if ( $db !== false ) {
251 return $db->getArray( $table, $vars, $conds, $fname );
257 function wfUpdateArray( $table, $values, $conds, $fname = "wfUpdateArray", $dbi = DB_WRITE
)
259 $db =& wfGetDB( $dbi );
260 if ( $db !== false ) {
261 $db->updateArray( $table, $values, $conds, $fname );
268 function wfTableName( $name, $dbi = DB_LAST
) {
269 $db =& wfGetDB( $dbi );
270 if ( $db !== false ) {
271 return $db->tableName( $name );
277 function wfStrencode( $s, $dbi = DB_LAST
)
279 $db =& wfGetDB( $dbi );
280 if ( $db !== false ) {
281 return $db->strencode( $s );
287 function wfNextSequenceValue( $seqName, $dbi = DB_WRITE
) {
288 $db =& wfGetDB( $dbi );
289 if ( $db !== false ) {
290 return $db->nextSequenceValue( $seqName );
296 function wfUseIndexClause( $index, $dbi = DB_READ
) {
297 $db =& wfGetDB( $dbi );
298 if ( $db !== false ) {
299 return $db->useIndexClause( $index );