본문 바로가기
Work/php

파일에서 데이터 가져 와서 디비(mysql)에 데이터 집어 넣기

by 승수 2010. 2. 10.


요즘은 회사에서 php도 조금씩 ....ㅋ

<?
  if ($mode == 'socket') {
      echo " 테이블의 기존데이터 삭제를 시작합니다. ~~~!!! \n\n ";

      $start_time = date("Y-m-d : H-i-s");
      echo " start_time : $start_time \n\n ";
      echo " 종류 : $type \n";
      echo " =================================== \n\n ";
  }

  // Configuration :
     $yesterday = date("Ymd", mktime(0,0,0,date("m") ,date("d")-1, date("Y")) );
   //  $yesterday = date("Ymd", mktime(0,0,0,date("m") ,date("d"), date("Y")) );
     //die($yesterday);

  //$filename = "daninfo1.".$yesterday; //<---------------- 파일이 날짜별로 생성시 응용
  $filename = "20060926.txt"; //<----------------- 데이터를 가져올 파일 이름
 //2009218 수정
     $src = "/dbspaces/web/update_integrate_oss/workinfo_yss/data/".$filename; // Source file //<-------- 데이터를 가져올 파일이 있는 경로명
  // Open the file :
     $line = file($src);

 if($line) {

   $dbconn = mysql_connect("localhost","test","test123") or die("DB서버 연결에 실패하였습니다!");//<------------- 디비 접속 정보 경로 // 아이디 // 비번
   //20090218 수정
   $status = mysql_select_db("test_smdb",$dbconn); // <------ 사용 database

   $delqry = "delete from workinfo_yss";
   $del_result = mysql_query($delqry, $dbconn);

   if($del_result) {
      echo(" \n 삭제가 정상적으로 수행 되었습니다.\n");


     $cnt = 0;
     while(list($key,$val) = each($line)) {   // 파일을 열어 각 라인마다 읽어들인다

        $val = trim($val);                              // 라인의 앞뒤 공백 제거
        $arr = split("\|",$val);                      // '|'로 문자열 분리

        $uid = trim($arr[0]);
  
  //20060210추가
  if($uid == "" || $uid == " " || $uid == null) continue;


        $fid = trim($arr[1]);
        $work_day = trim($arr[2]);
        $damdang = trim($arr[3]);
        $damdang_tel = trim($arr[4]);
        $writer = trim($arr[5]);
        $writer_tel = trim($arr[6]);
        $last_w = trim($arr[7]);
        $cusname = trim($arr[8]);
        $smpart = trim($arr[9]);
        $cus_tel = trim($arr[10]);
        $cus_fax = trim($arr[11]);
        $ref = trim($arr[12]);
        $sender = trim($arr[13]);
        $sender_tel = trim($arr[14]);
      $volume = trim($arr[15]);
        $subject = trim($arr[16]);
        $content = trim($arr[17]);
       $lineinfo = trim($arr[18]);
    $workdate = trim($arr[19]);
  $damage = trim($arr[20]);
        $tongjae = trim($arr[21]);
        $workman = trim($arr[22]);
        $checkflag = trim($arr[23]);
        $thread = trim($arr[24]);
        $cusgrp = trim($arr[25]);
        $worknum = trim($arr[26]);
        $num = trim($arr[27]);
        $cusgrpname = trim($arr[28]);


        $query = "insert into workinfo_yss values('$uid','$fid','$work_day','$damdang','$damdang_tel','$writer','$writer_tel','$last_w','$cusname','$smpart','$cus_tel','$cus_fax','$ref','$sender','$sender_tel','$volume','$subject','$content','$lineinfo','$workdate','$damage','$tongjae','$workman','$checkflag','$thread','$cusgrp','$worknum','$num','$cusgrpname')";

        $result = mysql_query($query, $dbconn);

        $cnt++;

     } // end of while

     echo(" 총 $cnt 개의 자료가 업로드 되었습니다.\n");
  }
  mysql_close($dbconn);

 }


  if ($mode == 'socket') {
     echo " 성공적으로 업로드 작업이 끝났습니다.~~~!!! \n\n ";

      $end_time = date("Y-m-d : H-i-s");
      echo " end_time : $end_time \n\n ";
  }


?>

 

'Work > php' 카테고리의 다른 글

mysql_num_rows() 관련  (0) 2010.10.22