一: 要求:
上面的图表 中的数据插入到 3张表中.
1)t_vide_warehourse 分类表:
此表中包含 一级分类 和二级分类. 二级分类是一级分类的子级.
2)t_video_info 包名表
此表 管理 第一张表. 并且 只有 第二次分类 才可以有 包 名 .
一个二级分类下 可以 有多个包.
3)t_video_file 文件表.
此表 关联 第二张表; 一个 包 下 可以 有多个文件.
-----------------------------------------------------------------------------------------------
情况1:
上面: 第二级分类 就是 [教育培训], 包名 是 [计算机培训], 文件名是 [Android开发初级课程SQLite数据库介绍]
情况2:
上面: 二级分类 名 是 [其他], 包名是 [Photoshop CS6一对一教程], 文件名是 [01-01 Photoshopcs6安装方法]
情况3:
这种分类是空白的 数据 ,就排除掉. 不插入到数据库.
二: 导入到数据库的主题文件.
因为一个excel文件包含了 17个sheet ,太大了. 所以我们一个一个sheet的导入.
----------------
目录结构:
----------------------------------
1. file01.php
1 <?php 2 // ini_set ('memory_limit', '-1'); 3 /***************读取excel文件**************/ 4 require_once 'PHPExcel_1.8.0/Classes/PHPExcel/IOFactory.php'; 5 6 // echo "停止运行!"; 7 // die; 8 9 10 $execlName = '01.xlsx'; 11 $firstCateName = "计算机"; 12 13 // $execlName = '02.xlsx'; 14 // $firstCateName = "金融、会计"; 15 16 // $execlName = '03.xlsx'; 17 // $firstCateName = "就业创业"; 18 19 // $execlName = '04.xlsx'; 20 // $firstCateName = "学前教育"; 21 22 // $execlName = '05.xlsx'; 23 // $firstCateName = "烹饪"; 24 25 // $execlName = '06.xlsx'; 26 // $firstCateName = "电子商务"; 27 28 // $execlName = '07.xlsx'; 29 // $firstCateName = "党政“两学一做”"; 30 31 // $execlName = '08.xlsx'; 32 // $firstCateName = "美术"; 33 34 // $execlName = '09.xlsx'; 35 // $firstCateName = "体育锻炼"; 36 37 // $execlName = '10.xlsx'; 38 // $firstCateName = "英语学习"; 39 40 // $execlName = '11.xlsx'; 41 // $firstCateName = "物联网"; 42 43 // $execlName = '12.xlsx'; 44 // $firstCateName = "个人提升"; 45 46 // $execlName = '13.xlsx'; 47 // $firstCateName = "国学"; 48 49 // $execlName = '14.xlsx'; 50 // $firstCateName = "影视"; 51 52 // $execlName = '15.xlsx'; 53 // $firstCateName = "音乐"; 54 55 // $execlName = '16.xlsx'; 56 // $firstCateName = "艺术修养"; 57 58 // $execlName = '17.xlsx'; 59 // $firstCateName = "养生"; 60 61 62 63 64 65 $reader = PHPExcel_IOFactory::createReader('Excel2007'); //设置以Excel5格式(Excel97-2003工作簿) 66 $objPHPExcel = $reader->load($execlName); // 载入excel文件 67 $objWorksheet = $objPHPExcel->getSheet(0); // 读取第一個工作表 68 $highestRow = $objWorksheet->getHighestRow(); // 取得总行数 69 // $highestColumm = $objWorksheet->getHighestColumn(); // 取得总列数 70 71 $highestColumm = 'K'; // 取得总列数 72 73 74 // echo '总行数'.$highestRow."总列数:".$highestColumm; 75 76 /************ 循环读取每个单元格的数据 *********************/ 77 78 79 //行数是以第2行开始: A2,B2,C2....----> A10,B10,C10...-----> 80 for ($row = 2; $row <= $highestRow; $row++) 81 { 82 for ($column = 'A'; $column <= $highestColumm; $column++) 83 {//列数是以A列开始 84 85 86 //取得一个单元格的值 87 $cell = $objWorksheet->getCell($column.$row)->getValue(); 88 //富文本对象 转为 字符串 89 if($cell instanceof PHPExcel_RichText) 90 { 91 $cell = $cell->__toString(); 92 } 93 94 95 //$oneData 是一条记录 96 $oneData[] = $cell; 97 98 } 99 100 //$data 是多条记录 101 $data[] = $oneData; 102 //清空原来的一条记录 103 unset($oneData); 104 } 105 106 //上面取出$data是初始数据,还需要进行处理 107 // 108 109 110 // 去除 没有 分类的数据 111 foreach ($data as $key => $value) 112 { 113 if(empty($value[2])) 114 { 115 unset($data[$key]); 116 } 117 } 118 119 // echo "<pre>"; 120 // print_r($data); 121 122 123 124 125 //1: 添加一级分类, 二级分类, 包名: 126 foreach ($data as $k => $v) 127 { 128 //一级分类: 129 $v[0] = $firstCateName; 130 131 $arr = explode('->', $v[2]); 132 133 if (count($arr) == 1) 134 { 135 //二级分类: 136 $v[1] = '其他'; 137 138 //包名: 139 } 140 else 141 { 142 //二级分类: 143 $v[1] = $arr[1]; 144 145 //包名: 146 $v[2] = $arr[2]; 147 } 148 149 150 151 $data1[] = $v; 152 } 153 154 // echo "<pre>"; 155 // print_r($data); 156 // print_r($data1); 157 158 159 //2: 获取 一级分类id; 二级分类id, 包id; 如果没有, 就插入返回的id 160 include_once 'test.php'; 161 162 foreach ($data1 as $k => $v) 163 { 164 //1: 插入一级分类: 165 $firstCateName = $v[0]; 166 $firstCateId = insertFrist($firstCateName); 167 168 //2: 插入二级分类: 169 $secondCateName = $v[1]; 170 $secondCateId = insertSecond($secondCateName, $firstCateId); 171 172 //3: 插入info表: 包名: 173 $baoName = $v[2]; 174 $path = '/Course/CourseImage/'.$v[5]; 175 $infoId = insertInfo($baoName, $path, $secondCateId); 176 177 //4: 插入文件: 178 $fileName = $v[3]; 179 $imagePath = '/Course/CourseImage/'.$v[5]; 180 $keywords = $v[6]; 181 $fileType = substr($v[4],strrpos($v[4],'.')+1); 182 $filePath = '/files/video/'.$v[4]; 183 insertFile($infoId, $fileName, $imagePath, $keywords, $fileType, $filePath); 184 185 } 186 187 188 echo $firstCateName. '导入完毕!'; 189 190 191 192 193 194 195 196 197 198 199 200 201 202 /*******************函数**********************/ 203 204 205 206 207 208 ?>
注意:
因为格式是 .xlsx 所以 这里是 Excel2007 , 不是 Excel5
2. test.php
插入数据库函数.
1 <?php 2 3 4 5 6 7 // var_dump(insertFrist('英语1')); 8 9 // var_dump(insertSecond('英语1-1', 153309)); 10 // var_dump(insertSecond('英语1-2', 153309)); 11 // var_dump(insertSecond('测试', 153309)); 12 13 // var_dump(insertFrist('英语2')); 14 // var_dump(insertSecond('测试', 153313)); 15 16 // var_dump(insertInfo('包3', '/coure/test/01.png',153314)); 17 // var_dump(insertInfo('包3', '/coure/test/01.png',153315)); 18 // 19 // var_dump(insertFile(111, '测试文件2', '/course/test/01.jpg', 'haha, gest,test', 'flv', '/course/video/01.flv')); 20 21 /*******************函数**********************/ 22 23 24 function insertFrist($firstCateName) 25 { 26 27 $firstCateName = trim($firstCateName); 28 29 $dbhost = '127.0.0.1'; // mysql服务器主机地址 30 $dbuser = 'root'; // mysql用户名 31 $dbpass = ''; // mysql用户名密码 32 $conn = mysql_connect($dbhost, $dbuser, $dbpass); 33 if(! $conn ) 34 { 35 die('Could not connect: ' . mysql_error()); 36 } 37 38 mysql_select_db('testvideo', $conn); 39 // 设置编码，防止中文乱码 40 mysql_query("set names utf8", $conn); 41 42 $sql = "SELECT * FROM t_vide_warehourse WHERE RW_NAME = '" .$firstCateName. "' AND RW_PARENT_ID = 0 "; 43 $result = mysql_query( $sql, $conn ); 44 if(! $result ) 45 { 46 die('Could not get data: ' . mysql_error()); 47 } 48 else 49 { 50 $num = mysql_num_rows($result); 51 52 if ($num == 0) 53 { 54 $sql = "INSERT INTO t_vide_warehourse (RW_NAME, RW_PARENT_ID) VALUES ('" .$firstCateName. "', 0)"; 55 if (mysql_query($sql, $conn)) { 56 return mysql_insert_id(); 57 }else{ 58 echo "插入一级出错". mysql_error(); 59 } 60 } 61 else 62 { 63 while ($row = mysql_fetch_array($result) ) 64 { 65 return $row["VIDEO_RW_ID"]; 66 } 67 } 68 69 } 70 71 72 //查询 73 mysql_close($conn); 74 } 75 76 77 function insertSecond($secondCateName, $firstCateId) 78 { 79 80 $secondCateName = trim($secondCateName); 81 82 $dbhost = '127.0.0.1'; // mysql服务器主机地址 83 $dbuser = 'root'; // mysql用户名 84 $dbpass = ''; // mysql用户名密码 85 $conn = mysql_connect($dbhost, $dbuser, $dbpass); 86 if(! $conn ) 87 { 88 die('Could not connect: ' . mysql_error()); 89 } 90 91 mysql_select_db('testvideo', $conn); 92 // 设置编码，防止中文乱码 93 mysql_query("set names utf8", $conn); 94 95 $sql = "SELECT * FROM t_vide_warehourse WHERE RW_NAME = '" .$secondCateName. "' AND RW_PARENT_ID = $firstCateId "; 96 $result = mysql_query( $sql, $conn ); 97 if(! $result ) 98 { 99 die('Could not get data: ' . mysql_error()); 100 } 101 else 102 { 103 $num = mysql_num_rows($result); 104 105 if ($num == 0) 106 { 107 $sql = "INSERT INTO t_vide_warehourse (RW_NAME, RW_PARENT_ID) VALUES ('" .$secondCateName. "', $firstCateId)"; 108 if (mysql_query($sql, $conn)) { 109 return mysql_insert_id(); 110 }else{ 111 echo "插入二级级出错". mysql_error(); 112 } 113 } 114 else 115 { 116 while ($row = mysql_fetch_array($result) ) 117 { 118 return $row["VIDEO_RW_ID"]; 119 } 120 } 121 122 } 123 124 125 //查询 126 mysql_close($conn); 127 } 128 129 function insertInfo($baoName, $path, $secondCateId) 130 { 131 132 $baoName = trim($baoName); 133 $path = trim($path); 134 135 $dbhost = '127.0.0.1'; // mysql服务器主机地址 136 $dbuser = 'root'; // mysql用户名 137 $dbpass = ''; // mysql用户名密码 138 $conn = mysql_connect($dbhost, $dbuser, $dbpass); 139 if(! $conn ) 140 { 141 die('Could not connect: ' . mysql_error()); 142 } 143 144 mysql_select_db('testvideo', $conn); 145 // 设置编码，防止中文乱码 146 mysql_query("set names utf8", $conn); 147 148 $sql = "SELECT * FROM t_video_info WHERE VIDEO_TITLE = '" .$baoName. "' AND RW_ID = $secondCateId "; 149 $result = mysql_query( $sql, $conn ); 150 if(! $result ) 151 { 152 die('Could not get data: ' . mysql_error()); 153 } 154 else 155 { 156 $num = mysql_num_rows($result); 157 158 if ($num == 0) 159 { 160 $sql = "INSERT INTO t_video_info (VIDEO_TITLE,PATH, RW_ID) VALUES ('" .$baoName. "', '" .$path. "', $secondCateId)"; 161 if (mysql_query($sql, $conn)) { 162 return mysql_insert_id(); 163 }else{ 164 echo "插入info出错". mysql_error(); 165 } 166 } 167 else 168 { 169 while ($row = mysql_fetch_array($result) ) 170 { 171 return $row["VIDEO_ID"]; 172 } 173 } 174 175 } 176 177 178 //查询 179 mysql_close($conn); 180 } 181 182 function insertFile($infoId, $fileName, $imagePath, $keywords, $fileType, $filePath) 183 { 184 185 $fileName = trim($fileName); 186 $imagePath = trim($imagePath); 187 $keywords = trim($keywords); 188 $fileType = trim($fileType); 189 $filePath = trim($filePath); 190 191 $dbhost = '127.0.0.1'; // mysql服务器主机地址 192 $dbuser = 'root'; // mysql用户名 193 $dbpass = ''; // mysql用户名密码 194 $conn = mysql_connect($dbhost, $dbuser, $dbpass); 195 if(! $conn ) 196 { 197 die('Could not connect: ' . mysql_error()); 198 } 199 200 mysql_select_db('testvideo', $conn); 201 // 设置编码，防止中文乱码 202 mysql_query("set names utf8", $conn); 203 204 $sql = "INSERT INTO t_video_file (VIDEO_ID, FILE_NAME, IMAGEPATH, KEYWORDS, FILE_TYPE, FILE_PATH) VALUES ($infoId, '" .$fileName. "', '" .$imagePath. "', '" .$keywords. "', '" .$fileType. "', '" .$filePath. "')"; 205 206 // echo $sql; 207 208 if (mysql_query($sql, $conn)) { 209 return mysql_insert_id(); 210 }else{ 211 echo "插入文件出错". mysql_error(); 212 } 213 214 215 216 217 218 219 //查询 220 mysql_close($conn); 221 } 222 223 224 225 226 ?>
这里4个函数:
1) insertFrist 给 第一张表插入 第一级分类, 如果重复,返回已有id ; 不重复, 插入,返回新的id;
2)insertSecond 给第一张表 插入 二级分类, 如果重复, 返回已有id; 不重复, 插入,返回新的id;
3)insertInfo 给第二张表插入 数据, 如果重复, 返回已有id; 不重复, 插入,返回新的id;
4)insertFile 给第三张宝插入数据, 对于文件 ,不考虑文件名是否重复.