Yii框架批量插入数据扩展类的简单实现方法

本文实例讲述了Yii框架批量插入数据扩展类的简单实现方法。分享给大家供大家参考，具体如下：

MySQL INSERT语句允许插入多行数据，如下所示：

    INSERT INTO tbl_name (a,b,c) VALUES(1,2,3),(4,5,6),(7,8,9);

那么要实现批量插入，主要的任务就是按照列顺序，把数据组装成上述格式即可，可以使用sprintf和vsprintf函数来实现。

下面是一个实现批量插入的Yii扩展类的简单示例（支持VARCHAR类型数据）：

    <?php
    /**
     * class for sql batch insert
     */
    class CDbBICommand extends CDbCommand{
      /** @var CActiveRecord $class */
      private $class;
      /** @var string $insert_tpl */
      private $insert_tpl = "insert into %s(%s) ";
      /** @var string $value_tpl */
      private $value_tpl = "(%s)";
      /** @var string $query */
      public $query;
      /** @var CDbColumnSchema[] $columns */
      private $columns;
      /** @var boolean $fresh */
      private $fresh;
      /** @param CActiveRecord $class
       * @param CDbConnection $db
       */
      public function __construct($class,$db){
       $this->class = $class;
       $this->createtpl();
       parent::_construct($db);
      }
      private function createtpl(){
       $this->fresh = true;
       $value_tpl = "";
       $columns_string = "";
       $this->columns = $this->class->getMetaData()->tableSchema->columns;
       $counter = 0;
       foreach($this->columns as $column){
        /** @var CDbColumnSchema $column */
        if($column->autoIncrement){
         $value_tpl .= "0";
        }else{
         $value_tpl .= "\"%s\"";
        }
        $columns_string .= $column->name;
        $counter ++;
        if($counter != sizeof($this->columns)){
         $columns_string .= ", ";
         $value_tpl .= ", ";
        }
       }
       $this->insert_tpl = sprintf($this->insert_tpl, $this->class->tableName(), $columns_string);
       $this->value_tpl = sprintf($this->value_tpl, $value_tpl);
      }
      /**
       * @param CActiveRecord $record
       */
      public function add($record){
       $values = array();
       $i = 0;
       foreach($this->columns as $column){
        if($column->autoIncrement){
         continue;
        }
        $values[$i] = $this->class->{$column->name};
        $i ++;
       }
       if(!$this->fresh){
        $this->query .= ",";
       }else{
        $this->query = "values";
       }
       $this->fresh = false;
       $this->query .= vsprintf($this->value_tpl, $values);
       return true;
      }
      public function execute(){
       $this->setText($this->insert_tpl." ".$this->query);
       return parent::execute();
      }
    }

使用方法是通过add方法逐个加入数据，然后调用execute执行。

更多关于Yii相关内容感兴趣的读者可查看本站专题：《Yii框架入门及常用技巧总结》、《php优秀开发框架总结》、《smarty模板入门基础教程》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家基于Yii框架的PHP程序设计有所帮助。