class Pipeline(object): def init(self): self.cOnn= pq.connect(host='127.0.0.1', user='root',port='3306', passwd='123456', db='root', charset='utf8') self.cur = self.conn.cursor() # def init(self): # host = '127.0.0.1' # port = 27017 # client = pymongo.MongoClient(host=host,port=port) # collection = client.local.letsgojpt # self.post = collection

def process_item(self, item, spider): for i in range(0,len(item["title_all"])): # sql = "insert into letsgojp(title_all, center_all) VALUES (%s, %s)" self.cur.execute("insert into letsgojp(title_all,center_all) values(%s,%s)",(item['title_all'][i],item['center_all'][i])) self.conn.commit() # self.post.insert(data) return item def close_spider(self, spider): self.cur.close() self.conn.close()

主要是这行报错

self.cur.execute("insert into letsgojp(title_all,center_all) values(%s,%s)",(item['title_all'][i],item['center_all'][i]))

用 mongo 的时候是正常存数据的，但是用 mysql 就报错，网上找一些，不太会用，请教各位大神了

14 条回复 2020-05-08 16:19:26 +08:00

ClericPy

2020-05-07 21:56:44 +08:00

1. 找个贴代码的地方把缩进留下...

2. 报错信息解释 90% 问题, 大部分时间报错信息最后一行一搜 stackoverflow 上都有同行遇到过

3. 纯看的话, 实在猜不到啊... 就语法来说, pymysql 会自动转义, 问题不大, 看你的列名也没有敏感关键字所以不加反引号也没事

jugelizi

2020-05-07 22:00:52 +08:00

[item['title_all'][i],item['center_all'][i]] 是不是？
也有可能没处理好特殊字符错误提示贴下啊

Colorful

2020-05-07 22:17:51 +08:00

@jugelizi 应该不会的吧，因为存 mongo 的时候是没总是的

chaneyccy

2020-05-07 22:55:09 +08:00

不贴报错信息，这也看不出来哪里有问题吧

没用过 SQL 好奇搜了一圈，没有发现模块导入是 import pymysql as pq，问题在这？

Colorful

2020-05-07 23:05:28 +08:00

@chaneyccy 不是那里，能爬到一条数据
self.cur.execute("insert into letsgojp(title_all,center_all) values(%s,%s)",(item['title_all'][i],item['center_all'][i]))

主要就是这行

aydd2004

2020-05-07 23:17:58 +08:00

execute 的内容 print 出来看一下

实在不行粘到 mysql 里面执行一下

dorothyREN

2020-05-08 00:01:50 +08:00

占位符那里的问题，插入字符串需要加上 \'%s\'

dorothyREN

2020-05-08 00:06:12 +08:00

@dorothyREN #7 ``` def save_data(self, title, content):
sql = "INSERT INTO test(title,content) VALUES (\'%s\',\'%s\')" % (title, content)
# print(sql)
self.cur.execute(sql)
self.conn.commit()
```