用pymysql操作MySQL数据库

Posted 2021-01-04 KumataのBloG

工具库安装

pip install pymysql

连接关闭数据库与增删改查操作

# 导入pymysql库
import pymysql

# 打开数据库连接
# 参数1：数据库服务器所在的主机+端口号
# 参数2：登陆数据库的用户名
# 参数3：登陆数据库的密码
# 参数4：要连接的数据库
# 参数5：字符编码
db = pymysql.connect(
    ‘localhost‘,
    ‘root‘,
    ‘123456‘,
    ‘school‘,
    charset = ‘utf8‘
)

# 增删改插操作
# 首先获取一个游标对象
cursor = db.cursor()

# 执行SQL语句

# 创建表
# ‘‘‘三引号来写跨行
# IF NOT EXISTS 表示如果没存在就创建表
# sql_table = ‘‘‘CREATE TABLE IF NOT EXISTS course(
#     c_id INT PRIMARY KEY AUTO_INCREMENT,
#     c_name VARCHAR(20) character set gbk default NULL,
#     c_weight INT
# )‘‘‘
# cursor.execute(sql_table)

# 插入数据
# sql_add = ‘‘‘
# 
# INSERT INTO course(c_name,c_weight) VALUES(‘英语‘,‘8‘);
# ‘‘‘
# try:
#     cursor.execute(sql_add)
#     db.commit()
# except: # 如果出现异常需要回滚
#     db.rollback()

# 删除数据
# sql_del = ‘‘‘DELETE FROM course WHERE c_name = ‘math‘;
# ‘‘‘
# try:
#     cursor.execute(sql_del)
#     db.commit()
# except: # 如果出现异常需要回滚
#     db.rollback()

# 修改数据
# sql_change = ‘‘‘UPDATE course SET c_weight = 4 WHERE c_name = ‘math‘;
# ‘‘‘
# try:
#     cursor.execute(sql_change)
#     db.commit()
# except: # 如果出现异常需要回滚
#     db.rollback()

# # 查询数据
# sql_select = ‘‘‘
# SELECT * FROM course
# ‘‘‘
# try:
#     cursor.execute(sql_select)
#     # 获取所有记录
#     results = cursor.fetchall() # 返回元祖
#     print(results)
#     for row in results:
#         #print(row)
#         c_id = row[0]
#         c_name = row[1]
#         c_weight = row[2]
#         print(‘name = %s,weight = %d‘ % (c_name,c_weight))
#
#     db.commit()
# except:# 如果出现异常需要回滚
#     db.rollback()



#关闭数据库连接
db.close()