python3操作mysql数据库增删改查

  1. #!/usr/bin/python3  
  2. import pymysql  
  3. import types  
  4.   
  5. db=pymysql.connect("localhost","root","123456","python");  
  6.   
  7. cursor=db.cursor()  
  8.   
  9. #创建user表  
  10. cursor.execute("drop table if exists user")  
  11. sql="""CREATE TABLE IF NOT EXISTS `user` ( 
  12.       `id` int(11) NOT NULL AUTO_INCREMENT, 
  13.       `name` varchar(255) NOT NULL, 
  14.       `age` int(11) NOT NULL, 
  15.       PRIMARY KEY (`id`) 
  16.     ) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""  
  17.   
  18. cursor.execute(sql)  
  19.   
  20.   
  21. #user插入数据  
  22. sql="""INSERT INTO `user` (`name`, `age`) VALUES 
  23. ('test1', 1), 
  24. ('test2', 2), 
  25. ('test3', 3), 
  26. ('test4', 4), 
  27. ('test5', 5), 
  28. ('test6', 6);"""  
  29.   
  30. try:  
  31.    # 执行sql语句  
  32.    cursor.execute(sql)  
  33.    # 提交到数据库执行  
  34.    db.commit()  
  35. except:  
  36.    # 如果发生错误则回滚  
  37.    db.rollback()  
  38.      
  39.      
  40. #更新  
  41. id=1  
  42. sql="update user set age=100 where id='%s'" % (id)  
  43. try:  
  44.     cursor.execute(sql)  
  45.     db.commit()  
  46. except:  
  47.     db.rollback()  
  48.       
  49. #删除  
  50. id=2  
  51. sql="delete from user where id='%s'" % (id)  
  52. try:  
  53.     cursor.execute(sql)  
  54.     db.commit()  
  55. except:  
  56.     db.rollback()  
  57.       
  58.       
  59. #查询  
  60. cursor.execute("select * from user")  
  61.   
  62. results=cursor.fetchall()  
  63.   
  64. for row in results:  
  65.     name=row[0]  
  66.     age=row[1]  
  67.     #print(type(row[1])) #打印变量类型 <class 'str'>  
  68.   
  69.     print ("name=%s,age=%s" %   
  70.              (age, name))  
 
【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/meng-wei-zhi/p/8214750.html