怎么在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中使用PDO操作sqlite數據庫，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。