一、前提
在 cmd 中已执行 pip install pymysql 安装完成 数据库（mysql ）模块
二、引入pymysql，并连接数据库
数据库连接
1 import pymysql 2 3 conn = pymysql.connect( 4 host="*.*.*.*",#数据库IP 5 user="*",#数据库的用户名 6 password="*",#密码 7 db="*",#数据库名 8 port=3306,#数据库端口（默认端口） 9 charset="utf8",#字符集 10 autocommit=True #自动提交 11 )#连接数据库
三、执行SQL语句存储数据 及 关闭数据库连接
1. 获取游标并执行SQL语句
callproc(self, procname, args):用来执行存储过程,接收的参数为存储过程名和参数列表,返回值为受影响的行数
execute(self, query, args):执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数
executemany(self, query, args):执行单条sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数
nextset(self):移动到下一个结果集
1 cursor = conn.cursor(pymysql.cursors.DictCursor) #建立游标 2 cursor.execute('insert into students (name,phone,age,sex) values ("张三","15975325689",20,"南");' )# 增 3 cursor.execute('update students set name = "万书成" where id = 20')# 改 4 cursor.execute("select * from students;") #查 5 conn.commit() #提交,若连接数据时已设置自动提交，则不需要执行再次执行提交，否则需要提交才能真正执行sql语句
2. 结果返回
1 # result =cursor.fetchall()# 获取数据库执行结果 2 # result =cursor.fetchmany(3)# 指定获取数据库几条执行结果 3 # result =cursor.fetchone()# 仅获取数据库1条执行结果 4 # print(result) 5 print("===========数据较多时，使用以下=================") 6 for line in cursor: 7 print(line)
3. 关闭连接数据库
1 cursor.close() 2 conn.close()