python操作达梦数据库新增改查-CFANZ编程社区

Python操作达梦数据库新增、修改、查询示例

达梦数据库（DM Database）是国内自主研发的关系型数据库系统。Python则是广泛使用的编程语言之一，提供了强大的数据库操作能力。本文将介绍如何使用Python对达梦数据库进行新增、修改和查询操作，并提供相应的代码示例。

环境准备

在开始之前，需要确保已安装以下几个组件：

Python：建议使用Python 3.x版本。
达梦数据库客户端：访问达梦数据库的必要工具。
Python DB-API驱动：基于dmPython或pydm库，可以通过pip安装。

pip install pydm

确保驱动程序与达梦数据库版本兼容。

连接达梦数据库

首先，我们需要建立与达梦数据库的连接。以下是连接数据库的基本示例。

import pydm

# 连接信息
host = "localhost"
port = 5236
database = "your_database"
user = "your_user"
password = "your_password"

# 建立连接
conn = pydm.connect(user=user, password=password, dsn=f"{host}:{port}/{database}")
cursor = conn.cursor()

新增数据

下面是一个新增数据的示例。假设我们有一个名为employees的表，结构如下：

| id | name       | age | department |
|----|------------|-----|------------|
| 1  | Alice      | 30  | IT         |
| 2  | Bob        | 25  | Marketing  |

我们将插入一条新记录。

# 新增员工
insert_query = "INSERT INTO employees (id, name, age, department) VALUES (?, ?, ?, ?)"
new_employee = (3, 'Charlie', 28, 'Finance')

cursor.execute(insert_query, new_employee)
conn.commit()  # 提交更改

修改数据

接下来，我们将更新已存在记录的内容。例如，我们要修改Bob的年龄。

# 更新员工年龄
update_query = "UPDATE employees SET age = ? WHERE name = ?"
updated_info = (26, 'Bob')

cursor.execute(update_query, updated_info)
conn.commit()  # 提交更改

查询数据

现在让我们查询employees表中的所有记录。

# 查询所有员工
select_query = "SELECT * FROM employees"
cursor.execute(select_query)

# 获取并打印结果
results = cursor.fetchall()
for row in results:
    print(row)  # 输出每一条记录

关闭连接

完成数据库操作后，请务必关闭连接，以释放资源。

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

总结

通过上述步骤，我们已经成功实现了对达梦数据库的新增、修改和查询操作。使用Python操作达梦数据库，可以方便地进行数据管理和更新。以下是完整代码汇总：

import pydm

# 连接信息
host = "localhost"
port = 5236
database = "your_database"
user = "your_user"
password = "your_password"

# 建立连接
conn = pydm.connect(user=user, password=password, dsn=f"{host}:{port}/{database}")
cursor = conn.cursor()

# 新增员工
insert_query = "INSERT INTO employees (id, name, age, department) VALUES (?, ?, ?, ?)"
new_employee = (3, 'Charlie', 28, 'Finance')
cursor.execute(insert_query, new_employee)
conn.commit()

# 更新员工年龄
update_query = "UPDATE employees SET age = ? WHERE name = ?"
updated_info = (26, 'Bob')
cursor.execute(update_query, updated_info)
conn.commit()

# 查询所有员工
select_query = "SELECT * FROM employees"
cursor.execute(select_query)
results = cursor.fetchall()
for row in results:
    print(row)

# 关闭连接
cursor.close()
conn.close()

将这些操作结合使用，可以帮助开发者更加高效地管理和操作数据库。希望本文能够为您提供有益的参考和指导！