PHP使用PDO操作sqlite数据库应用案例
时间:2022-07-27
本文章向大家介绍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;
}
}
- 重学javascript 红皮高程(6)
- WriteUp分享 | LCTF的一道preg_match绕过+出题人的锅
- 利用crypto++库实现AES加密算法
- Android之倒计时CountdownTimer用法
- WriteUp分享 | LCTF的一道padding oracle攻击+sprintf格式化字符串导致的SQL注入
- 10.27 target介绍
- Android 之游戏开发流程
- shell脚本后台运行
- Android的.so文件你需要知道那些知识
- xshel配色方案
- cocos2dx-v3.5 2048 (一): 项目架构
- cocos2dx-v3.5 2048 (二): GameTool的设计与实现
- cocos2dx-v3.5 2048(三):菜单实现
- 2017 LCTF WriteUp 4篇
- php概述
- php教程
- php环境搭建
- PHP书写格式
- php变量
- php常量
- PHP注释
- php数组
- php字符串 string
- PHP整型 integer
- PHP浮点型 float
- php布尔型
- php数据类型之数组
- php数据类型之对象
- php数据类型之null
- php数据类型之间的转换
- php运算符
- php表达式
- PHP循环控制
- PHP流程控制
- php函数
- php全局变量
- PHP魔术变量
- php命名空间
- php 日期
- PHP包含文件
- php文件
- PHP 文件上传
- php Cookies
- php Sessions
- php email
- php安全email
- php错误处理
- PHP异常处理
- php过滤器
- PHP 高级过滤器
- php json
- php 表单
- PHP MySQL 简介
- PHP 连接 MySQL
- php创建数据库
- php 创建表
- php mysq 插入数据
- PHP MySQL 插入多条数据
- PHP MySQL 预处理语句
- php mysql 读取数据
- php mysql where
- PHP MySQL Order By
- PHP MySQL Update
- PHP MySQL Delete
- php ODBC
- 浙大版《C语言程序设计(第3版)》题目集 练习2-15 求简单交错序列前N项和
- 浙大版《C语言程序设计(第3版)》题目集 练习2-17 生成3的乘方表
- WPF 漂亮的现代化控件 新 ModernWPF 界面库
- 浙大版《C语言程序设计(第3版)》题目集 练习2-18 求组合数
- 浙大版《C语言程序设计(第3版)》题目集 习题2-1 求整数均值
- PHP 正则表达式 获取富文本中的 img标签的src属性
- 浙大版《C语言程序设计(第3版)》题目集 习题2-2 阶梯电价
- 浙大版《C语言程序设计(第3版)》题目集 习题2-3 求平方与倒数序列的部分和
- 浙大版《C语言程序设计(第3版)》题目集 习题2-4 求交错序列前N项和
- 二十五块DIY 带屏幕可远程的温湿度传感器
- 浙大版《C语言程序设计(第3版)》题目集 习题2-5 求平方根序列前N项和
- 浙大版《C语言程序设计(第3版)》题目集 习题2-6 求阶乘序列前N项和
- 案例:ADG环境遇到redo日志member路径有误以及RMAN-6571错误
- 浙大版《C语言程序设计(第3版)》题目集 练习3-2 计算符号函数的值
- 浙大版《C语言程序设计(第3版)》题目集 练习3-3 统计学生平均成绩与及格人数