导入数据库模块
# -*- coding:utf-8 -*-
import pymysql
1.链接到数据库
host - 连接服务器(地址可以是阿里云地址,也可以是本地电脑localhost/127.0.0.1)
user - 数据库用户名
passwd - 数据库密码
db 数据库名称
port 端口 redis默认端口是3306
charset 编码
db = pymysql.Connect(
host='47.106.81.223',
user='root',
passwd='123456',
db='company',
port=3306,
charset='utf8'
)
查看是否连接上了数据库
print(db)
2.获取游标/指针
cursor = db.cursor()
3.执行sql
execute(sql[, args]) 执行一个数据库查询或命令
sql = 'show tables;'
cursor.execute(sql)
4.获取结果
# fetchall 获取指针结果集中的所有行,返回的结果集是一个元组(tuples)
# fetchone 从查询结果集中返回下一行
# fetchmany([size = cursor.arraysize]):得到结果集的下几行
data = cursor.fetchall()
for i in data:
print('id:%s name:%s' % (i[0],i[1]))
5.提交
如果执行了更新/插入/删除操作,必须要进行提交,才真正在数据库中完成了操作,这是为了保证事务性
db.commit()
6.处理异常 - 回滚
try:
sql = '''insert into tbcourse values
(8888,'C语言程序设计',3,'大神级讲师授课需要抢座');'''
cursor.executemany(sql)
# 事务性
# 提交
# 针对插入 更新 删除 操作
db.commit()
except:
db.rollback()
7.关闭连接
db.close()