书接上文,将查询结果导出到文件,遇到文件已存在的情况,怎么办?MySQL 又不能覆盖或者说替换掉原来的文件,在吃饭的时候,经由 XCY
、XTH
、YXD
、YMQ
的点化,我们可以每次都对文件动态命名,只要保证每次的名字都是唯一的就可以了呗,显然最容易想到的就是利用时间戳来作为文件的名字啦。
那么具体如何实现? Talk is cheap! Show me the code.
set @sql = concat(
"SELECT '用户名', '密码', '身份' UNION ALL
SELECT u.UserName, u.PassWord, u.Status FROM news_tagging_app_user as u INTO OUTFILE 'D:/PythonProject/news_tagging_system/news_tagging_app/static/tag_result/", UNIX_TIMESTAMP(), ".csv'
CHARACTER SET gbk
FIELDS TERMINATED BY ','
LINES TERMINATED BY '\r\n'
");
prepare execsql from @sql;
EXECUTE execsql;
--------------------------------------------------------------------------------------
补充说明:
① MySQL 变量的定义、使用和查看。
② MySQL 中 SQL 语句之字符串拼接函数 contact 。
③ MySQL 时间戳函数 UNIX_TIMESTAMP() 。
exmaple 如下。(纸上得来终觉浅,绝知此事要躬行。)
--------------------------------------------------------------------------------------
SET @num := UNIX_TIMESTAMP();
SET @file := CONCAT('D:/PythonProject/news_tagging_system/news_tagging_app/static/tag_result/',@num,'.csv');
SELECT @file;
思考:为什么下面的写法是错误的?
SET @num := UNIX_TIMESTAMP();
SELECT "用户名", "密码", "身份" UNION ALL
SELECT u.UserName, u.PassWord, u.Status FROM news_tagging_app_user as u INTO OUTFILE CONCAT('D:/PythonProject/news_tagging_system/news_tagging_app/static/tag_result/',@num,'.csv')
CHARACTER SET gbk #将查询结果转换为GB2312格式
FIELDS TERMINATED BY ',' #指定列之间分隔符
LINES TERMINATED BY '\r\n'
;
再谈需求:每隔一定时间将数据导出至本地保存,当用户请求下载时,始终提供最新导出的数据。
因此,要解决上面的问题,我们可以结合前面文章介绍到的定时器,每隔一段时间导出一次数据
Code as follows
# 如果原来存在该名字的任务计划则先删除
drop event if exists export_tag_result;
# 设置分隔符为 '$$' ,mysql默认的语句分隔符为 ';' ,这样在后续的 create 到 end 这段代码都会看成是一条语句来执行
DELIMITER $$
CREATE EVENT export_tag_result
ON SCHEDULE EVERY 10 SECOND
DO
BEGIN
SET @sql = concat(
"SELECT '用户名', '密码', '身份' UNION ALL
SELECT u.UserName, u.PassWord, u.Status FROM news_tagging_app_user as u INTO OUTFILE 'D:/PythonProject/news_tagging_system/news_tagging_app/static/tag_result/", UNIX_TIMESTAMP(), ".csv'
CHARACTER SET gbk
FIELDS TERMINATED BY ','
LINES TERMINATED BY '\r\n'
");
PREPARE execsql from @sql;
EXECUTE execsql;
END $$
# 将语句分割符设置回 ';'
DELIMITER ;
上述这段代码参考这篇文章较多,值得一看。
生成的结果如下图所示:
接下来就是要找出最新版本了,我们使用 Python 代码进行寻找。代码如下:
import os
list_dir = os.listdir('D:\\PythonProject\\news_tagging_system\\news_tagging_app\static\\tag_result')
num = []
for each_file in list_dir:
num.append(each_file.split('.')[0]) #取文件名的前缀用于比较大小
last_result = max(num) #因为文件名是使用的时间戳命名,所以最大的就是最新保存的版本
print(last_result)
附
该文章于2017年9月29日于CSDN上首次发表,2017年12月24日搬家至此!