mysql的dbconn_管道错误使用mysql.conn
我完全迷路了。這是我的管道。我說我跑錯了File "c:\python27\lib\site-packages\twisted\internet\defer.py", line 588, in _runCallbacks
current.result = callback(current.result, *args, **kw)
File "C:\Python27\bff\bff\pipelines.py", line 42, in process_item
cursor.execute(add_Product)
File "c:\python27\lib\site-packages\mysql\connector\cursor.py", line 492, in execute
stmt = operation.encode(self._connection.python_charset)
AttributeError: 'tuple' object has no attribute 'encode'
正如您在注釋代碼中看到的,我嘗試了幾種不同的方法。一開始,正如我在示例中看到的那樣做,但是我得到一個錯誤:當我把(item['StoreName'])放在值行中而不是在上面定義它為Name=item['StoreName']時,sadi item沒有被定義
一、 我使用mySQL.connector我從mqsql.org網站網站。提前謝謝
^{pr2}$
編輯。這是我的新代碼`
from __future__ import print_function
from datetime import date, datetime, timedelta
import mysql.connector
#from scrapy.extensions import DropItem
#from bff.items import ItemInfo
class mySQLPipeline(object):
def process_item(self, item, spider):
Product = item['ProdName']
Path = item['ProdPath']
UPC = item['ProdUPC']
Model = item['ProdModel']
Desc = item['ProdDesc']
Price = item['ProdPrice']
Stock = item['InStock']
#Ships = item['Ships']
Name = item['StoreName']
cnx = mysql.connector.connect(user='****', password='****',
host='127.0.0.1',
port='****',
database='****')
cursor = cnx.cursor()
# add_Product = ("INSERT INTO walmart_products (ProdName, StoreName) VALUES (%s, %s,)", Product, Name,)
# add_Product = ("INSERT INTO walmart_products, (ProdName)"
# "VALUES (%s)", (Name))
# "VALUES (%(Name)s)")
add_Product = ("INSERT INTO walmart_products "
"(ProdName, ProdPath, ProdUPC, ProdModel, ProdDesc, ProdPrice, InStock, StoreName) "
"VALUES (%s, %s, %s, %s, %s, %s, %s, %s)")
#item['Ships'],
data_Product = (Product, Path, UPC, Model, Desc, Price, Stock, Name)
#Add new product
cursor.execute(add_Product, data_Product)
# Make sure data is committed to the database
cnx.commit()
cursor.close()
cnx.close()
return item
`
總結
以上是生活随笔為你收集整理的mysql的dbconn_管道错误使用mysql.conn的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: oracle11g imp性能,怎么最快
- 下一篇: linux sql 语句菜鸟,Linux