dumptest

在博客上备份下 公司内部的一个媒体信息导入程序
sql_query($sql) or die(mysql_error());
$sql = "TRUNCATE TABLE `temp`;";
$db->sql_query($sql) or die(mysql_error());
$sql = "TRUNCATE TABLE `media_info`;";
$db->sql_query($sql) or die(mysql_error());
*/
if(($fp=fopen("media.txt","r"))===false)
   {
           die("打开文件失败");
   }
//以CSV格式打开文件，自动分割逗号
while($line = fgetcsv($fp,1024))
{
   //判断文件名出现次数
   $query="SELECT COUNT(filename) AS result from temp where filename="{$line[1]}"";
   //大于1集
   $link=$db->sql_query($query) or die(mysql_error());
        //得到result
   $row=$db->sql_fetchrow($link) or die(mysql_error());
   $result=$row['result'];
   //echo "sum is $result
";
       if($result==1)
       {
        $que1="UPDATE temp SET rec=rec+1 WHERE filename="{$line[1]}"";
        $db->sql_query($que1) or die(mysql_error());
       $que="SELECT id from media_info WHERE topic="{$line[1]}"";
       $db->sql_query($que) or die(mysql_error());
       $link=$db->sql_query($que) or die(mysql_error());
       $cu=$db->sql_fetchrow($link);
       ;
       $que1="SELECT rec from temp where filename="{$line[1]}"";
       $link=$db->sql_query($que1) or die(mysql_error());
       $cou=$db->sql_fetchrow($link);
       $query="UPDATE media_opern_info SET cp_media_id="{$line[0]}" where id="{$cu['id']}" and opern="{$cou['rec']}"";
    echo "$query
";
       $db->sql_query($query) or die(mysql_error());
       }
    else
       {
         //将文件名插入表
   $query="INSERT INTO temp(filename,rec) VALUES("{$line[1]}",'1')";
   //echo $query;
   $db->sql_query($query) or die(mysql_error());
   $query="UPDATE media_info SET cp_media_id='$line[0]' WHERE topic="{$line[1]}"";
    $db->sql_query($query) or die(mysql_error());
       }
}
//释放
fclose($fp);
$db->sql_freeresult();
?>