Pymysql知识

查询操做

# 查询操做：
# 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()