PHP使用PHPExcel读取excel数据并批量上传到数据库

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

<?php

header("Content-type:text/html; charset=utf-8");

// 制定允许其他域名访问

header("Access-Control-Allow-Origin:*");

// 响应类型

header('Access-Control-Allow-Methods:POST');

// 响应头设置

header('Access-Control-Allow-Headers:x-requested-with, content-type');

// 数据库配置文件

include'./config/config.php';

// 下载 PHPExcel 放入项目内，引入即可

include"./PHPExcel-1.8/Classes/PHPExcel/IOFactory.php";

// 获取前端传入的文件

$file=$_FILES['file'];

//临时文件存放路径

$fileTmp=$file['tmp_name'];

$fileSize=$file['size'];

$fileName=$file['name'];

//错误，输出0，表示文件提交成功

$fileError=$file['error'];

if($fileError==0) {

$inputFileName=$fileTmp;

date_default_timezone_set('PRC');

// 读取excel文件

try{

$inputFileType= PHPExcel_IOFactory::identify($inputFileName);

$objReader= PHPExcel_IOFactory::createReader($inputFileType);

$objPHPExcel=$objReader->load($inputFileName);

}catch(Exception$e) {

}

// 确定要读取的sheet，什么是sheet，看excel的右下角

$sheet=$objPHPExcel->getSheet(0);

$highestRow=$sheet->getHighestRow();

$highestColumn=$sheet->getHighestColumn();

$time=date('Y-m-d h:i:s', time());

// 把数据处理后存入数组

$array=array();

$time=date('Y-m-d h:i:s', time());

for($row= 2;$row<=$highestRow;$row++) {

$rowData=$sheet->rangeToArray('A'.$row.':'.$highestColumn.$row, NULL, TRUE, FALSE);

// 重复数据不插入数据库

$falg=$rowData[0][0];

$sqlIf="SELECT codes FROM tablef where codes = '$falg'";

$querySQL= mysqli_query($conn,$sqlIf);

$arrSQL= mysqli_fetch_array($querySQL);

if($arrSQL== null) {

// 获取到 Excel 每行的数据插入数据库，需根据你自己的表格进行调整

$sql="insert into tablef(codes,year,month,idcode,type,timese) values('".$rowData[0][0]."','".($rowData[0][1])."','".$rowData[0][2]."','".$rowData[0][3]."','".$rowData[0][4]."','".$time."')";

$query=mysqli_query($conn,$sql);//函数执行一条 MySQL 查询。

}

}

// 成功后返回给前端

echojson_encode(["msg"=>'ok']);

}else{

echojson_encode(["msg"=>'no']);

}

// 断开数据库连接

$conn->close();

?>