PHP將cvs導入到MySql

wxx4 11年前發布 | 1K 次閱讀 PHP

<?php

$databasehost = "localhost"; $databasename = "test"; $databasetable = "sample"; $databaseusername ="test"; $databasepassword = ""; $fieldseparator = ","; $lineseparator = "\n"; $csvfile = "filename.csv";

/**/ / Would you like to add an ampty field at the beginning of these records? / This is useful if you have a table with the first field being an auto_increment integer / and the csv file does not have such as empty field before the records. / Set 1 for yes and 0 for no. ATTENTION: don't set to 1 if you are not sure. /* This can dump data in the wrong fields if this extra field does not exist in the table /**/ $addauto = 0; /**/

/ Would you like to save the mysql queries in a file? If yes set $save to 1. / Permission on the file should be set to 777. Either upload a sample file through ftp and /* change the permissions, or execute at the prompt: touch output.sql && chmod 777 output.sql /**/ $save = 1; $outputfile = "output.sql"; /**/

if (!file_exists($csvfile)) { echo "File not found. Make sure you specified the correct path.\n"; exit; }

$file = fopen($csvfile,"r");

if (!$file) { echo "Error opening data file.\n"; exit; }

$size = filesize($csvfile);

if (!$size) { echo "File is empty.\n"; exit; }

$csvcontent = fread($file,$size);

fclose($file);

$con = @mysql_connect($databasehost,$databaseusername,$databasepassword) or die(mysql_error()); @mysql_select_db($databasename) or die(mysql_error());

$lines = 0; $queries = ""; $linearray = array();

foreach(split($lineseparator,$csvcontent) as $line) {

    $lines++;

    $line = trim($line," \t");

    $line = str_replace("\r","",$line);

    /************************************
    This line escapes the special character. remove it if entries are already escaped in the csv file
    ************************************/
    $line = str_replace("'","\'",$line);
    /*************************************/

    $linearray = explode($fieldseparator,$line);

    $linemysql = implode("','",$linearray);

    if($addauto)
            $query = "insert into $databasetable values('','$linemysql');";
    else
            $query = "insert into $databasetable values('$linemysql');";

    $queries .= $query . "\n";

    @mysql_query($query);

}

@mysql_close($con);

if ($save) {

    if (!is_writable($outputfile)) {
            echo "File is not writable, check permissions.\n";
    }

    else {
            $file2 = fopen($outputfile,"w");

            if(!$file2) {
                    echo "Error writing to the output file.\n";
            }
            else {
                    fwrite($file2,$queries);
                    fclose($file2);
            }
    }

}

echo "Found a total of $lines records in this csv file.\n";

?></pre>

 本文由用戶 wxx4 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!