sqlite/trunk/nucleus/sqlite/sqlite.php

   1 <?php\r
   2     /****************************************\r
   3     * SQLite-MySQL wrapper for Nucleus      *\r
   4     *                           ver 0.9.0.5 *\r
   5     * Written by Katsumi                    *\r
   6     ****************************************/\r
   7 \r
   8 // Check SQLite installed\r
   9 \r
  10 if (!function_exists('sqlite_open')) exit('Sorry, SQLite is not available from PHP (maybe, not installed in the server).');\r
  11 \r
  12 // Initializiation stuff\r
  13 require_once dirname(__FILE__) . '/sqliteconfig.php';\r
  14 $SQLITE_DBHANDLE=sqlite_open($SQLITECONF['DBFILENAME']);\r
  15 require_once dirname(__FILE__) . '/sqlitequeryfunctions.php';\r
  16 $SQLITECONF['VERSION']='0.9.0.5';\r
  17 \r
  18 //Following thing may work if MySQL is NOT installed in server.\r
  19 if (!function_exists('mysql_query')) {\r
  20         define ("MYSQL_ASSOC", SQLITE_ASSOC);\r
  21         define ("MYSQL_BOTH", SQLITE_BOTH);\r
  22         define ("MYSQL_NUM", SQLITE_NUM);\r
  23         function mysql_connect(){\r
  24                 global $SQLITECONF;\r
  25                 $SQLITECONF['OVERRIDEMODE']=true;\r
  26                 $args=func_get_args();\r
  27                 return call_user_func_array('nucleus_mysql_connect',$args);\r
  28         }\r
  29         foreach (array('mysql_affected_rows','mysql_change_user','mysql_client_encoding','mysql_close',\r
  30                 'mysql_create_db','mysql_data_seek','mysql_db_name','mysql_db_query','mysql_drop_db','mysql_errno',\r
  31                 'mysql_error','mysql_escape_string','mysql_fetch_array','mysql_fetch_assoc','mysql_fetch_field','mysql_fetch_lengths',\r
  32                 'mysql_fetch_object','mysql_fetch_row','mysql_field_flags','mysql_field_len','mysql_field_name','mysql_field_seek',\r
  33                 'mysql_field_table','mysql_field_type','mysql_free_result','mysql_get_client_info','mysql_get_host_info',\r
  34                 'mysql_get_proto_info','mysql_get_server_info','mysql_info','mysql_insert_id','mysql_list_dbs',\r
  35                 'mysql_list_fields','mysql_list_processes','mysql_list_tables','mysql_num_fields','mysql_num_rows','mysql_numrows',\r
  36                 'mysql_pconnect','mysql_ping','mysql_query','mysql_real_escape_string','mysql_result','mysql_select_db',\r
  37                 'mysql_stat','mysql_tablename','mysql_thread_id','mysql_unbuffered_query')\r
  38                  as $value) eval(\r
  39                 "function $value(){\n".\r
  40                 "  \$args=func_get_args();\n".\r
  41                 "  return call_user_func_array('nucleus_$value',\$args);\n".\r
  42                 "}\n");\r
  43 }\r
  44 \r
  45 // Empty object for mysql_fetch_object().\r
  46 class SQLITE_OBJECT {}\r
  47 \r
  48 function sqlite_ReturnWithError($text='Not supported',$more=''){\r
  49         // Show warning when error_reporting() is set.\r
  50         if (!(error_reporting() & E_WARNING)) return false;\r
  51         \r
  52         // Seek the file and line that originally called sql function.\r
  53         $a=debug_backtrace();\r
  54         foreach($a as $key=>$btrace) {\r
  55                 if (!($templine=$btrace['line'])) continue;\r
  56                 if (!($tempfile=$btrace['file'])) continue;\r
  57                 $file=str_replace('\\','/',$file);\r
  58                 if (!$line && !$file && strpos($tempfile,'/sqlite.php')===false && strpos($tempfile,'/sqlitequeryfunctions.php')===false) {\r
  59                         $line=$templine;\r
  60                         $file=$tempfile;\r
  61                 }\r
  62                 echo "\n<!--$tempfile line:$templine-->\n";\r
  63         }\r
  64         echo "Warning from SQLite-MySQL wrapper: $text<br />\n";\r
  65         if ($line && $file) echo "in <b>$file</b> on line <b>$line</b><br />\n";\r
  66         echo $more;\r
  67         return false;\r
  68 }\r
  69 function sqlite_DebugMessage($text=''){\r
  70         global $SQLITECONF;\r
  71         if (!$SQLITECONF['DEBUGREPORT']) return;\r
  72         if ($text) $SQLITECONF['DEBUGMESSAGE'].="\n".$text."\n";\r
  73         if (headers_sent()) {\r
  74                 echo '<!--sqlite_DebugMessage'.$SQLITECONF['DEBUGMESSAGE'].'sqlite_DebugMessage-->';\r
  75                 unset($SQLITECONF['DEBUGMESSAGE']);\r
  76         }\r
  77 }\r
  78 \r
  79 // nucleus_mysql_XXXX() functions follow.\r
  80 \r
  81 function nucleus_mysql_connect($p1=null,$p2=null,$p3=null,$p4=null,$p5=null){\r
  82         // All prameters are ignored.\r
  83         global $SQLITE_DBHANDLE,$SQLITECONF;\r
  84         if (!$SQLITE_DBHANDLE) $SQLITE_DBHANDLE=sqlite_open($SQLITECONF['DBFILENAME']);\r
  85         // Initialization queries.\r
  86         foreach($SQLITECONF['INITIALIZE'] as $value) nucleus_mysql_query($value);\r
  87         // Unregister the function 'php' in sql query.\r
  88         sqlite_create_function($SQLITE_DBHANDLE,'php','pi');\r
  89         return $SQLITE_DBHANDLE;\r
  90 }\r
  91 \r
  92 function nucleus_mysql_close($p1=null){\r
  93         global $SQLITE_DBHANDLE;\r
  94         if (!($dbhandle=$p1)) $dbhandle=$SQLITE_DBHANDLE;\r
  95         $SQLITE_DBHANDLE='';\r
  96         return sqlite_close ($dbhandle);\r
  97 }\r
  98 \r
  99 function nucleus_mysql_select_db($p1,$p2=null){\r
 100         // SQLite does not support multiple databases in a file.\r
 101         // So this function do nothing and always returns true.\r
 102         // Note: mysql_select_db() function returns true/false,\r
 103         // not link-ID.\r
 104         return true;\r
 105 }\r
 106 \r
 107 function nucleus_mysql_query($p1,$p2=null,$unbuffered=false){//echo htmlspecialchars($p1)."<br />\n";\r
 108         global $SQLITE_DBHANDLE,$SQLITECONF;\r
 109         if (!($dbhandle=$p2)) $dbhandle=$SQLITE_DBHANDLE;\r
 110         $query=trim($p1);\r
 111         if (strpos($query,"\xEF\xBB\xBF")===0) $query=substr($query,3);// UTF-8 stuff\r
 112         if (substr($query,-1)==';') $query=substr($query,0,strlen($query)-1);\r
 113         \r
 114         // Remove MySQL specific comment, '-- '.\r
 115         $query=preg_replace('/($|[\r\n])\-\-[\s^\r\n]([^\r\n]*)/','',$query);\r
 116         \r
 117         // Escape style is changed from MySQL type to SQLite type here.\r
 118         // This is important to avoid possible SQL-injection.\r
 119         $strpositions=array();// contains the data show where the strings are (startposition => endposition)\r
 120         if (strpos($query,'`')!==false || strpos($query,'"')!==false || strpos($query,"'")!==false)\r
 121                 $strpositions=sqlite_changeQuote($query);\r
 122         //echo "<br />".htmlspecialchars($p1)."<br /><br />\n".htmlspecialchars($query)."<hr />\n";\r
 123 \r
 124         // Debug mode\r
 125         if ($SQLITECONF['DEBUGMODE']) $query=sqlite_mysql_query_debug($query);\r
 126         \r
 127         // Anyway try it.\r
 128         if ($unbuffered) {\r
 129                 if ($ret=@sqlite_unbuffered_query($dbhandle,$query)) return $ret;\r
 130         } else {\r
 131                 if ($ret=@sqlite_query($dbhandle,$query)) return $ret;\r
 132         }\r
 133         \r
 134         // Error occured. Query must be translated.\r
 135         return sqlite_mysql_query_sub($dbhandle,$query,$strpositions,$p1,$unbuffered);\r
 136 }\r
 137 function sqlite_mysql_query_sub($dbhandle,$query,$strpositions=array(),$p1=null,$unbuffered=false){//echo htmlspecialchars($p1)."<br />\n";\r
 138         // Query translation is needed, especially when changing the data in database.\r
 139         // So far, this routine is written for 'CREATE TABLE','DROP TABLE', 'INSERT INTO',\r
 140         // 'SHOW TABLES LIKE', 'SHOW KEYS FROM', 'SHOW INDEX FROM'\r
 141         // and several functions used in query.\r
 142         // How about 'UPDATE' ???\r
 143         global $SQLITE_DBHANDLE,$SQLITECONF;\r
 144         $beforetrans=time()+microtime();\r
 145         if (!$p1) $p1=$query;\r
 146         $morequeries=array();\r
 147         $temptable=false;\r
 148         $uquery=strtoupper($query);\r
 149         if (strpos($uquery,'CREATE TABLE')===0 || ($temptable=(strpos($uquery,'CREATE TEMPORARY TABLE')===0))) {\r
 150                 if (!($i=strpos($query,'('))) return sqlite_ReturnWithError('nucleus_mysql_query: '.$p1);\r
 151                 //check if the command is 'CREATE TABLE IF NOT EXISTS'\r
 152                 if (strpos(strtoupper($uquery),'CREATE TABLE IF NOT EXISTS')===0) {\r
 153                         $tablename=trim(substr($query,26,$i-26));\r
 154                         if (substr($tablename,0,1)!="'") $tablename="'$tablename'";\r
 155                         $res=sqlite_query($dbhandle,"SELECT tbl_name FROM sqlite_master WHERE tbl_name=$tablename LIMIT 1");\r
 156                         if (nucleus_mysql_num_rows($res)) return true;\r
 157                 } else {\r
 158                         $tablename=trim(substr($query,12,$i-12));\r
 159                         if (substr($tablename,0,1)!="'") $tablename="'$tablename'";\r
 160                 }\r
 161                 $query=trim(substr($query,$i+1));\r
 162                 for ($i=strlen($query);0<$i;$i--) if ($query[$i]==')') break;\r
 163                 $query=substr($query,0,$i);\r
 164                 $commands=_sqlite_divideByChar(',',$query);\r
 165                 require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 166                 $query=sqlite_createtable_query($commands,$tablename,$temptable,$morequeries);\r
 167         } else if (strpos($uquery,'DROP TABLE IF EXISTS')===0) {\r
 168                 if (!($i=strpos($query,';'))) $i=strlen($query);\r
 169                 $tablename=trim(substr($query,20,$i-20));\r
 170                 if (substr($tablename,0,1)!="'") $tablename="'$tablename'";\r
 171                 $res=sqlite_query($dbhandle,"SELECT tbl_name FROM sqlite_master WHERE tbl_name=$tablename LIMIT 1");\r
 172                 if (!nucleus_mysql_num_rows($res)) return true;\r
 173                 $query='DROP TABLE '.$tablename;\r
 174         } else if (strpos($uquery,'ALTER TABLE ')===0) {\r
 175                 $query=trim(substr($query,11));\r
 176                 if ($i=strpos($query,' ')) {\r
 177                         $tablename=trim(substr($query,0,$i));\r
 178                         $query=trim(substr($query,$i));\r
 179                         require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 180                         $ret =sqlite_altertable($tablename,$query,$dbhandle);\r
 181                         if (!$ret) sqlite_ReturnWithError('SQL error',"<br /><i>".nucleus_mysql_error()."</i><br />".htmlspecialchars($p1)."<br /><br />\n".htmlspecialchars("ALTER TABLE $tablename $query")."<hr />\n");\r
 182                         return $ret;\r
 183                 }\r
 184                 // Else, syntax error\r
 185         } else if (strpos($uquery,'RENAME TABLE ')===0) {\r
 186                 require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 187                 return sqlite_renametable(_sqlite_divideByChar(',',substr($query,13)),$dbhandle);\r
 188         } else if (strpos($uquery,'INSERT INTO ')===0 || strpos($uquery,'REPLACE INTO ')===0 ||\r
 189                         strpos($uquery,'INSERT IGNORE INTO ')===0 || strpos($uquery,'REPLACE IGNORE INTO ')===0) {\r
 190                 $buff=str_replace(' IGNORE ',' OR IGNORE ',substr($uquery,0,($i=strpos($uquery,' INTO ')+6)));\r
 191                 $query=trim(substr($query,$i));\r
 192                 if ($i=strpos($query,' ')) {\r
 193                         $buff.=trim(substr($query,0,$i+1));\r
 194                         $query=trim(substr($query,$i));\r
 195                 }\r
 196                 if ($i=strpos($query,' ')) {\r
 197                         if (strpos(strtoupper($query),'SET')===0) {\r
 198                                 $query=trim(substr($query,3));\r
 199                                 $commands=_sqlite_divideByChar(',',$query);\r
 200                                 $query=' VALUES(';\r
 201                                 $buff.=' (';\r
 202                                 foreach($commands as $key=>$value){\r
 203                                         //echo "[".htmlspecialchars($value)."]";\r
 204                                         if (0<$key) {\r
 205                                                 $buff.=', ';\r
 206                                                 $query.=', ';\r
 207                                         }\r
 208                                         if ($i=strpos($value,'=')) {\r
 209                                                 $buff.=trim(substr($value,0,$i));\r
 210                                                 $query.=substr($value,$i+1);\r
 211                                         }\r
 212                                 }\r
 213                                 $buff.=')';\r
 214                                 $query.=')';\r
 215                         } else {\r
 216                                 $beforevalues='';\r
 217                                 $commands=_sqlite_divideByChar(',',$query);\r
 218                                 $query='';\r
 219                                 foreach($commands as $key=>$value){\r
 220                                         if ($beforevalues=='' && preg_match('/^(.*)\)\s+VALUES\s+\(/i',$value,$matches)) {\r
 221                                                 $beforevalues=$buff.' '.$query.$matches[1].')';\r
 222                                         }\r
 223                                         if (0<$key) $query.=$beforevalues.' VALUES ';// supports multiple insertion\r
 224                                         $query.=$value.';';\r
 225                                 }\r
 226                         }\r
 227                 }\r
 228                 $query=$buff.' '.$query;\r
 229         } else if (strpos($uquery,'SHOW TABLES LIKE ')===0) {\r
 230                 $query='SELECT name FROM sqlite_master WHERE type=\'table\' AND name LIKE '.substr($query,17);\r
 231         } else if (strpos($uquery,'SHOW TABLES')===0) {\r
 232                 $query='SELECT name FROM sqlite_master WHERE type=\'table\'';\r
 233         } else if (strpos($uquery,'SHOW KEYS FROM ')===0) {\r
 234                 require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 235                 $query=sqlite_showKeysFrom(trim(substr($query,15)),$dbhandle);\r
 236         } else if (strpos($uquery,'SHOW INDEX FROM ')===0) {\r
 237                 require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 238                 $query=sqlite_showKeysFrom(trim(substr($query,16)),$dbhandle);\r
 239         } else if (strpos($uquery,'SHOW FIELDS FROM ')===0) {\r
 240                 require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 241                 $query=sqlite_showFieldsFrom(trim(substr($query,17)),$dbhandle);\r
 242         } else if (strpos($uquery,'SHOW COLUMNS FROM ')===0) {\r
 243                 require_once(dirname(__FILE__) . '/sqlitealtertable.php');\r
 244                 $query=sqlite_showFieldsFrom(trim(substr($query,18)),$dbhandle);\r
 245         } else if (strpos($uquery,'TRUNCATE TABLE ')===0) {\r
 246                 $query='DELETE FROM '.substr($query,15);\r
 247         } else if (preg_match('/^DESC \'([^\']+)\' \'([^\']+)\'$/',$query,$m)) {\r
 248                 return nucleus_mysql_query("SHOW FIELDS FROM '$m[1]' LIKE '$m[2]'");\r
 249         } else if (preg_match('/^DESC ([^\s]+) ([^\s]+)$/',$query,$m)) {\r
 250                 return nucleus_mysql_query("SHOW FIELDS FROM '$m[1]' LIKE '$m[2]'");\r
 251         } else SQLite_Functions::sqlite_modifyQueryForUserFunc($query,$strpositions);\r
 252 \r
 253         //Throw query again.\r
 254         $aftertrans=time()+microtime();\r
 255         if ($unbuffered) {\r
 256                 $ret=sqlite_unbuffered_query($dbhandle,$query);\r
 257         } else {\r
 258                 $ret=sqlite_query($dbhandle,$query);\r
 259         }\r
 260 \r
 261         $afterquery=time()+microtime();\r
 262         if ($SQLITECONF['MEASURESPEED']) sqlite_DebugMessage("translated query:$query\n".\r
 263                 'translation: '.($aftertrans-$beforetrans).'sec, query: '.($afterquery-$aftertrans).'sec');\r
 264         if (!$ret) sqlite_ReturnWithError('SQL error',"<br /><i>".nucleus_mysql_error()."</i><br />".htmlspecialchars($p1)."<br /><br />\n".htmlspecialchars($query)."<hr />\n");\r
 265         foreach ($morequeries as $value) if ($value) @sqlite_query($dbhandle,$value);\r
 266         return $ret;\r
 267 }\r
 268 function sqlite_changeQuote(&$query){\r
 269         // This function is most important.\r
 270         // When you modify this function, do it very carefully.\r
 271         // Otherwise, you may allow crackers to do SQL-injection.\r
 272         // This function returns array that shows where the strings are.\r
 273         $sarray=array();\r
 274         $ret='';\r
 275         $qlen=strlen($query);\r
 276         for ($i=0;$i<$qlen;$i++) {\r
 277                 // Go to next quote\r
 278                 if (($i1=strpos($query,'"',$i))===false) $i1=$qlen;\r
 279                 if (($i2=strpos($query,"'",$i))===false) $i2=$qlen;\r
 280                 if (($i3=strpos($query,'`',$i))===false) $i3=$qlen;\r
 281                 if ($i1==$qlen && $i2==$qlen && $i3==$qlen) {\r
 282                         $temp=preg_replace('/[\s]+/',' ',substr($query,$i)); // Change all spacying to ' '.\r
 283                         $ret.=($temp);\r
 284                         if (strstr($temp,';')) exit('Warning: try to use more than two queries?');\r
 285                         break;\r
 286                 }\r
 287                 if ($i2<($j=$i1)) $j=$i2;\r
 288                 if ($i3<$j) $j=$i3;\r
 289                 $temp=preg_replace('/[\s]+/',' ',substr($query,$i,$j-$i)); // Change all spacying to ' '.\r
 290                 $ret.=($temp);\r
 291                 $c=$query[($i=$j)]; // $c keeps the type of quote.\r
 292                 if (strstr($temp,';')) exit('Warning: try to use more than two queries?');\r
 293                 \r
 294                 // Check between quotes.\r
 295                 // $j shows the begging positioin.\r
 296                 // $i will show the ending position.\r
 297                 $j=(++$i);\r
 298                 while ($i<$qlen) {\r
 299                         if (($i1=strpos($query,$c,$i))===false) $i1=$qlen;\r
 300                         if (($i2=strpos($query,"\\",$i))===false) $i2=$qlen;\r
 301                         if ($i2<$i1) {\r
 302                                 // \something. Skip two characters.\r
 303                                 $i=$i2+2;\r
 304                                 continue;\r
 305                         } if ($i1<($qlen-1) && $query[$i1+1]==$c) {\r
 306                                 // "", '' or ``.  Skip two characters.\r
 307                                 $i=$i1+2;\r
 308                                 continue;\r
 309                         } else {// OK. Reached the end position\r
 310                                 $i=$i1;\r
 311                                 break;\r
 312                         }\r
 313                 }\r
 314                 $i1=strlen($ret);\r
 315                 $ret.="'".sqlite_changeslashes(substr($query,$j,$i-$j));\r
 316                 if ($i<$qlen) $ret.="'"; //else Syntax error in query.\r
 317                 $i2=strlen($ret);\r
 318                 $sarray[$i1]=$i2;\r
 319         }//echo htmlspecialchars($query).'<br />'.htmlspecialchars($ret).'<br />';\r
 320         $query=$ret;\r
 321         return $sarray;\r
 322 }\r
 323 function sqlite_changeslashes(&$text){\r
 324         // By SQLite, "''" is used in the quoted string instead of "\'".\r
 325         // In addition, only "'" seems to be allowed for perfect quotation of string.\r
 326         // This routine is used for the conversion from MySQL type to SQL type.\r
 327         // Do NOT use stripslashes() but use stripcslashes().  Otherwise, "\r\n" is not converted.\r
 328         if ($text==='') return '';\r
 329         return (sqlite_escape_string (stripcslashes((string)$text)));\r
 330 }\r
 331 function _sqlite_divideByChar($char,$query,$limit=-1){\r
 332         if (!is_array($char)) $char=array($char);\r
 333         $ret=array();\r
 334         $query=trim($query);\r
 335         $buff='';\r
 336         while (strlen($query)){\r
 337                 $i=strlen($query);\r
 338                 foreach($char as $value){\r
 339                         if (($j=strpos($query,$value))!==false) {\r
 340                                 if ($j<$i) $i=$j;\r
 341                         }\r
 342                 }\r
 343                 if (($j=strpos($query,'('))===false) $j=strlen($query);\r
 344                 if (($k=strpos($query,"'"))===false) $k=strlen($query);\r
 345                 if ($i<$j && $i<$k) {// ',' found\r
 346                         $buff.=substr($query,0,$i);\r
 347                         if (strlen($buff)) $ret[]=$buff;\r
 348                         $query=trim(substr($query,$i+1));\r
 349                         $buff='';\r
 350                         $limit--;\r
 351                         if ($limit==0) exit;\r
 352                 } else if ($j<$i && $j<$k) {// '(' found\r
 353                         if (($i=strpos($query,')',$j))===false) {\r
 354                                 $buff.=$query;\r
 355                                 if (strlen($buff)) $ret[]=$buff;\r
 356                                 $query=$buff='';\r
 357                         } else {\r
 358                                 $buff.=substr($query,0,$i+1);\r
 359                                 $query=substr($query,$i+1);\r
 360                         }\r
 361                 } else if ($k<$i && $k<$j) {// "'" found\r
 362                         if (($i=strpos($query,"'",$k+1))===false) {\r
 363                                 $buff.=$query;\r
 364                                 if (strlen($buff)) $ret[]=$buff;\r
 365                                 $query=$buff='';\r
 366                         } else {\r
 367                                 $buff.=substr($query,0,$i+1);\r
 368                                 $query=substr($query,$i+1);\r
 369                         }\r
 370                 } else {// last column\r
 371                         $buff.=$query;\r
 372                         if (strlen($buff)) $ret[]=$buff;\r
 373                         $query=$buff='';\r
 374                 }\r
 375         }\r
 376         if (strlen($buff)) $ret[]=$buff;\r
 377         return $ret;\r
 378 }\r
 379 function sqlite_mysql_query_debug(&$query){\r
 380         // There is nothing to do here in this version.\r
 381         return $query;\r
 382 }\r
 383 \r
 384 function nucleus_mysql_list_tables($p1=null,$p2=null) {\r
 385         global $SQLITE_DBHANDLE,$MYSQL_DATABASE;\r
 386         return sqlite_query($SQLITE_DBHANDLE,"SELECT name as Tables_in_$MYSQL_DATABASE FROM sqlite_master WHERE type='table'");\r
 387 }\r
 388 function nucleus_mysql_listtables($p1=null,$p2=null) { return nucleus_mysql_list_tables($p1,$p2);}\r
 389 \r
 390 function nucleus_mysql_affected_rows($p1=null){\r
 391         global $SQLITE_DBHANDLE;\r
 392         if (!($dbhandle=$p1)) $dbhandle=$SQLITE_DBHANDLE;\r
 393         return sqlite_changes($dbhandle);\r
 394 }\r
 395 \r
 396 function nucleus_mysql_error($p1=null){\r
 397         global $SQLITE_DBHANDLE;\r
 398         if (!($dbhandle=$p1)) $dbhandle=$SQLITE_DBHANDLE;\r
 399         return sqlite_error_string ( sqlite_last_error ($dbhandle) );\r
 400 }\r
 401 \r
 402 function nucleus_mysql_fetch_array($p1,$p2=SQLITE_BOTH){\r
 403         return sqlite_fetch_array ($p1,$p2);\r
 404 }\r
 405 \r
 406 function nucleus_mysql_fetch_assoc($p1){\r
 407         return sqlite_fetch_array($p1,SQLITE_ASSOC);\r
 408 }\r
 409 \r
 410 function nucleus_mysql_fetch_object($p1,$p2=SQLITE_BOTH){\r
 411         if (is_array($ret=sqlite_fetch_array ($p1,$p2))) {\r
 412                 $o=new SQLITE_OBJECT;\r
 413                 foreach ($ret as $key=>$value) {\r
 414                         if (strstr($key,'.')) {// Remove table name.\r
 415                                 $key=preg_replace('/^(.+)\."(.+)"$/','"$2"',$key);\r
 416                                 $key=preg_replace('/^(.+)\.([^.^"]+)$/','$2',$key);\r
 417                         }\r
 418                         $o->$key=$value;\r
 419                 }\r
 420                 return $o;\r
 421         } else return false;\r
 422 }\r
 423 \r
 424 function nucleus_mysql_fetch_row($p1){\r
 425         return sqlite_fetch_array($p1,SQLITE_NUM);\r
 426 }\r
 427 \r
 428 function nucleus_mysql_field_name($p1,$p2){\r
 429         return sqlite_field_name ($p1,$p2);\r
 430 }\r
 431 \r
 432 function nucleus_mysql_free_result($p1){\r
 433         // ???? Cannot find corresponding function of SQLite.\r
 434         // Maybe SQLite is NOT used for the high spec server\r
 435         // that need mysql_free_result() function because of\r
 436         // many SQL-queries in a script.\r
 437         return true;\r
 438 }\r
 439 \r
 440 function nucleus_mysql_insert_id($p1=null){\r
 441         global $SQLITE_DBHANDLE;\r
 442         if (!($dbhandle=$p1)) $dbhandle=$SQLITE_DBHANDLE;\r
 443         return sqlite_last_insert_rowid ($dbhandle);\r
 444 }\r
 445 \r
 446 function nucleus_mysql_num_fields($p1){\r
 447         return sqlite_num_fields ($p1);\r
 448 }\r
 449 \r
 450 function nucleus_mysql_num_rows($p1){\r
 451         return sqlite_num_rows ($p1);\r
 452 }\r
 453 function nucleus_mysql_numrows($p1){\r
 454         return sqlite_num_rows ($p1);\r
 455 }\r
 456 \r
 457 function nucleus_mysql_result($p1,$p2,$p3=null){\r
 458         if ($p3) return sqlite_ReturnWithError('nucleus_mysql_result');\r
 459         if (!$p2) return sqlite_fetch_single ($p1);\r
 460         $a=sqlite_fetch_array ($p1);\r
 461         return $a[$p2];\r
 462 }\r
 463 \r
 464 function nucleus_mysql_unbuffered_query($p1,$p2=null){\r
 465         return nucleus_mysql_query($p1,$p2,true);\r
 466 }\r
 467 \r
 468 function nucleus_mysql_client_encoding($p1=null){\r
 469         return sqlite_libencoding();\r
 470 }\r
 471 \r
 472 function nucleus_mysql_data_seek($p1,$p2) {\r
 473         return sqlite_seek($p1,$p2);\r
 474 }\r
 475 \r
 476 function nucleus_mysql_errno ($p1=null){\r
 477         global $SQLITE_DBHANDLE;\r
 478         if (!($dbhandle=$p1)) $dbhandle=$SQLITE_DBHANDLE;\r
 479         return sqlite_last_error($dbhandle);\r
 480 }\r
 481 \r
 482 function nucleus_mysql_escape_string ($p1){\r
 483         // The "'" will be changed to "''".\r
 484         // This way works for both MySQL and SQLite when single quotes are used for string.\r
 485         // Note that single quote is always used in this wrapper.\r
 486         // If a plugin is made on SQLite-Nucleus and such plugin will be used for MySQL-Nucleus,\r
 487         // nucleus_mysql_escape_string() will be changed to mysql_escape_string() and\r
 488         // this routine won't be used, so this way won't be problem.\r
 489         return sqlite_escape_string($p1);\r
 490 }\r
 491 \r
 492 function nucleus_mysql_real_escape_string ($p1,$p2=null){\r
 493         //addslashes used here.\r
 494         return addslashes($p1);\r
 495 }\r
 496 \r
 497 function nucleus_mysql_create_db ($p1,$p2=null){\r
 498         // All prameters are ignored.\r
 499         // Returns always true;\r
 500         return true;\r
 501 }\r
 502 \r
 503 function nucleus_mysql_pconnect($p1=null,$p2=null,$p3=null,$p4=null,$p5=null){\r
 504         global $SQLITE_DBHANDLE,$SQLITECONF;\r
 505         sqlite_close ($SQLITE_DBHANDLE);\r
 506         $SQLITE_DBHANDLE=sqlite_popen($SQLITECONF['DBFILENAME']);\r
 507         return ($SQLITE['DBHANDLE']=$SQLITE_DBHANDLE);\r
 508 }\r
 509 \r
 510 function nucleus_mysql_fetch_field($p1,$p2=null){\r
 511         if ($p2) return sqlite_ReturnWithError('nucleus_mysql_fetch_field');\r
 512         // Only 'name' is supported.\r
 513         $o=new SQLITE_OBJECT;\r
 514         $o->name=array();\r
 515         if(is_array($ret=sqlite_fetch_array ($p1,SQLITE_ASSOC )))\r
 516                 foreach ($ret as $key=>$value) {\r
 517                         if (is_string($key)) array_push($o->name,$key);\r
 518                 }\r
 519         return $o;\r
 520 \r
 521 }\r
 522 function nucleus_mysql_get_client_info(){\r
 523         return nucleus_mysql_get_server_info();\r
 524 }\r
 525 function nucleus_mysql_get_server_info(){\r
 526         $res=nucleus_mysql_query('SELECT sqlite_version();');\r
 527         if (!$res) return '?.?.?';\r
 528         $row=nucleus_mysql_fetch_row($res);\r
 529         if (!$row) return '?.?.?';\r
 530         return $row[0];\r
 531 }\r
 532 \r
 533 // This function is called instead of _execute_queries() in backp.php\r
 534 function sqlite_restore_execute_queries(&$query){\r
 535         global $DIR_NUCLEUS,$DIR_LIBS,$DIR_PLUGINS,$CONF;\r
 536         \r
 537         // Skip until the first "#" or "--"\r
 538         if (($i=strpos($query,"\n#"))===false) $i=strlen($query);\r
 539         if (($j=strpos($query,"\n--"))===false) $j=strlen($query);\r
 540         if ($i<$j) $query=substr($query,$i+1);\r
 541         else  $query=substr($query,$j+1);\r
 542         \r
 543         // Save the query to temporary file in sqlite directory.\r
 544         if (function_exists('microtime')) {\r
 545                 $prefix=preg_replace('/[^0-9]/','',microtime());\r
 546         } else {\r
 547                 srand(time());\r
 548                 $prefix=(string)rand(0,999999);\r
 549         }\r
 550         $tmpname=tempnam($DIR_NUCLEUS.'sqlite/',"tmp$prefix");\r
 551         if (!($handle=@fopen($tmpname,'w'))) return 'Cannot save temporary DB file.';\r
 552         fwrite($handle,$query);\r
 553         fclose($handle);\r
 554         $tmpname=preg_replace('/[\s\S]*?[\/\\\\]([^\/\\\\]+)$/','$1',$tmpname);\r
 555         \r
 556         // Read the option from NP_SQLite\r
 557         if (!class_exists('NucleusPlugin')) { include($DIR_LIBS.'PLUGIN.php');}\r
 558         if (!class_exists('NP_SQLite')) { include($DIR_PLUGINS.'NP_SQLite.php'); }\r
 559         $p=new NP_SQLite();\r
 560         if (!($numatonce=@$p->getOption('numatonce'))) $numatonce=20;\r
 561         if (!($refreshwait=@$p->getOption('refreshwait'))) $refreshwait=1;\r
 562         \r
 563         // Start process.\r
 564         $url="plugins/sqlite/restore.php?dbfile=$tmpname&numatonce=$numatonce&refreshwait=$refreshwait";\r
 565         header('HTTP/1.0 301 Moved Permanently');\r
 566         header('Location: '.$url);\r
 567         exit('<html><body>Moved Permanently</body></html>');\r
 568 }\r
 569 \r
 570 ?>