2011-10-28 76 views
0

我需要從FTP服務器導入數據。 FTP服務器上的文件名根據時間戳發生變化。我需要在PHP MySQL腳本中處理FTP服務器上的所有文件。我如何獲取文件名,然後在我的導入語句中使用它們。從FTP獲取文件名列表

我這個當前的代碼:

<?php 

$source = "DespGoods.csv"; 
$target = fopen("DespGoods.csv", "w"); 

$conn = ftp_connect("ftp.example.com") or die("Could not connect"); 
ftp_login($conn,"user","pass"); 

ftp_fget($conn,$target,$source,FTP_ASCII); 

echo "file downloaded.\n"; 

/********************************/ 
/* Code at http://legend.ws/blog/tips-tricks/csv-php-mysql-import/ 
/* Edit the entries below to reflect the appropriate values 
/********************************/ 
$databasehost = "localhost"; 
$databasename = "dbname"; 
$databasetable = "dbtable"; 
$databaseusername ="dbuser; 
$databasepassword = "dbpass"; 
$fieldseparator = ","; 
$lineseparator = "\n"; 
$csvfile = "DespGoods.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 = 0; 
$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); 
     } 
    } 

} 

mysql_close(); 
>? 

感謝, 瑞安

+2

聖牛 - 如果那些是真正的密碼和用戶名,你應該立即改變它們! –

+0

謝謝,我的不好:-) – Smudger

回答