查询操作
# 查询操作: # fetchone()#返回一个 # fetchall()#返回全部 # fetchmany()#返回多个 import pymysql db=pymysql.connect('127.0.0.1','root','','db4')#连接数据库 cursor=db.cursor()#创建游标对象 要是以字典的形式展开 #pymysql.cursors.DictCursor以字典的形式显示 sql='select * from employee' cursor.execute(sql) # ret=cursor.fetchall()#全部拿到数据,以元组的形式 # print(ret) # ret=cursor.fetchone()#每次拿一个 # print(ret) # # ret=cursor.fetchone() # print(ret) # ret=cursor.fetchone() print(type(ret)) # ret=cursor.fetchmany(3)#以元组的形式返回 # print(ret) cursor.close()#关闭游标 db.close()#关闭数据库连接
插入操作
import pymysql conn=pymysql.connect('127.0.0.1','root','','db7')#连接数据库 cursor=conn.cursor()#创建游标 sql="insert into t1 (name)values('alex'),('wusir')"#字段名要+括号 try: cursor.execute(sql) conn.commit()#提交到数据库 except: print(1) conn.rollback()#如果发生错误就回滚 conn.close()
修改操作
import pymysql conn=pymysql.connect('127.0.0.1','root','','db7')#数据库连接 cursor=conn.cursor()#游标 sql="update t1 set name='alexsb' where id=1" try: cursor.execute(sql) conn.commit() except: print(1) conn.rollback() conn.close()
删除操作
import pymysql db=pymysql.connect('127.0.0.1','root','','db7')#连接数据库 cursor=db.cursor()#创建游标对象 sql="delete from t1 where id=1" try: cursor.execute(sql)#执行sql语句 db.commit()#提交修改 except: print(1) db.rollback()#出错数据回滚 db.close()