php 把csv文件导入到mysql数据库

error_reporting(0);// 导入csv格式的文件
$connect=mysql_connect("localhost","root","") or die("could not connect to database");
mysql_select_db("gklqtzcx",$connect) or die (mysql_error());
mysql_query("set names 'gbk'");
$fname = $_files['myfile']['name'];
$handle=fopen("$fname","r");
while($data=fgetcsv($handle,10000,",")){
$q="insert into records (name,classes,a_time,college,notify,receiver,r_time,handler) values ('$data[1]','$data[2]','$data[3]','$data[4]','$data[5]','$data[6]','$data[7]','$data[8]')";
mysql_query($q) or die (mysql_error());
}
fclose($handle);
echo "<meta http-equiv="refresh" content="1;url=list.php">1秒钟转入列表页,请稍等."

?>
<form enctype="multipart/form-data" action="<?php echo"".$_server["php_self"].""; ?>" method="post">
<p>导入cvs数据 <input name="myfile" type="file"> <input value="提交" type="submit">
</p>
</form>

class mysql {
      public $sqlserver = 'localhost';
      public $sqluser = 'root';
      public $sqlpassword = '';
      public $database;

      public $last_query = '';

      private $connection;
      private $query_result;

      public function __construct() {}

      public function __destruct() {
       $this->close();
      }

    //+======================================================+
    // create a connection to the mysql database
    //+======================================================+
    public function connect($server = null, $user = null, $password = null, $database = null){
     if (isset($server)) $this->sqlserver = $server;
     if (isset($user)) $this->sqluser = $user;
     if (isset($password)) $this->sqlpassword = $password;
     if (isset($database)) $this->database = $database;

    $this->connection = mysql_connect($this->sqlserver, $this->sqluser, $this->sqlpassword);
    if($this->connection){
    if (mysql_select_db($this->database)){
    return $this->connection;
    }else{
    return $this->error();
    }
    }else{
    return $this->error();
    }
    }
    //+======================================================+
    // execute a query
    //+======================================================+
    public function query($query, $die = false){
      if ($query != null){
       $this->last_query = $query;
       $this->query_result = mysql_query($query, $this->connection);
       if(!$this->query_result){
        if ($die) die("die: ".$this->query_result);
        return $this->error();
       }else{
        if ($die) die("die: ".$this->query_result);
        return $this->query_result;
       }
      }else{
       echo "empty query cannot be executed!";
      }
    }
    //+======================================================+
    // returns the result
    //+======================================================+
    public function getresult(){
       return $this->query_result;
    }
    //+======================================================+
    // returns the connection
    //+======================================================+
    public function getconnection(){
       return $this->connection;
    }
    //+======================================================+
    // returns an object with properties rep
    //     resenting the result fields www.111cn.net and values
    //+======================================================+
    public function getobject($qry = null){
     if (isset($qry)) $this->query($qry);
     return mysql_fetch_object($this->getresult());
    }
    //+======================================================+
    // returns an array with keys representi
    //     ng the result fields and values
    //+======================================================+
    public function getarray($query_id = ""){
      if($query_id == null){
       $return = mysql_fetch_array($this->getresult());
      }else{
       $return = mysql_fetch_array($query_id);
      }
      return $return ? $return : $this->error();
    }
    //+======================================================+
    // returns the number of rows in the res
    //     ult
    //+======================================================+
      public function getnumrows($qry = null){
       if (isset($qry)) $this->query($qry);
       $amount = mysql_num_rows($this->getresult());
       return empty($amount) ? 0 : $amount;
    }
    //+======================================================+
    // returns if the result contains rows
    //+======================================================+
    public function hasresults($qry = null) {
      if (isset($qry)) $this->query($qry);
     return $this->getnumrows($qry) > 0;
    }
    //+======================================================+
    // returns the number of rows that where
    //     affected by the last action
    //+======================================================+
    public function getaffectedrows($qry = null, $query_id = null){
      if (isset($qry)) $this->query($qry);
      if(empty($query_id)){
       $return = mysql_affected_rows($this->getresult());
      }else{
       $return = mysql_affected_rows($query_id);
      }
      return $return ? $return : $this->error();
    }
    //+======================================================+
    // returns the auto generated id from th
    //     e last insert action
    //+======================================================+
    public function getinsertid($connection_link = null){
    return mysql_insert_id(isset($connection_link) ? $connection_link : $this->connection);
    }
    //+======================================================+
    // close the connection to the mysql dat
    //     abase
    //+======================================================+
    public function close(){
    if(isset($this->connection)){
    return @mysql_close($this->connection);
    }
    else {
     return $this->error();
    }
    }
    //+======================================================+
    // outputs the mysql error
    //+======================================================+
    private function error(){
    if(mysql_error() != ''){
    echo '<b>mysql errorwww.111cn.net</b>: '.mysql_error().'<br/>';
    }
    }
    }

    //demo
    // database object initialization
