MySQL:
使用MySQL插入数据前确保数据库和插入的表已经存在
这里用join方法将序列中的元素以指定的字符连接生成一个新的字符串
mdb = pymysql.connect('localhost', 'root', '123456', 'jd_seach',charset='utf8')
cursor = mdb.cursor()
#插入数据 product是该函数传入的一个参数(字典类型)
table = 'jd_seach_table'
keys = ','.join(product.keys())
values = ','.join(['%s']*len(product))#动态添加
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表不存在时自动创建
#product是字典类型的参数
db[MONGODB_TABLE].insert_one(product)
网友评论