Sqlite数据库转Mysql代码

dashan 提交于

论坛: 
一般讨论
<?php
include("class/mysql.php");
try{
        $link=new DB_MySQL();
        $link->connect();
        $link->selectdb();
        $db=sqlite_open("mssql.php");
        $tables=array("admin","class","config","linkcon","loginlog","content");        
        foreach ($tables as $value){
                transfer($value);
        }

        $link->close();        
}catch(Exception $e){
        print $e->getMessage();
        exit();
}
//数据转移函数，输入值为表名，可自动清空目标表    
function transfer($table)
{
        global $link,$db;
        $query="select id from $table";
        $link->query($query);
        if($link->affected_rows()!=0){
                $query="truncate $table";
                $link->query($query);
        }
     $query="select * from $table";
    $array=sqlite_array_query($db,$query);
    $query="insert into $table values (null";
    $flag=0;
           foreach($array as $row){
                   $i=1;
                   $j=0;
                   if($flag==1)
                           $query.=",(null";
                   foreach($row as $col){
                        if($j%2!=0 && $j>2){
                                $query.=',''.$row[$i++].''';
                        }                        
                        $j++;
                }   
                $query=$query.")";
                $flag=1;
          }
   $link->query($query);
}
?>