$db = new mysql();
$db->connect("localhost", "root", "123456", "user");

// update query
//$db->query("update table_name set field_name = value where another_field = another_value");

// select with check for record amount

if ($db->hasresults("select * from userinfo")) {
//   loop through the user records, and get them as objects
//   note that the getobject method will use the last executed query when not provided with a new one
  while ($user = $db->getobject()) {
    echo "user $user->username is called $user->password<br /> ";
  }
}
else {
  echo "no results where found";
}

class excel{

    /**
     *头的excel文件（前缀的行）
     *
     *从excel复制的xml规格。
     *
     * @访问私有
     * @无功串
     */
    var $header = "<?xml version="1.0" encoding="utf-8"?>
<workbook xmlns="urn:schemas-microsoft-com:office:spreadsheet"
 xmlns:x="urn:schemas-microsoft-com:office:excel"
 xmlns:ss="urn:schemas-microsoft-com:office:spreadsheet"
 xmlns:html="http://www.w3.org/tr/rec-html40">";

    /**
     *页脚的excel文件（附加到行）
     *
     *从excel复制的xml规格。
     *
     * @访问私有
     * @无功串
     */
    var $footer = "</workbook>";

    /**
     * document lines (rows in an array)
     *
     * @access private
     * @var array
     */
    var $lines = array ();

    /**
     工作表名称
     *
     *包含一个单一的工作表名称
     *
     * @访问私有
     * @无功串
     */
    var $worksheet_title = "table1";

    /**
  添加一个单行的文档字符串$
     *
     * @访问私有
     * @帕拉姆库马拉阵列一维阵列
     * @待办事项行创造应做减本-> addarray
     */
    function addrow ($array) {

        // initialize all cells for this row
        $cells = "";
       
        // foreach key -> write value into cells
        foreach ($array as $k => $v):
   
         // 加个字符串与数字的判断 避免生成的 excel 出现数字以字符串存储的警告
         if(is_numeric($v)) {
          // 防止首字母为 0 时生成 excel 后 0 丢失
          if(substr($v, 0, 1) == 0) {
           $cells .= "<cell><data ss:type="string">" . $v . "</data></cell> ";
          } else {
           $cells .= "<cell><data ss:type="number">" . $v . "</data></cell> ";
          }
         } else {
             $cells .= "<cell><data ss:type="string">" . $v . "</data></cell> ";
         }

        endforeach;

        // transform $cells content into one row
        $this->lines[] = "<row> " . $cells . "</row> ";

    }

    /**
    *添加一个数组到文档
     *
     *这应该是唯一的方法需要生成一个excel
     *文件。
     *
     * @访问公开
     * @帕拉姆库马拉数组二维数组
     * @待办事项可以转移到__construct（）稍后
     */
    function addarray ($array) {

        // run through the array and add them into rows
        foreach ($array as $k => $v):
            $this->addrow ($v);
        endforeach;

    }

    /**
    设置工作表名称
     *
     *检查的字符串不允许字符（： /?*),
     *削减它的最大31个字符，并设置标题。该死
     *为何未允许字符无处可寻？视窗
     *帮助没有帮助...
     *
     * @访问公开
     * @帕拉姆库马拉字符串$标题设计标题
     */
    function setworksheettitle ($title) {

        // strip out special chars first
        $title = preg_replace ("/[\|:|/|?|*|[|]]/", "", $title);

        // now cut it to the allowed length
        $title = substr ($title, 0, 31);

        // set title
        $this->worksheet_title = $title;

    }

   /**
     *生成excel文件
     *
     *最后生成的excel文件，并使用header（）函数
     *提供给浏览器。
     *
     * @访问公开
     * @帕拉姆库马拉字符串$文件名名称的excel文件来生成（... xls）中
     */
    function generatexml ($filename) {

        // deliver header (as recommended in php manual)
        header("content-type: application/vnd.ms-excel; charset=utf-8");
        header("content-disposition: inline; filename="" . $filename . ".xls"");

        // print out document to the browser
        // need to use strips教程lashes for the damn ">"
        echo stripslashes ($this->header);
        echo " <worksheet ss:name="" . $this->worksheet_title . ""> <table> ";
        echo "<column ss:index="1" ss:autofitwidth="0" ss:width="110"/> ";
        echo implode (" ", $this->lines);
        echo "</table> </worksheet> ";
        echo $this->footer;

    }

}

