-
-
/*
- * PHP code to export MySQL data to CSV
- *
- * Sends the result of a MySQL query as a CSV file for download
- * Easy to convert to UTF-8.
- */
-
- /*
- * establish database connection
- */
-
- $conn = mysql_connect('localhost', 'login', 'pass') or die(mysql_error());
- mysql_select_db('database_name', $conn) or die(mysql_error($conn));
- mysql_query("SET NAMES CP1252");
- /*
- * execute sql query
- */
- $query = sprintf('SELECT field1,field2 FROM table_name');
- $result = mysql_query($query, $conn) or die(mysql_error($conn));
- /*
- * send response headers to the browser
- * following headers instruct the browser to treat the data as a csv file called export.csv
- */
- header('Content-Type: text/csv; charset=cp1252');
- header('Content-Disposition: attachment;filename=output.csv');
- /*
- * output header row (if atleast one row exists)
- */
-
- $row = mysql_fetch_assoc($result);
- if ($row) {
- echocsv(array_keys($row));
- }
-
- /*
- * output data rows (if atleast one row exists)
- */ 导出csv文件
- while ($row) {
- echocsv($row);
- $row = mysql_fetch_assoc($result);
- }
-
- /*
- * echo the input array as csv data maintaining consistency with most CSV implementations
- * - uses double-quotes as enclosure when necessary
- * - uses double double-quotes to escape double-quotes
- * - uses CRLF as a line separator
- */
-
- function echocsv($fields)
- {
- $separator = '';
- foreach ($fields as $field) {
- if (preg_match('/\\r|\\n|,|"/', $field)) {
- $field = '"' . str_replace('"', '""', $field) . '"';
- }
- echo $separator . $field;
- $separator = ',';
- }
- echo "\r\n";
- }
- ?>
复制代码
二、php导入与导出csv文件的类
php实现csv文件的导入和导出类。
代码:
-
-
/**
- * CSV 文件处理类
- */
- class Csv{
- public $csv_array; //csv数组数据
- public $csv_str; //csv文件数据
- public function __construct($param_arr, $column){
- $this->csv_array = $param_arr;
- $this->path = $path;
- $this->column = $column;
- }
- /**
- * 导出
- * */
- public function export(){
- if(empty($this->csv_array) || empty($this->column)){
- return false;
- }
- $param_arr = $this->csv_array;
- unset($this->csv_array);
- $export_str = implode(',',$param_arr['nav'])."n";
- unset($param_arr['nav']);
- //组装数据
- foreach($param_arr as $k=>$v){
- foreach($v as $k1=>$v1){
- $export_str .= implode(',',$v1)."n";
- }
- }
- //将$export_str导出
- header( "Cache-Control: public" );
- header( "Pragma: public" );
- header("Content-type:application/vnd.ms-excel");
- header("Content-Disposition:attachment;filename=txxx.csv");
- header('Content-Type:APPLICATION/OCTET-STREAM');
- ob_start();
- // $file_str= iconv("utf-8",'gbk',$export_str);
- ob_end_clean();
- echo $export_str;
- }
- /**
- * 导入
- * */
- public function import($path,$column = 3){
- $flag = flase;
- $code = 0;
- $msg = '未处理';
- $filesize = 1; //1MB
- $maxsize = $filesize * 1024 * 1024;
- $max_column = 1000;
-
- //检测文件是否存在
- if($flag === flase){
- if(!file_exists($path)){
- $msg = '文件不存在';
- $flag = true;
- }
- }
- //检测文件格式
- if($flag === flase){
- $ext = preg_replace("/.*.([^.]+)/","$1",$path);
- if($ext != 'csv'){
- $msg = '只能导入CSV格式文件';
- $flag = true;
- }
- }
- //检测文件大小
- if($flag === flase){
- if(filesize($path)>$maxsize){
- $msg = '导入的文件不得超过'.$maxsize.'B文件';
- $flag = true;
- }
- }
- //读取文件
- if($flag == flase){
- $row = 0;
- $handle = fopen($path,'r');
- $dataArray = array();
- while($data = fgetcsv($handle,$max_column,",")){
- $num = count($data);
- if($num $msg = '文件不符合规格真实有:'.$num.'列数据';
- $flag = true;
- break;
- }
- if($flag === flase){
- for($i=0;$i if($row == 0){
- break;
- }
- //组建数据
- $dataArray[$row][$i] = $data[$i];
- }
- }
- $row++;
- }
- }
- return $dataArray;
- }
- }
- $param_arr = array(
- 'nav'=>array('用户名','密码','邮箱'),
- array(0=>array('xiaohai1','123456','xiaohai1@jbxue.com'),
- 1=>array('xiaohai2','213456','xiaohai2@jbxue.com'),
- 2=>array('xiaohai3','123456','xiaohai3@jbxue.com')
- ));
- $column = 3;
- $csv = new Csv($param_arr, $column);
- //$csv->export();
- $path = 'C:\Documents and Settings\Administrator\Temp\txxx.csv';
- $import_arr = $csv->import($path,3);
- var_dump($import_arr);
- ?>
复制代码
|