CSV 파일을 읽어들여 DB에 저장하는 소스코드

CREATE TABLE IF NOT EXISTS `mb_old` (
  `mb_no` int(11) NOT NULL AUTO_INCREMENT,
  `mb_id` varchar(20) NOT NULL,
  `mb_password` varchar(255) NOT NULL,
  `mb_name` varchar(255) NOT NULL,
  PRIMARY KEY (`mb_no`),
  KEY `mb_id` (`mb_id`)
) ENGINE=InnoDB  DEFAULT CHARSET=utf8 ;

<?php
include_once(“./dbconfig.php”);

// DB Connect
$connect = mysql_connect($mysql_host, $mysql_user, $mysql_password);
if(!$connect) {
    die(“Can’t Connect DB : ” . mysql_error());
}
@mysql_query(” set names utf8 “);
$db_selected = mysql_select_db($mysql_db, $connect);
if(!$db_selected) {
    die(“Can’t    Use $mysql_db : ” . mysql_error());
}

function mysql_password($value) // 비밀번호 암호화 함수
{
    $sql = ” select password(‘$value’) as pass “;
    $result = mysql_query($sql);
    $row = mysql_fetch_assoc($result);
    return $row[pass];
}

$csv = “./member.csv”;

$lines = file($csv); // member.csv 파일 전체를 배열로 읽어들임
$count = count($lines); // 파일의 라인 수

for($i = 1; $i < $count; $i++) {
    // csv 파일의 두번째 라인부터 DB에 입력해야 하므로 $i = 1
    $str = explode(“,”, rtrim($lines[$i], “rn”));

    $mb_id = trim(strip_tags(mysql_escape_string(addslashes($str[0]))));
    if(!$mb_id) { // mb_id 없으면 다음 라인
        continue;
    }
    $mb_password = mysql_password(trim(mysql_escape_string(addslashes($str[1]))));
    $mb_name = trim(strip_tags(mysql_escape_string(addslashes($str[2]))));

    $sql = ” insert into mb_old (mb_id, mb_password, mb_name) values (‘$mb_id’, ‘$mb_password’, ‘$mb_name’) “;
    $result = mysql_query($sql);

    if(!$result) { // 쿼리 에러 시 다음 라인
        continue;
    }
}
?>