python操作mysql

# 安装库
pip install PyMySQL
#创建连接
import pymysql db
= pymysql.connect("数据库ip","用户","密码","数据库" ) # 打开数据库连接 cursor = db.cursor() #创建游标
cursor.execute(
"SELECT VERSION()") # 使用 execute() 方法执行 SQL 查询 数据库版本 data = cursor.fetchone() # 使用 fetchone() 方法获取单条数据 print ("Database version : %s " % data) db.close() # 关闭数据库连接

import pymysql
conn = pymysql.connect(
host = 'localhost',
port = 3306,
user = 'root',
password = '123',
database = 'homework',
charset='utf8'
)
cur = conn.cursor(pymysql.cursors.DictCursor) # 设置返回的数据类型是字典 [{},{},{}]
cur = conn.cursor() # 默认返回的数据类型是元组 ((),(),())
# cur 数据库操作符
# sql = 'drop table ind1;'
# sql = """CREATE TABLE EMPLOYEE (
# FIRST_NAME CHAR(20) NOT NULL,
# LAST_NAME CHAR(20),
# AGE INT,
# SEX CHAR(1),
# INCOME FLOAT )"""
try:
sql = 'select * from class'
ret = cur.execute(sql)
conn.commit()
except:
conn.rollback()

print(ret)
res = cur.fetchone() #一个个取值
print(res)
ret = cur.fetchmany(2) #多个
# res = cur.fetchall() #全部
print(ret)
cur.close()
conn.close()
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall(): 接收全部的返回结果行.
rowcount: 这是一个只读属性,并返回执行execute()方法后影响的行数。
sql 表示的 增删改查
sql
= "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
原文地址:https://www.cnblogs.com/zhangchen-sx/p/10263699.html