MySQL:
使用MySQL插入數(shù)據(jù)前確保數(shù)據(jù)庫和插入的表已經(jīng)存在
這里用join方法將序列中的元素以指定的字符連接生成一個新的字符串
mdb = pymysql.connect('localhost', 'root', '123456', 'jd_seach',charset='utf8')
cursor = mdb.cursor()
#插入數(shù)據(jù) product是該函數(shù)傳入的一個參數(shù)(字典類型)
table = 'jd_seach_table'
keys = ','.join(product.keys())
values = ','.join(['%s']*len(product))#動態(tài)添加
sql = 'INSERT INTO {table}({keys}) VALUES ({values})'.format(table=table,keys=keys,values=values)
try:
if cursor.execute(sql,tuple(product.values())):
print('successfuly',product)
mdb.commit()
except Exception as e:
print('failed',e)
mdb.rollback()
mdb.close()
MongoDB:
MONGODB_TABLE表不存在時自動創(chuàng)建
#product是字典類型的參數(shù)
db[MONGODB_TABLE].insert_one(product)