PHP使用PDO操作sqlite数据库应用案例
发布:smiling 来源: PHP粉丝网 添加日期:2021-11-11 17:02:36 浏览: 评论:0
这篇文章主要介绍了PHP使用PDO操作sqlite数据库,结合实例形式分析了php基于yaf框架使用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;
- }
- }
Tags: PDO sqlite
- 上一篇:PHP实现的敏感词过滤方法示例
- 下一篇:PHP实现会员账号单唯一登录的方法分析
相关文章
- ·PDO版本问题 Invalid parameter number: no parameters were bound(2013-12-03)
- ·pdo连接数据类与中文乱码解决方法(2014-09-11)
- ·pdo连接数据库与查询与保存数据到mysql(2014-09-11)
- ·pdo连接access数据库代码(2014-09-11)
- ·php实现基于PDO的预处理示例(2018-08-31)
- ·Linux(CentOS)下PHP扩展PDO编译安装的方法(2019-10-04)
- ·PHP中PDO的事务处理分析(2019-10-04)
- ·PHP的PDO操作简单示例(2019-10-31)
- ·PHP5.2中PDO的简单使用方法(2019-11-06)
- ·如何获取PDO对象并设置属性?(代码详解)(2020-02-03)
- ·如何使用PDO进行SELECT查询?(代码示例)(2020-02-03)
- ·PHP PDOStatement:bindParam插入数据错误问题分析(2020-07-02)
- ·PDO预处理语句PDOStatement对象使用总结(2021-04-27)
- ·PHP PDOStatement对象bindpram()、bindvalue()和bindcolumn之间的区别(2021-04-27)
- ·php使用pdo连接并查询sql数据库的方法(2021-05-04)
- ·php使用pdo连接mssql server数据库实例(2021-05-04)
推荐文章
热门文章
最新评论文章
- 写给考虑创业的年轻程序员(10)
- PHP新手上路(一)(7)
- 惹恼程序员的十件事(5)
- PHP邮件发送例子,已测试成功(5)
- 致初学者:PHP比ASP优秀的七个理由(4)
- PHP会被淘汰吗?(4)
- PHP新手上路(四)(4)
- 如何去学习PHP?(2)
- 简单入门级php分页代码(2)
- php中邮箱email 电话等格式的验证(2)