[已解决]python操作数据库写入数据的sql语句问题

happy_study

1. def writeSql(a,b,c):
   
2.    
   
3.     sql = "INSERT INTO movies(a,b,c) values(%s,%s,%s)"

复制代码

现在要把函数传来的参数的值写入数据库，这个sql语句该怎么写

最佳答案

月排行榜 / 总排行榜

空青

2019-7-18 11:24:40

基本思路我给你捋一下，要将数据插入到mysql数据库，可以使用下面的步骤
1、连接到数据库，获取到游标
2、写好insert插入操作的sql语句
3、使用游标执行insert的sql语句
4、提交操作
另外，插入操作有可能因为某些原因会失败（磁盘满了，网络断了等等。。。），需要做异常处理，如果插入过程中有失败，那么回滚，本次操作无效。

现在我假定你的数据库名是demo,表名是movies。表的字段包括三个avalue，bvalue，cvalue（你写出的是a,b,c,为了避免你理解混了，我给改了）。
用户名user，密码123456，host是127.0.0.1（本机）。要插入的值是函数传入的参数值a，b，c。

代码如下供你参考：

1. import pymysql
   
2. 
   
3. 
   
4. def writeSql(a, b, c):
   
5.     sql = "INSERT INTO movies(avalue,bvalue,cvalue) values (%s,%s,%s)"
   
6.     # 连接数据库
   
7.     db = pymysql.connect(host='127.0.0.1', database='demo', user='user', password='123456',
   
8.                          port=3306, charset='utf8')
   
9.     # 获取游标
   
10.     cursor = db.cursor()
    
11.     try:
    
12.         # 用游标来执行sql语句
    
13.         cursor.execute(sql, (a, b, c))
    
14.         # 提交操作
    
15.         db.commit()
    
16.     except Exception as e:
    
17.         print(e)
    
18.         # 如果插入过程中有异常，就回滚
    
19.         db.rollback()
    

复制代码

好了，我相信你仔细看看应该能明白的。

跳转到最佳答案楼层

空青

基本思路我给你捋一下，要将数据插入到mysql数据库，可以使用下面的步骤
1、连接到数据库，获取到游标
2、写好insert插入操作的sql语句
3、使用游标执行insert的sql语句
4、提交操作
另外，插入操作有可能因为某些原因会失败（磁盘满了，网络断了等等。。。），需要做异常处理，如果插入过程中有失败，那么回滚，本次操作无效。

现在我假定你的数据库名是demo,表名是movies。表的字段包括三个avalue，bvalue，cvalue（你写出的是a,b,c,为了避免你理解混了，我给改了）。
用户名user，密码123456，host是127.0.0.1（本机）。要插入的值是函数传入的参数值a，b，c。

代码如下供你参考：

1. import pymysql
   
2. 
   
3. 
   
4. def writeSql(a, b, c):
   
5.     sql = "INSERT INTO movies(avalue,bvalue,cvalue) values (%s,%s,%s)"
   
6.     # 连接数据库
   
7.     db = pymysql.connect(host='127.0.0.1', database='demo', user='user', password='123456',
   
8.                          port=3306, charset='utf8')
   
9.     # 获取游标
   
10.     cursor = db.cursor()
    
11.     try:
    
12.         # 用游标来执行sql语句
    
13.         cursor.execute(sql, (a, b, c))
    
14.         # 提交操作
    
15.         db.commit()
    
16.     except Exception as e:
    
17.         print(e)
    
18.         # 如果插入过程中有异常，就回滚
    
19.         db.rollback()
    

复制代码

好了，我相信你仔细看看应该能明白的。

毛绒绒

基础版本

1. import pymysql
   
2. 
   
3. id = '20120001'
   
4. user = 'Bob'
   
5. age = 20
   
6. 
   
7. db = pymysql.connect(host='localhost', user='root', password='123456', port=3306, db='spiders')
   
8. cursor = db.cursor()
   
9. sql = 'INSERT INTO students(id, name, age) values(%s, %s, %s)'
   
10. try:
    
11.     cursor.execute(sql, (id, user, age))
    
12.     db.commit()
    
13. except:
    
14.     db.rollback()
    
15. db.close()

复制代码

进阶动态插入版本

1. data = {
   
2.     'id': '20120001',
   
3.     'name': 'Bob',
   
4.     'age': 20
   
5. }
   
6. table = 'students'
   
7. keys = ', '.join(data.keys())
   
8. values = ', '.join(['%s'] * len(data))
   
9. sql = 'INSERT INTO {table}({keys}) VALUES ({values})'.format(table=table, keys=keys, values=values)
   
10. try:
    
11.    if cursor.execute(sql, tuple(data.values())):
    
12.        print('Successful')
    
13.        db.commit()
    
14. except:
    
15.     print('Failed')
    
16.     db.rollback()
    
17. db.close()

复制代码

高级动态插入&更新重复版本

1. data = {
   
2.     'id': '20120001',
   
3.     'name': 'Bob',
   
4.     'age': 21
   
5. }
   
6. 
   
7. table = 'students'
   
8. keys = ', '.join(data.keys())
   
9. values = ', '.join(['%s'] * len(data))
   
10. 
    
11. sql = 'INSERT INTO {table}({keys}) VALUES ({values}) ON DUPLICATE KEY UPDATE'.format(table=table, keys=keys, values=values)
    
12. update = ','.join([" {key} = %s".format(key=key) for key in data])
    
13. sql += update
    
14. try:
    
15.     if cursor.execute(sql, tuple(data.values())*2):
    
16.         print('Successful')
    
17.         db.commit()
    
18. except:
    
19.     print('Failed')
    
20.     db.rollback()
    
21. db.close()

复制代码

数据来源:静觅 崔庆才的个人博客 python3网络爬虫开发实战 5.2.1-mysql存储

happy_study

空青 发表于 2019-7-18 11:24
基本思路我给你捋一下，要将数据插入到mysql数据库，可以使用下面的步骤
1、连接到数据库，获取到游标
2 ...

感谢，我猜你也是爬取猫眼top100吧，好熟悉的数据库表名

空青

happy_study 发表于 2019-7-18 11:39
感谢，我猜你也是爬取猫眼top100吧，好熟悉的数据库表名

哈哈，我爬虫入门的时候搞的是豆瓣top100

Muyann

感谢，学习了