本文實例講述了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程序設計有所幫助。
新聞熱點
疑難解答
圖片精選
