芝麻HTTP:

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

芝麻HTTP:。芝麻HTTP:,芝麻http

若是你的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
Field字段名字和 数据库字段的名字
同样。那么恭喜您你就足以拷贝那段SQL拼接脚本。举行MySQL入库管理。…

那二日上班接手,外人留下来的爬虫开采一个很有意思的 SQL脚本拼接。

那两日上班接手,外人留下来的爬虫发掘二个很有意思的 SQL脚本拼接。

实际拼接代码如下:

一旦您的Scrapy Field字段名字和 数据库字段的名字
同样。那么恭喜您你就足以拷贝那段SQL拼接脚本。进行MySQL入库管理。

假如您的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语句

​
    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()# 写入操作

​
​

    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()# 写入操作



​

具体得以达成就是首先个for循环,获取key作为MySQL字段名字、VALUES做为SQL的VALUES(拼接成八个布署的SQL语句)

其一SQL拼接完结了,假诺数据仓库储存在同样数量则 更新,不存在则插入 的SQL语句

 那几个SQL拼接实现了,假使数据仓库储存在同样数量则 更新,不设有则插入
的SQL语句

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

具体得以达成便是首先个for循环,获取key作为MySQL字段名字、VALUES做为SQL的VALUES(拼接成1个插入的SQL语句)

具体落到实处正是第四个for循环,获取key作为MySQL字段名字、VALUES做为SQL的VALUES(拼接成三个布署的SQL语句)

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

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

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

和率先个for循环的中的sql就重组了 insert into  XXXXX   on duplicate key
update 那么些。存在则更新 不设有则插入的SQL语句。

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

 

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

*
*
Website