首页 > 数据库技术 > 详细

Scrapy小技巧-MySQL存储, MYSQL拼接

时间:2018-10-04 02:36:10      阅读:176      评论:0      收藏:0      [点我收藏+]

这两天上班接手,别人留下来的爬虫发现一个很好玩的 SQL脚本拼接。

只要你的Scrapy Field字段名字和 数据库字段的名字 一样。那么恭喜你你就可以拷贝这段SQL拼接脚本。进行MySQL入库处理。

具体拼接代码如下:

    def process_item(self, item, spider):
        if isinstance(item, WhoscoredNewItem):
            table_name = item.pop(‘table_name‘)
            col_str = ‘‘
            row_str = ‘‘
            for key in item.keys():
                col_str = col_str + " " + key + ","
                row_str = "{}‘{}‘,".format(row_str, item[key] if "‘" not in item[key] else item[key].replace("‘", "\\‘"))
                sql = "insert INTO {} ({}) VALUES ({}) ON DUPLICATE KEY UPDATE ".format(table_name, col_str[1:-1], row_str[:-1])
            for (key, value) in six.iteritems(item):
                sql += "{} = ‘{}‘, ".format(key, value if "‘" not in value else value.replace("‘", "\\‘"))
            sql = sql[:-2]
            self.cursor.execute(sql) #执行SQL
            self.cnx.commit()# 写入操作

  

 

这个SQL拼接实现了,如果数据库存在相同数据则 更新,不存在则插入 的SQL语句

具体实现就是第一个for循环,获取key作为MySQL字段名字、VALUES做为SQL的VALUES(拼接成一个插入的SQL语句)

第二个for循环,实现了 字段名 = VALUES的拼接。

和第一个for循环的中的sql就组成了 insert into  XXXXX   on duplicate key update 这个。存在则更新 不存在则插入的SQL语句。

Scrapy小技巧-MySQL存储, MYSQL拼接

原文:https://www.cnblogs.com/pythonClub/p/9740718.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!