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.
16 if ($wgDBtype=="mysql") {
17 require_once( "Database.php" );
19 } elseif ($wgDBtype=="pgsql") {
20 require_once( "DatabasePostgreSQL.php" );
25 # Usually aborts on failure
26 # If errors are explicitly ignored, returns success
27 function wfQuery( $sql, $db, $fname = "" )
30 if ( !is_numeric( $db ) ) {
31 # Someone has tried to call this the old way
32 $wgOut->fatalError( wfMsgNoDB( "wrong_wfQuery_params", $db, $sql ) );
36 return $c->query( $sql, $fname );
42 function &wfGetDB( $db = DB_LAST
)
44 global $wgLoadBalancer;
45 return $wgLoadBalancer->getConnection( $db );
48 # Turns buffering of SQL result sets on (true) or off (false). Default is
49 # "on" and it should not be changed without good reasons.
50 # Returns the previous state.
52 function wfBufferSQLResults( $newstate, $dbi = DB_LAST
)
54 $db =& wfGetDB( $dbi );
55 if ( $db !== false ) {
56 return $db->setBufferResults( $newstate );
62 # Turns on (false) or off (true) the automatic generation and sending
63 # of a "we're sorry, but there has been a database error" page on
64 # database errors. Default is on (false). When turned off, the
65 # code should use wfLastErrno() and wfLastError() to handle the
66 # situation as appropriate.
67 # Returns the previous state.
69 function wfIgnoreSQLErrors( $newstate, $dbi = DB_LAST
)
71 $db =& wfGetDB( $dbi );
72 if ( $db !== false ) {
73 return $db->setIgnoreErrors( $newstate );
79 function wfFreeResult( $res, $dbi = DB_LAST
)
81 $db =& wfGetDB( $dbi );
82 if ( $db !== false ) {
83 $db->freeResult( $res );
90 function wfFetchObject( $res, $dbi = DB_LAST
)
92 $db =& wfGetDB( $dbi );
93 if ( $db !== false ) {
94 return $db->fetchObject( $res, $dbi = DB_LAST
);
100 function wfFetchRow( $res, $dbi = DB_LAST
)
102 $db =& wfGetDB( $dbi );
103 if ( $db !== false ) {
104 return $db->fetchRow ( $res, $dbi = DB_LAST
);
110 function wfNumRows( $res, $dbi = DB_LAST
)
112 $db =& wfGetDB( $dbi );
113 if ( $db !== false ) {
114 return $db->numRows( $res, $dbi = DB_LAST
);
120 function wfNumFields( $res, $dbi = DB_LAST
)
122 $db =& wfGetDB( $dbi );
123 if ( $db !== false ) {
124 return $db->numFields( $res );
130 function wfFieldName( $res, $n, $dbi = DB_LAST
)
132 $db =& wfGetDB( $dbi );
133 if ( $db !== false ) {
134 return $db->fieldName( $res, $n, $dbi = DB_LAST
);
140 function wfInsertId( $dbi = DB_LAST
)
142 $db =& wfGetDB( $dbi );
143 if ( $db !== false ) {
144 return $db->insertId();
150 function wfDataSeek( $res, $row, $dbi = DB_LAST
)
152 $db =& wfGetDB( $dbi );
153 if ( $db !== false ) {
154 return $db->dataSeek( $res, $row );
160 function wfLastErrno( $dbi = DB_LAST
)
162 $db =& wfGetDB( $dbi );
163 if ( $db !== false ) {
164 return $db->lastErrno();
170 function wfLastError( $dbi = DB_LAST
)
172 $db =& wfGetDB( $dbi );
173 if ( $db !== false ) {
174 return $db->lastError();
180 function wfAffectedRows( $dbi = DB_LAST
)
182 $db =& wfGetDB( $dbi );
183 if ( $db !== false ) {
184 return $db->affectedRows();
190 function wfLastDBquery( $dbi = DB_LAST
)
192 $db =& wfGetDB( $dbi );
193 if ( $db !== false ) {
194 return $db->lastQuery();
200 function wfSetSQL( $table, $var, $value, $cond, $dbi = DB_WRITE
)
202 $db =& wfGetDB( $dbi );
203 if ( $db !== false ) {
204 return $db->set( $table, $var, $value, $cond );
210 function wfGetSQL( $table, $var, $cond="", $dbi = DB_LAST
)
212 $db =& wfGetDB( $dbi );
213 if ( $db !== false ) {
214 return $db->get( $table, $var, $cond );
220 function wfFieldExists( $table, $field, $dbi = DB_LAST
)
222 $db =& wfGetDB( $dbi );
223 if ( $db !== false ) {
224 return $db->fieldExists( $table, $field );
230 function wfIndexExists( $table, $index, $dbi = DB_LAST
)
232 $db =& wfGetDB( $dbi );
233 if ( $db !== false ) {
234 return $db->indexExists( $table, $index );
240 function wfInsertArray( $table, $array, $fname = "wfInsertArray", $dbi = DB_WRITE
)
242 $db =& wfGetDB( $dbi );
243 if ( $db !== false ) {
244 return $db->insertArray( $table, $array, $fname );
250 function wfGetArray( $table, $vars, $conds, $fname = "wfGetArray", $dbi = DB_LAST
)
252 $db =& wfGetDB( $dbi );
253 if ( $db !== false ) {
254 return $db->getArray( $table, $vars, $conds, $fname );
260 function wfUpdateArray( $table, $values, $conds, $fname = "wfUpdateArray", $dbi = DB_WRITE
)
262 $db =& wfGetDB( $dbi );
263 if ( $db !== false ) {
264 $db->updateArray( $table, $values, $conds, $fname );