ThinkChat🤖让你学习和工作更高效,注册即送10W Token,即刻开启你的AI之旅 广告
## 增加 * 创建testInsert.py文件,向学生表中插入一条数据 * 下面是python2 ~~~ #encoding=utf-8 import MySQLdb try: conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8') cs1=conn.cursor() count=cs1.execute("insert into students(sname) values('张良')") print count conn.commit() cs1.close() conn.close() except Exception,e: print e.message ~~~ ## 修改 * 创建testUpdate.py文件,修改学生表的一条数据 ~~~ #encoding=utf-8 import MySQLdb try: conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8') cs1=conn.cursor() count=cs1.execute("update students set sname='刘邦' where id=6") print count conn.commit() cs1.close() conn.close() except Exception,e: print e.message ~~~ ## 删除 * 创建testDelete.py文件,删除学生表的一条数据 ~~~ #encoding=utf-8 import MySQLdb try: conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8') cs1=conn.cursor() count=cs1.execute("delete from students where id=6") print count conn.commit() cs1.close() conn.close() except Exception,e: print e.message ~~~ ## sql语句参数化 * 创建testInsertParam.py文件,向学生表中插入一条数据 ~~~ #encoding=utf-8 import MySQLdb try: conn=MySQLdb.connect(host='localhost',port=3306,db='test1',user='root',passwd='mysql',charset='utf8') cs1=conn.cursor() sname=raw_input("请输入学生姓名:") params=[sname] count=cs1.execute('insert into students(sname) values(%s)',params) print count conn.commit() cs1.close() conn.close() except Exception,e: print e.message ~~~ ## 其它语句 * cursor对象的execute()方法,也可以用于执行create table等语句 * 建议在开发之初,就创建好数据库表结构,不要在这里执行 ## python3代码 ~~~ #!/usr/bin/env python # -*- coding: utf-8 -*- ''' @Time : 5/14/18 11:17 PM @Author : haibo @File : Connection.py ''' from pymysql import * try: conn = connect(host="localhost", port=3306, user="root", passwd="haibo", db="python3", charset="utf8") cur1 = conn.cursor() # sql = "insert into student(name,birthday) values('李XX','1997-8-7')" # sql = "update student set name ='lihui' where id=7" sql = "delete from student where id=7" cur1.execute(sql) conn.commit() cur1.close() conn.close() except Exception as e: print(e.message) ~~~