import pymysql
# 与C/S架构中的client一样使用connect与数据库建立连接
conn = pymysql.connect(
user = 'root',
password = '123456',
host = '127.0.0.1',
port = 3306,
charset = 'utf8',
database = 'day36'
)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)# 产生一个游标对象
# cursor=pymysql.cursors.DictCursor 将查询出来的结果制作成字典的形式返回
sql = 'select * from userinfo'
res = cursor.execute(sql) # 执行sql语句
print(res) # execute返回的是当前sql所受影响的行数
# ret=cursor.fetchone() #只获取查询结果中的一条数据
# ret = cursor.fetchall() #获取查询结果的所有数据
# ret = cursor.fetchmany(2) #指定获取几条数据 如果数字超了也不会报错
# print(ret)
print(cursor.fetone()
print(cursor.fetone())
# 相对移动
# cursor.scroll(2, 'relative') # 基于指针所在的位置,往后偏移
# 绝对移动
cursor.scroll(1, 'absolute') # 基于启始位置 往后偏移
print(cursor.fetchall())
数据的增删改查
import pymysql
conn = pymysql.connect(
user = 'root',
passwd = '123456',
db = 'day36',
host = '127.0.0.1',
port = 3306,
charset = 'utf8',
autocommit = True # 自动提交
)
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
# 增
sql = "insert into userinfo(name,password,dep_id) values('jason',789,1)"
# 改
# sql = "update userinfo set name='mike' while id =6"
# 删除
# sql = "delete from userinfo where id = 1"
res = cursor.execute(sql)
# conn.commit() # 确认当前操作 真正的同步到数据库
print(res)
'''
针对增删改操作,执行重要程度偏高,
必须要有一步确认操作(commit)
'''