PHP使用PDO操作sqlite数据库应用案例

本文实例讲述了php使用pdo操作sqlite数据库。分享给大家供大家参考，具体如下：

1、需求：

已知：

1)、一个json文件，里面是一个二维数组，数组解析出来为：

array (
   0 =>
   array (
    'title' => '九十九',
   ),
   1 =>
   array (
    'title' => '电脑九十九',
   ),
   2 =>
   array (
    'title' => '手机九十九',
   ),
   3 =>
   array (
    'title' => '手机电脑九十九',
   ),
);

2)、一个sqlite数据库文件 20180824.db 新建一个sqlite数据库文件

新建表 report

表字段 id words time

求：

把从json中查到的数据，在sqlite中检索，判断是否存在；
如果存在就给sqlite加上一个 word_sort字段，把title在文件中是第几个(一次递增，不是json文件数组的键值)写入到word_sort字段

思路：

① 获取jsonlist.json文件内容并json_decode($str,true)转为二维数组
② 连接sqlite表
③ try{}catch(){} 给表增加 word_sort字段
④ 把json文件中的数据数组化
⑤ 每次循环5000条json数据，用 in 在report表中查询（title字段需要拼接）
⑥ 把查询出来的数据用 sql的批量跟新语句拼接
⑦ try{}catch(){}批量更新report表数据
⑧ echo输出运行结果

2、php代码(yaf框架)：

<?php
/**
 * @todo 组词
 * class communitycontroller
 */
class combinwordcontroller extends rest{
  /**
   * @todo 判断.json数据是否存在，存在把数据往前排
   * @linux 212 /usr/local/php7/bin/php /var/www/web/shop/public/cli.php request_uri="/v1/combinword/index"
   */
  public function indexaction(){
    set_time_limit ( 0 );  //设置时间不过时
    $data = $this->getjson();  //获取json数据
    $dbfile_path = app_path.'/data/combinword/20180824.db';
    $db = new pdo("sqlite:{$dbfile_path}");
    //设置数据库句柄    属性 pdo::attr_errmode：错误报告。   pdo::errmode_exception: 抛出 exceptions 异常。
    $db->setattribute(pdo::attr_errmode, pdo::errmode_exception);
    //加combinword字段 start
    $add_filed = 'word_sort';
    $add_filed_sql = "alter table report add {$add_filed} text(32)";
    try {
      $db->begintransaction();//启动事务
      $db->exec($add_filed_sql);  //加字段
      $db->commit();//提交事务
    }catch(pdoexception $e){
      //$e->getmessage();//获取错误信息。
      echo '字段已经存在'.php_eol;
      $db->rollback();//回滚，如果一个地方出现错误，回到总体操作之前。
    }
    //加combinword字段 end
    $addstep = 5000;  //每次操作的数据
    $word_cnt = 0;
    $succ_cnt = 0;
    $sort = 0;
    $total = count($data);
    for ( $x=0; $x<$total; $x += $addstep ){
      $temp_json = array_slice($data, $x, $addstep);  //批量操作 100条
      $temp_json = array_column( $temp_json, "title" );
      $temp_json = array_unique($temp_json);
      $temp_str = $this->getstrbyarr($temp_json);
      $temp_sql = "select * from report where words in ({$temp_str})";
      $res = $db->query($temp_sql);
      $result = $res->fetchall(pdo::fetch_assoc);  //获取数组结果集
      $words_result = array_column($result, 'words'); //结果去重
      $unique_result = array_unique($words_result);
      //var_export($unique_result);die;
      //批量更新 start
      $update_sql = "update report set {$add_filed} = case words ";
      foreach ($unique_result as $k => $v){
        $updatevalue = $v;
        $update_sql .= " when '{$updatevalue}' then ".$sort++;
      }
      $sort += count($unique_result);  //加上排序字段
      $update_sql_str = $this->getstrbyarr( $unique_result );
      $update_sql .= " end where words in ({$update_sql_str})";
        //var_export($update_sql);die;
      try {
        $db->begintransaction();//启动事务
        $cnt = $db->exec($update_sql);  //加字段
        $db->commit();//提交事务
        $word_cnt += count($result);
        $succ_cnt += $cnt;
        echo "更新了[{".count($result)."}]个关键字，共影响了[{$cnt}]条数据 ".php_eol;
      }catch(pdoexception $e){
        //$e->getmessage();//获取错误信息。
        echo "批量更新失败 ".php_eol;
        $db->rollback();//回滚，如果一个地方出现错误，回到总体操作之前。
      }
      //批量更新end
    }
    echo "一共更新了[{$word_cnt}]个关键字，共影响了[{$succ_cnt}]条数据 ".php_eol;
    die;
  }
  /**
   * @todo 根据数组返回拼接的字符串
   * @param unknown $temp_json 数组
   * @return string 字符串
   */
  function getstrbyarr($temp_json){
    $temp_str = '';
    $count = count($temp_json);
    $lastvalue = end($temp_json);//var_export($lastvalue);die;  //获取数组最后一个元素
    foreach ($temp_json as $k => $v){
      $next_str = '';
      if($v != $lastvalue ){  //不是最后一个
        $next_str = ',';
      }else{
        $next_str = '';
      }
      $temp_str .= "'".$v."'{$next_str}";
    }
    return $temp_str;
  }
  /**
   * @todo 获取json数据
   */
  public function getjson(){
    $filename = app_path.'/data/combinword/jsonlist.json';
    $json = file_get_contents($filename);
    $array = json_decode($json, true);
    return $array;
  }
}

更多关于php相关内容感兴趣的读者可查看本站专题：《php基于pdo操作数据库技巧总结》、《php+oracle数据库程序设计技巧总结》、《php+mongodb数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家php程序设计有所帮助。