数据库进阶教程：结合编程实现动态数据操作
在前一篇文章中，我们了解了数据库的基础知识及其核心操作。这次，我们将通过编程语言（以 Python 为例）与数据库进行交互，进一步提升你的数据库应用能力。我们将学习如何通过代码完成数据的插入、查询、更新和删除，并实现一个小型的动态应用。
准备工作：环境搭建
-
安装 MySQL 数据库
如果你还没有安装数据库，可以通过 MySQL 官网 下载并安装 MySQL Community Server。 -
安装 Python 和相关库
确保你已安装 Python（推荐版本 3.8 或更高）。然后通过pip安装数据库交互库：pip install mysql-connector-python
场景描述：用户信息管理系统
我们将继续使用前一篇的 users 表，目标是通过 Python 实现对用户信息的动态管理，包括：
- 新增用户。
- 查询用户信息。
- 更新用户的电子邮件。
- 删除用户。
代码实现
1. 连接到数据库
首先，编写一个函数用于连接 MySQL 数据库：
import mysql.connector
def connect_to_db():
try:
connection = mysql.connector.connect(
host="localhost", # 数据库主机
user="root", # 数据库用户名
password="yourpassword", # 数据库密码
database="yourdatabase" # 数据库名称
)
return connection
except mysql.connector.Error as err:
print(f"Error: {err}")
return None
2. 创建用户插入功能
通过 Python 插入一条新的用户记录：
def add_user(username, email, registration_date):
connection = connect_to_db()
if connection:
try:
cursor = connection.cursor()
query = "INSERT INTO users (username, email, registration_date) VALUES (%s, %s, %s)"
cursor.execute(query, (username, email, registration_date))
connection.commit()
print("User added successfully!")
except mysql.connector.Error as err:
print(f"Error: {err}")
finally:
connection.close()
调用示例：
add_user("Daisy", "daisy@example.com", "2023-12-04")
3. 查询用户信息
通过用户名动态查询用户数据：
def get_user_by_username(username):
connection = connect_to_db()
if connection:
try:
cursor = connection.cursor()
query = "SELECT * FROM users WHERE username = %s"
cursor.execute(query, (username,))
result = cursor.fetchone()
if result:
print(f"User found: {result}")
else:
print("User not found.")
except mysql.connector.Error as err:
print(f"Error: {err}")
finally:
connection.close()
调用示例：
get_user_by_username("Alice")
4. 更新用户信息
更新用户的电子邮件地址：
def update_user_email(username, new_email):
connection = connect_to_db()
if connection:
try:
cursor = connection.cursor()
query = "UPDATE users SET email = %s WHERE username = %s"
cursor.execute(query, (new_email, username))
connection.commit()
if cursor.rowcount > 0:
print("User email updated successfully!")
else:
print("User not found.")
except mysql.connector.Error as err:
print(f"Error: {err}")
finally:
connection.close()
调用示例：
update_user_email("Alice", "alice.updated@example.com")
5. 删除用户
根据用户名删除用户记录：
def delete_user(username):
connection = connect_to_db()
if connection:
try:
cursor = connection.cursor()
query = "DELETE FROM users WHERE username = %s"
cursor.execute(query, (username,))
connection.commit()
if cursor.rowcount > 0:
print("User deleted successfully!")
else:
print("User not found.")
except mysql.connector.Error as err:
print(f"Error: {err}")
finally:
connection.close()
调用示例：
delete_user("Charlie")
完整示例：用户管理菜单
将以上功能整合到一个简单的命令行菜单中：
def main():
while True:
print("\nUser Management System")
print("1. Add User")
print("2. Get User")
print("3. Update User Email")
print("4. Delete User")
print("5. Exit")
choice = input("Enter your choice: ")
if choice == "1":
username = input("Enter username: ")
email = input("Enter email: ")
registration_date = input("Enter registration date (YYYY-MM-DD): ")
add_user(username, email, registration_date)
elif choice == "2":
username = input("Enter username to search: ")
get_user_by_username(username)
elif choice == "3":
username = input("Enter username to update: ")
new_email = input("Enter new email: ")
update_user_email(username, new_email)
elif choice == "4":
username = input("Enter username to delete: ")
delete_user(username)
elif choice == "5":
print("Goodbye!")
break
else:
print("Invalid choice. Please try again.")
if __name__ == "__main__":
main()
总结：从理论到实践
通过这篇文章，你学会了如何结合 Python 编程与数据库进行交互：
- 建立数据库连接。
- 使用编程语言动态执行 SQL 操作。
- 整合功能，开发一个完整的用户管理系统。
你可以将这些代码扩展到更复杂的场景，比如实现基于 Web 的数据库交互（例如使用 Flask 或 Django 框架）。数据库的学习是一个循序渐进的过程，勤于动手实践是关键！
原文地址：https://blog.csdn.net/B5201234/article/details/144409828
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！