import pymysql

# python 连接数据库，返回数据库连接对象
conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")
PRint(conn)

输出连接对象如下所示：

<pymysql.connections.Connection object at 0x00000000021E2F60>

其中 connect 方法相关的参数可以依据名称进行判断。

接下来就是创建游标，提取数据。

# 通过 cursor() 创建游标对象，并让查询结果以字典格式输出
cur = conn.cursor(cursor=pymysql.cursors.DictCursor)
# 输出 <pymysql.cursors.DictCursor object at 0x0000000002C03B00>

下一步使用游标对象 cur 的 execute 方法执行 sql。

cur.execute("select * from user")

最后通过相关方法获取查询结果，本案例获取所有用户使用 fetchall 方法。

# 获取查询结果
data = cur.fetchall()

输入数据库检索的所有数据。

[{'name': '橡皮擦', 'uid': 1}, {'name': 'CSDN', 'uid': 2}]

关闭游标，关闭连接

# 关闭游标
cur.close()
# 关闭数据库连接
conn.close()

接下来我们将其修改的复杂一些，检索特定数据，例如 uid=1 的数据，并且用到上下文管理器 with 进行对象的关闭。

第一种写法

import pymysql

# python 连接数据库，返回数据库连接对象
conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")
# print(conn)
with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:
    cur.execute("select * from user where uid = %s", 1)
    # 获取查询结果
    data = cur.fetchall()
    print(data)

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

第二种写法

import pymysql

# python 连接数据库，返回数据库连接对象
conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")
# print(conn)
with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:
    cur.execute("select * from user where uid = %(uid)s", {"uid": 1})
    # 获取查询结果
    data = cur.fetchall()
    print(data)

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

两种写法，在 execute 方法参数存在差异，可直接对比学习。

python 更新数据表数据 接下来演示的是使用 python 去更新表数据，例如将 uid = 2 的 name 列更新为 Code。

import pymysql

# python 连接数据库，返回数据库连接对象
conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")
# print(conn)
with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:
    try:
        cur.execute("update user set name =%s where uid = %s", ["Code", 2])

        conn.commit()  # 提交事务
    except Exception as e:
        print("数据更新异常", e)
        conn.rollback()  # 数据回滚

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

上述代码核心为在执行 SQL 操作之后，需要使用事务处理，即 conn.COMmit 提交事务，确保当前修改生效，如果出现异常，还需要使用 conn.rollback 对提交事务进行回滚。

cursor. execute 可以返回受影响行数，可以直接通过该值判断是否修改成功。

本次代码还使用了 try-except 语句，对于 PyMySQL 模块内置的异常类，清单如下：

• StandardError
  • Warning
  • Error
    • InterfaceError
    • DatabaseError
      • DataError
      • operationalError
      • IntegrityError
      • ProgrammingError
      • NotSupportedError

python 新增数据表数据 接下来演示增加数据，本次插入数据都采用硬编码，如果想创建一个自动递增的表字段，需要继续研究 sql 相关写法。

import pymysql

# python 连接数据库，返回数据库连接对象
conn = pymysql.connect(host="127.0.0.1", user="root", password="xiangpica", database="cadb", charset="utf8")
# print(conn)
with conn.cursor(cursor=pymysql.cursors.DictCursor) as cur:
    try:
        affected = cur.execute("insert into user(name,uid) values (%s,%s)", ["Good", 3])

        conn.commit()  # 提交事务
        print("受影响行数", affected)
    except Exception as e:
        print("数据插入异常", e)
        conn.rollback()  # 数据回滚

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

python 删除表格数据 核心代码如下所示：

affected = cur.execute("delete from user where uid = %s", [3])
conn.commit()  # 提交事务
print("受影响行数", affected)

写到这里，你可以自行完成一个 python 简单的数据库操作封装。

python 操作 nosql 之 dbm

mysql 数据关系型数据库，与之对应的就是非关系型数据库，例如 python 内置的 dbm（database manager ）

第一个要学习的方法是 dbm.oPEn，方法原型如下所示：

def open(file, flag='r', mode=0o666):

flag 参数：

• r : 只读；
• w : 只写；
• n : 总是创建一个数据库，打开方式为读写；
• c : 存在不创建，不存在则创建。

关闭数据库使用 dbm.close()，使用 with 语句之后，不需要手动释放资源。

with dbm.open(xxx) as db:
	pass

dbm 存储的形式类似 python 字典，以键值对形式存在。

import dbm

with dbm.open('example.db', 'n') as db:
    db['name'] = '橡皮擦' # 存储值
    db['age'] = '18' # values must be bytes or strings

读取值使用 db[key] 即可，如果没有 key 值，提示 KeyError 错误。

import dbm

with dbm.open('example.db', 'r') as db:
    ca = db["name"]
    age = db["age"]
    print(ca)

dbm 数据库保存的数据是字符串类型或者字节序列类型，读取到的值是字节序列类型，需要使用解码函数 decode 转换成字符串。

写在后面

以上内容就是本文的全部内容，希望对学习路上的你有所帮助~

今天是持续写作的第 230 / 365 天。 期待 关注，点赞、评论、收藏。

更多精彩

• 滚雪球学 Python（完结）
• 滚雪球学 Python 第二轮（完结）
• 滚雪球学 Python 第三轮
• 滚雪球学 Python 番外篇（完结）