MySQL 将查询结果导出到文件（续）

书接上文，将查询结果导出到文件，遇到文件已存在的情况，怎么办？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日搬家至此！