使用 Python 连接 MySQL 并执行创建数据库和数据表的操作，可以通过多种库实现，例如 `pymysql`、`mysql-connector-python` 和 `sqlalchemy`。以下是使用这些库的示例代码。 ### 使用 `pymysql` 创建数据库和数据表 ```python import pymysql # 连接到 MySQL 服务器（不需要指定数据库） connection = pymysql.connect( host='localhost', user='root', password='your_password', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor ) try: with connection.cursor() as cursor: # 创建数据库（如果不存在） cursor.execute("CREATE DATABASE IF NOT EXISTS mydatabase") # 重新连接并指定数据库 connection = pymysql.connect( host='localhost', user='root', password='your_password', database='mydatabase', charset='utf8mb4', cursorclass=pymysql.cursors.DictCursor ) with connection.cursor() as cursor: # 创建数据表 create_table_sql = """ CREATE TABLE IF NOT EXISTS mytable ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255) NOT NULL, age INT ) """ cursor.execute(create_table_sql) # 提交事务 connection.commit() finally: connection.close() ``` ### 使用 `mysql-connector-python` 创建数据库和数据表 ```python import mysql.connector # 连接到 MySQL 服务器 cnx = mysql.connector.connect( host='localhost', user='root', password='your_password' ) cursor = cnx.cursor() # 创建数据库（如果不存在） cursor.execute("CREATE DATABASE IF NOT EXISTS mydatabase") # 切换到新创建的数据库 cursor.execute("USE mydatabase") # 创建数据表 create_table_sql = """ CREATE TABLE IF NOT EXISTS mytable ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255) NOT NULL, age INT ) """ cursor.execute(create_table_sql) # 提交事务 cnx.commit() # 关闭连接 cursor.close() cnx.close() ``` ### 使用 `sqlalchemy` 创建数据库和数据表 ```python from sqlalchemy import create_engine, Column, Integer, String from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import sessionmaker # 创建数据库引擎 engine = create_engine("mysql+mysqlconnector://root:your_password@localhost:3306/mydatabase", echo=True) # 声明基类 Base = declarative_base() # 定义数据表模型 class MyTable(Base): __tablename__ = 'mytable' id = Column(Integer, primary_key=True) name = Column(String(255), nullable=False) age = Column(Integer) # 创建数据库和数据表 Base.metadata.create_all(engine) # 创建会话 Session = sessionmaker(bind=engine) session = Session() # 添加数据（可选） new_record = MyTable(name='张三', age=30) session.add(new_record) session.commit() session.close() ``` ### 总结 - 使用 `pymysql` 或 `mysql-connector-python` 可以直接通过 SQL 语句操作数据库和数据表。 - 使用 `sqlalchemy` 可以通过 ORM 模式定义数据表结构，并自动生成数据库和表[^1]。