安装 pymysql
pip install pymysql
连接数据库的步骤
1. 连上数据库:帐号、密码、ip、端口号、数据库
2. 建立游标
3. 执行sql
4. 获取结果
5. 关闭游标
6. 连接关闭
1 import pymysql 2 coon = pymysql.connect( 3 host = '127.0.0.1',user = 'root',passwd = '123456', 4 port = 3306,db = 'mydb',charset = 'utf8' 5 #port必须写int类型 6 #charset必须写utf8,不能写utf-8 7 ) 8 cur = coon.cursor() #建立游标 9 cur.execute("select * from stu") #查询数据 10 res = cur.fetchall() #获取结果 11 print(res) 12 cur.close() #关闭游标 13 coon.close() #关闭连接 14 --------------------------------------------------------------------------- 15 #如果是插入数据,则要commit一下,把第9行换成以下两行 16 cur.execute('insert into stu(name,sex) VALUE ("pzp","man");') 17 coon.commit()
把连接数据库封装成一个函数
1 def my_db(host,user,passwd,db,sql,port= 3306,charset = 'utf8'): 2 import pymysql 3 coon = pymysql.connect(host=host, 4 port=port, 5 user=user, 6 passwd = passwd, 7 db = db, 8 charset = charset 9 ) 10 cur = coon.cursor() 11 cur.execute(sql) 12 if sql.strip()[:6].upper() == 'SELECT': 13 res = cur.fetchall() 14 else: 15 coon.commit() 16 res = 'ok' 17 cur.close() 18 coon.close() 19 return res
Connection:创建了Python客户端与数据库之间的网络通路。他的参数如下
参数名 | 类型 | 说明 |
host | String | MySQL的服务器地址 |
port | int | MySQL的端口号 |
user | String | 用户名 |
passwd | String | 密码 |
db | String | 使用的数据库 |
charset | String | 连接字符集 |
Connection支持的方法:
方法名 | 说明 |
cursor() | 创建并且返回游标 |
commit() | 提交当前事物 |
rollback() | 回滚当前事物r() |
close() | 关闭Connection |
Cursor:游标对象,用于执行查询和获取结果,它支持的方法如下:
方法名 | 说明 |
execute() | 用于执行一个数据库的查询命令 |
fetchone() | 获取结果集中的下一行
返回一条数据,返回字典里面的元素,类型可以是列表或字典(根据游标类型)
|
fetchmany(size) |
获取结果集中的下(size)行 |
fetchall() | 获取结果集中的所有行,
把数据库里面的每一行数据放到一个list里面
|
rowcount | 最近一次execute返回数据/影响的行数 |
close() | 关闭游标 |