php如何讀取CSV大文件并且將其導入數據庫示例

思路：

成都創新互聯公司專業IDC數據服務器托管提供商，專業提供成都服務器托管，服務器租用，成都服務器托管，成都服務器托管，成都多線服務器托管等服務器托管服務。

讀取csv文件，每讀取一行數據，就插入數據庫

示例

文件夾結構

/

file.csv????//csv大文件，這里只模擬三行數據，不考慮運行效率（PS：csv文件格式很簡單，文件一般較小，解析很快，運行效率的瓶頸主要在寫入數據庫操作）

index.php????//php文件

file.csv

singi,20

lily,19

daming,23

index.php

/**

*?讀取csv文件，每讀取一行數據，就插入數據庫

*/

//獲取數據庫實例

$dsn?=?'mysql:dbname=test;host=127.0.0.1';

$user?=?'root';

$password?=?'';

try?{

$db?=?new?PDO($dsn,?$user,?$password);

}?catch?(PDOException?$e)?{

echo?'Connection?failed:?'?.?$e-getMessage();

}

//讀取file.csv文件

if?(($handle?=?fopen("file.csv",?"r"))?!==?FALSE)?{

while?(($row?=?fgetcsv($handle,?1000,?","))?!==?FALSE)?{

//寫入數據庫

$sth?=?$db-prepare('insert?into?test?set?name=:name,age=:age');

$sth-bindParam(':name',$row[0],PDO::PARAM_STR,255);

$sth-bindParam(':age',$row[1],PDO::PARAM_INT);

$sth-execute();

}

fclose($handle);

}

數據表

CREATE?TABLE?`test`?(

`id`?INT(10)?UNSIGNED?NOT?NULL?AUTO_INCREMENT,

`name`?VARCHAR(255)?NULL?DEFAULT?''?COLLATE?'utf8mb4_bin',

`age`?INT(10)?NULL?DEFAULT?'0',

PRIMARY?KEY?(`id`)

)

COLLATE='utf8mb4_bin'

ENGINE=InnoDB;

運行結束后，數據庫中會插入csv中的三行數據

PHP使用pdo連接access數據庫并循環顯示數據操作示例

本文實例講述了PHP使用pdo連接access數據庫并循環顯示數據操作。分享給大家供大家參考，具體如下：

PDO連接與查詢：

try

{

$conn

=

new

PDO("odbc:driver={microsoft

access

driver

(*.mdb)};

dbq=".realpath("MyDatabase.mdb"))

or

die("鏈接錯誤！");

//echo

"鏈接成功！";

}

catch(PDOException

$e){

echo

$e-getMessage();

}

$sql

=

"select

*

from

users";

1.

foreach()方法

foreach

($conn-query($sql)

as

$row)

{

$row["UserID"];

$row["UserName"];

$row["UserPassword"];

}

2.

while()方法

$rs

=

$conn-query($sql);

$rs-setFetchMode(PDO::FETCH_NUM);

while($row=$rs-fetch()){

$row[0];

$row[1];

$row[2];

}

php使用PDO抽象層獲取查詢結果，主要有三種方式：

（1）PDO::query()查詢。

看下面這段php代碼：

?php

//PDO::query()查詢

$res

=

$db-query('select

*

from

user');

$res-setFetchMode(PDO::FETCH_NUM);

//數字索引方式

while

($row

=

$res-fetch()){

print_r($row);

}

?

（2）PDO-exec()處理sql

?php

//PDO-exec()處理sql

$db-setAttribute(PDO::ATTR_ERRMODE,

PDO::ERRMODE_EXCEPTION);

$res

=

$db-exec("insert

into

user(id,name)

values('','php點點通')");

echo

$res;

?

（3）PDO::prepare()預處理執行查詢

?php

//PDO::prepare()預處理執行查詢

$res

=

$db-prepare("select

*

from

user");

$res-execute();

while

($row

=

$res-fetchAll())

{

print_r($row);

}

?

setAttribute()

方法是設置屬性，常用參數如下：

PDO::CASE_LOWER

--

強制列名是小寫

PDO::CASE_NATURAL

--

列名按照原始的方式

PDO::CASE_UPPER

--

強制列名為大寫

setFetchMode方法來設置獲取結果集的返回值的類型，常用參數如下：

PDO::FETCH_ASSOC

--

關聯數組形式

PDO::FETCH_NUM

--

數字索引數組形式

PDO::FETCH_BOTH

--

兩者數組形式都有，這是默認的

PDO::FETCH_OBJ

--

按照對象的形式，類似于以前的

mysql_fetch_object()

對上面總結如下：

查詢操作主要是PDO::query()、PDO::exec()、PDO::prepare()。

PDO-query()

—

處理一條SQL語句，并返回一個“PDOStatement”

PDO-exec()

—

處理一條SQL語句，并返回所影響的條目數

PDO::prepare()主要是預處理操作，需要通過$rs-execute()來執行預處理里面的SQL語句

最后介紹兩個常用的函數：

（1）fetchColumn()獲取指定記錄里一個字段結果，默認是第一個字段！

?php

$res

=

$db-query('select

*

from

user');

//獲取指定記錄里第二個字段結果

$col

=

$res-fetchColumn(1);

echo

$col;

?

（2）fetchAll()，從一個結果集中獲取數據，然后存放在關聯數組中

?php

$res

=

$db-query('select

*

from

user');

$res_arr

=$res-fetchAll();

print_r($res_arr);

?

更多關于PHP相關內容感興趣的讀者可查看本站專題：《PHP基于pdo操作數據庫技巧總結》、《php+Oracle數據庫程序設計技巧總結》、《PHP+MongoDB數據庫操作技巧大全》、《php面向對象程序設計入門教程》、《php字符串(string)用法總結》、《php+mysql數據庫操作入門教程》及《php常見數據庫操作技巧匯總》

希望本文所述對大家PHP程序設計有所幫助。

您可能感興趣的文章:PHP使用PDO連接ACCESS數據庫PHP數據庫鏈接類(PDO+Access)實例分享php中mysql連接方式PDO使用詳解關于php連接mssql：pdo

odbc

sql

serverPhp中用PDO查詢Mysql來避免SQL注入風險的方法php中在PDO中使用事務(Transaction)全新的PDO數據庫操作類php版（僅適用Mysql）php使用pdo連接并查詢sql數據庫的方法php使用pdo連接mssql

server數據庫實例PHP實現PDO的mysql數據庫操作類

php怎么樣實例化數據庫對象

php 連接數據庫的幾種方式

$con = mysql_connect(服務器,服務器用戶名,服務器密碼默認為“”)

mysql_select_db（數據庫，$con）選擇數據庫

mysql_query($sql,$con);

$con = mysqli_connect(服務器,服務器用戶名,服務器密碼默認為“”，數據庫名)

$query = mysqli_query($conn,$sql);

$conn = new mysqli(服務器,服務器用戶名,服務器密碼默認為“”，數據庫名);

$query = $conn-query($sql);

php?寫入數據庫?例子

?php

//?以?MySQL?為例:

mysql_connect('127.0.0.1',?'root',?'root',?3306);??//?連接數據庫

mysql_select_db('test');???????????????????????????//?選擇數據庫

mysql_query('set?names?utf8');?????????????????????//?執行SQL

//?插入數據語句

$sql?=?"INSERT?INTO?table?(username,?password)?VALUES?('Jack@163.com',?'123456')";

$r?=?mysql_query($sql);

if?(mysql_affected_rows())?{

echo?'新增成功';

}?else?{

echo?mysql_error();

}