代码链接 数据库（下）

一 循环查询数据（1）

import pymysql
# 使用代码链接数据库
conn=pymysql.connect(host="localhost",user="root",password="root",database="pymysql_demo",port=3306)
# 创建游标
cursor=conn.cursor()
sql="""
select * from user 
"""
cursor.execute(sql)
while True:
    result=cursor.fetchone()
    if result:
        print(result)
    else:
        break
conn.close()

一 循环查询数据（2）

import pymysql
# 使用代码链接数据库
conn=pymysql.connect(host="localhost",user="root",password="root",database="pymysql_demo",port=3306)
# 创建游标
cursor=conn.cursor()
sql="""
select * from user 
"""
cursor.execute(sql)

results=cursor.fetchmany(2)
for result in results:
    print(result)
conn.close()

二 更新数据库

import pymysql
# 使用代码链接数据库
conn=pymysql.connect(host="localhost",user="root",password="root",database="pymysql_demo",port=3306)
# 创建游标
cursor=conn.cursor()
sql="""
update user set name="niuniu" where id=1
"""
cursor.execute(sql)
conn.commit()
# 插入 更新 删除 都需要进行commit操作
conn.close()