$conn = new com("adodb.connection");
$connstr = "driver={microsoft access driver (*.mdb)}; dbq=". realpath("data/db.mdb");

$conn->open($connstr);
$rs = new com("adodb.recordset");
$rs->open("select * from szd_t",$conn,1,1);
while(! $rs->eof)
$f = $rs->fields(1);
echo $f->value;
$rs->movenext();

 * created on 2010-4-21
 *
 * the class for control mysql
 *
 * made by s71ence
 *
 * @$host
 * @$user_name
 * @$user_pwd
 * @$data_base
 * @$coding
 */
 class mysql
 {
 private $host;//主机名
 private $user_name;//用户名
 private $user_pwd;//密码
 private $data_base;//数据库名
 private $coding;//编码

//构造函数 进行初始化操作
 function __construct($host,$user_name,$user_pwd,$data_base,$coding)
 {
  $this->host=$host;
  $this->user_name=$user_name;
  $this->user_pwd=$user_pwd;
  $this->data_base=$data_base;
  $this->coding=$coding;
  $this->connect();//初始化连接
 }

/*********************************************************************************************
 * 数据库
 * 基本方法
 ********************************************************************************************/

//数据库连接
 function connect()
 {
  $link=mysql_connect($this->host,$this->user_name,$this->user_pwd) or die($this->error());
  mysql_select_db($this->data_base,$link) or die("无法连接数据库".$this->data_base);
  mysql_query("set names '$this->coding'");
 }

//错误信息
 function error()
 {
  return mysql_error();
 }

//mysql_query()方法
 function query($sql, $type = '')
 {
     if(!($query = mysql_query($sql)))
  {
   $this->show('say:', $sql);
  }

  //echo $sql."<br/>";//测试完成后 注释
     return $query;
 }

//sql语句显示
 function show($message = '', $sql = '')
 {
  if(!$sql)
  {
   echo $message;
  }
  else
  {
   echo $message.'<br>'.$sql;
  }
 }

//mysql_affected_rows()方法
    function affected_rows()
 {
  return mysql_affected_rows();
 }

//mysql_result方法
 function result($query, $row)
 {
  return mysql_result($query, $row);
 }

//mysql_num_rows方法
 function num_rows($query)
 {
  return @mysql_num_rows($query);
 }

//mysql_num_fields方法
 function num_fields($query)
 {
  return mysql_num_fields($query);
 }

//mysql_free_result方法
 function free_result($query)
 {
  return mysql_free_result($query);
 }

//mysql_insert_id方法
 function insert_id()
 {
  return mysql_insert_id();
 }

//mysql_fetch_row方法
 function fetch_row($query)
 {
  return mysql_fetch_row($query);
 }

//mysql_get_server_info方法
 function version()
 {
  return mysql_get_server_info();
 }

//mysql_fetch_array()方法
 function fetch_array($result)
 {
  return mysql_fetch_array($result);
 }

//mysql_close方法
 function close()
 {
  return mysql_close();
 }

/*********************************************************************
 * 数据库
 * 功能方法
 *********************************************************************/

/*
 * insert方法
 *  $table 表名
 * $fields 字段名
 * $value 字段值
 */

 function fn_insert($table,$fields,$values)
 {
  return $this->query("insert into $table ($fields) values ($values)");
  $this->close();
 }

/*
 * select方法
 *  $table 表名
 * $fields 字段名
 * $condition 查询条件
 * $order 排序条件
 * $limit 取出条数
 */
 function fn_select($table,$fields,$condition,$order,$limit)
 {
  $query="select $fields from $table";

  if($condition!="")
  {
   $query.=" where $condition";
  }

  if($order!="")
  {
   $query.=" order by $order ";
  }

  if($limit!="")
  {
   $query.=" limit $limit";
  }

  return $this->query($query);
  $this->close();
 }

/*
 * delete方法
 * $table 表名
 * $fields 字段名
 * $values 字段值
 */
 function fn_delete($table,$condition)
 {
  return $this->query("delete from $table where $condition");
  $this->close();
 }

/*
 * update方法
 * $table 表名
 * $fields 字段名
 * $values 字段值
 */
 function fn_update($table,$set,$condition)
 {
  $sql="update $table set $set";
  if($condition!="")
  {
   $sql.=" where $condition";
  }

  return $this->query($sql);
  $this->close();
 }

/*
 * 析构函数，垃圾回收
 */
 function __destruct()
 {
  //echo "clear";
    }
 }
 

 $db =  new mysql('127.0.0.1','username','password','databasename',"utf8");