创建数据库表
import pymysql
# 打开数据库连接
db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
# 使用cursor()方法获取操作游标
cur = db.cursor()
# 使用execute方法执行SQL语句
cur.execute("drop table if exists student")
sql = "create table student(id int primary key auto_increment ,name char(20),sex char(1),age int)"
try:
# 执行sql语句
cur.execute(sql)
# 提交到数据库执行
db.commit()
except:
db.rollback()
# 关闭数据库连接
db.close()
数据库查询操作
import pymysql
db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
cur = db.cursor()
sql = "select * from student "
try:
cur.execute(sql)
result = cur.fetchall()
for row in result:
id = row[0]
name = row[1]
sex = row[2]
age = row[3]
print(id ,name ,sex,age)
finally:
db.close()
数据库插入操作
import pymysql
# 打开数据库连接
db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
# 使用cursor()方法获取操作游标
cur = db.cursor()
# 使用execute方法执行SQL语句
sql ="INSERT INTO student(name,sex,age) values('mac',1,222)"
try:
# 执行sql语句
cur.execute(sql)
# 提交到数据库执行
db.commit()
except:
db.rollback()
# 关闭数据库连接
db.close()
数据库更新操作
import pymysql
# 打开数据库连接
db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
# 使用cursor()方法获取操作游标
cur = db.cursor()
# 使用execute方法执行SQL语句
sql ="update student set age = 123 where age = 222"
try:
# 执行sql语句
cur.execute(sql)
# 提交到数据库执行
db.commit()
except:
db.rollback()
# 关闭数据库连接
db.close()
删除操作
import pymysql
# 打开数据库连接
db= pymysql.connect(host='localhost',user="root",password="root",db="ceshi",port=3306,charset='utf8')
# 使用cursor()方法获取操作游标
cur = db.cursor()
# 使用execute方法执行SQL语句
sql ="delete from student where age > 50"
try:
# 执行sql语句
cur.execute(sql)
# 提交到数据库执行
db.commit()
except:
db.rollback()
# 关闭数据库连接
db.close()