以下是一个使用 Python 连接 MySQL 数据库的示例。这个示例使用 mysql-connector-python 库来实现数据库连接和基本的操作。

安装依赖

首先,确保你已经安装了 mysql-connector-python 库。如果没有安装,可以使用以下命令进行安装:

pip install mysql-connector-python

示例代码

以下是一个简单的 Python 脚本,用于连接 MySQL 数据库并执行基本的查询操作:

import mysql.connector
from mysql.connector import Error

def create_connection(host_name, user_name, user_password, db_name):
    """创建与 MySQL 数据库的连接"""
    connection = None
    try:
        connection = mysql.connector.connect(
            host=host_name,
            user=user_name,
            password=user_password,
            database=db_name
        )
        print("成功连接到 MySQL 数据库")
    except Error as e:
        print(f"连接错误: {e}")
    return connection

def execute_query(connection, query):
    """执行单条 SQL 查询"""
    cursor = connection.cursor()
    try:
        cursor.execute(query)
        connection.commit()
        print("查询成功")
    except Error as e:
        print(f"查询错误: {e}")

def main():
    # 数据库连接参数
    host = "localhost"  # 数据库主机
    user = "root"       # 数据库用户名
    password = "password"  # 数据库密码
    database = "mydatabase"  # 数据库名称

    # 创建连接
    connection = create_connection(host, user, password, database)

    # 示例查询:创建表
    create_table_query = """
    CREATE TABLE IF NOT EXISTS users (
        id INT AUTO_INCREMENT PRIMARY KEY,
        name VARCHAR(100) NOT NULL,
        age INT NOT NULL
    );
    """
    execute_query(connection, create_table_query)

    # 示例查询:插入数据
    insert_user_query = "INSERT INTO users (name, age) VALUES ('Alice', 30);"
    execute_query(connection, insert_user_query)

    # 关闭连接
    if connection.is_connected():
        connection.close()
        print("数据库连接已关闭")

if __name__ == "__main__":
    main()

代码说明

  1. 创建连接create_connection 函数用于创建与 MySQL 数据库的连接,并返回连接对象。
  2. 执行查询execute_query 函数用于执行 SQL 查询,并处理可能的错误。
  3. 主函数:在 main 函数中,设置数据库连接参数,创建连接,执行创建表和插入数据的查询,最后关闭连接。

注意事项

  • 确保 MySQL 服务正在运行,并且可以通过指定的主机和端口访问。
  • 用户名和密码必须具有访问指定数据库的权限。
  • 根据需要修改数据库连接参数。

运行该脚本后,你将能够连接到 MySQL 数据库并执行基本的 SQL 操作。

Logo

Agent 垂直技术社区,欢迎活跃、内容共建。

更多推荐