我们可以使用pyMySQL模块和MySQL.connector来操作MySQL数据库
MySQL.connector:
常用操作: 插入数据 insert 查询数据 select 更新数据 update
创建数据库连接:connect( host ,port, user , passwd , database)
import mysql.connector
connect = mysql.connector.connect(
"host": "localhost",
"port": 3306,
"user": "root",
"password": "******",
"database": "test"
)
cursor = connect.cursor() # 获取游标
sql = "SELECT no, name,FROM student;"
cursor.execute(sql) # 执行sql语句
for i in cursor:
print(i[0], i[1]) # 打印test中学生表的两个字段的数据
connect.close()
#host:IP地址,本地使用 "localhost"或'127.0.0.1'
#port:端口
#user:账号
#password:数据库密码
#database:数据库
我们也可以用cursor.fetcall()获取返回结果为列表类型,再去遍历打印输出
批量插入数据:
sql='insert into student values(%s,%s,%s)'
val=[
(3,'李四',20),
(6,'王五',21)
]
cursor.executemany(sql,val)
pyMySQL:
from pymysql import *
#创建数据库连接
conn = connect(host='localhost',port=3306,user='root',password='root',db='mytestdb',charset='utf8')
#打开游标
cur = conn.cursor()
#执行 sql语句
#让用户输入用户名密码
sname = input("请输入用户名:")
passwd = input("请输入密码:")
# 编写sql语句
sql = "select * from t_student where sname='%s' and passwd='%s'"%(sname,passwd)
# 执行sql语句,返回查询到的记录条数rowcount,如果rowcount不为0,则登录成功,否则登录失败
rowcount = cur.execute(sql)
if rowcount!=0:
print("登录成功")
else:
print("登录失败")
#5 关闭游标
cur.close()
#6 关闭连接
conn.close()