PyMySQL操作MySQL基础入门

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，用于与数据库进行交互，实现增删改查等操作。

PyMySQL的使用操作需要先安装MySQL服务，这里就不展开说明了。

一、PyMySQL安装

pip install PyMySQL

二、准备好需要测试的数据库和表

新建python-test数据库，新建test测试表，表字段结构如下：

CREATE TABLE `test` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL COMMENT '姓名',
  `age` int(11) DEFAULT NULL COMMENT '年龄',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

填充测试数据：

INSERT INTO `python-test`.`test`(`id`, `name`, `age`) VALUES (1, '张三', 18);
INSERT INTO `python-test`.`test`(`id`, `name`, `age`) VALUES (2, '李四', 20);

测试数据准备好后，开始编写代码连接数据库。

三、创建数据库连接、增删改查完整代码

import pymysql

# 打开数据库连接
db_connect = pymysql.connect(
    host='localhost',  # 数据库地址
    user='root',  # 数据库用户名
    password='root',  # 数据库密码
    database='python-test'  # 连接的数据库名
)
cursor = db_connect.cursor()  # 创建游标对象

'''1、添加数据'''
insert_sql = """INSERT INTO test(name, age) VALUES('王五', 22)"""
try:
    cursor.execute(insert_sql)
    db_connect.commit()
except:
    db_connect.rollback()
else:
    print('数据添加成功')

'''2、查询数据'''
# 查询单条数据
select_sql = """SELECT * FROM test"""
cursor.execute(select_sql)
fetch_one = cursor.fetchone()
print('数据查询结果：', fetch_one)  # (1, '张三', 18)
# 查询所有数据
cursor.execute(select_sql)
all_data = cursor.fetchall()  # print(all_data)：((1, '张三', 18), (2, '李四', 20), (3, '王五', 22))

'''3、更新数据'''
update_sql = """UPDATE test set age = age + 1"""
try:
    cursor.execute(update_sql)
    db_connect.commit()
except:
    db_connect.rollback()
else:
    print('更新数据成功')

'''4、删除数据'''
del_sql = """delete from test where name='%s'""" % '王五'
try:
    cursor.execute(del_sql)
    db_connect.commit()
except:
    db_connect.rollback()
else:
    print('数据删除成功')

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