db_update_cs6_para.php 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. <?php
  2. require_once "../public/_pdo.php";
  3. require_once "../path.php";
  4. $db_file = _FILE_DB_PAGE_INDEX_;
  5. PDO_Connect("sqlite:$db_file");
  6. // 打开文件并读取数据
  7. $irow=0;
  8. if(($fp=fopen("./cs6_para.csv", "r"))!==FALSE){
  9. // 开始一个事务,关闭自动提交
  10. $PDO->beginTransaction();
  11. $query="INSERT INTO cs6_para ('book','para','book_name','cspara') VALUES ( ? , ? , ? , ? )";
  12. $stmt = $PDO->prepare($query);
  13. // 提交更改
  14. try{
  15. while(($data=fgetcsv($fp,0,','))!==FALSE){
  16. $irow++;
  17. if($irow>1){
  18. if($data[3]==$data[4]){
  19. $stmt->execute(array($data[0],$data[1],$data[2],$data[3]));
  20. }
  21. else{
  22. $begin = (int)$data[3];
  23. $end = (int)$data[4];
  24. $arr1=array();
  25. for($i=$begin; $i<=$end; $i++){
  26. $arr1[] = $i;
  27. }
  28. foreach ($arr1 as $key => $value) {
  29. $stmt->execute(array($data[0],$data[1],$data[2],$value));
  30. }
  31. }
  32. }
  33. }
  34. $PDO->commit();
  35. }catch (Exception $e){
  36. var_dump($e);
  37. $PDO->rollback();
  38. }
  39. if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
  40. $error = PDO_ErrorInfo();
  41. echo "error - $error[2] \n";
  42. }
  43. else{
  44. echo "updata recorders.\n";
  45. }
  46. fclose($fp);
  47. }
  48. else{
  49. echo "can not open csv file. cs6_para.csv";
  50. }
  51. echo "齐活!功德无量!all done!";
  52. ?>