如何用python使用mysql数据库

摘要

使用 Python 连接和操作 MySQL 数据库可以分为以下几个步骤：

• 导入必要的模块：使用 pip install mysql-connector-python 安装 mysql-connector-python 模块。
• 建立连接：使用 mysql.connector.connect() 函数建立与 MySQL 数据库的连接。
• 创建游标：使用 connection.cursor() 方法创建游标对象，用于执行查询和更新。
• 执行查询：使用 execute() 方法执行查询，并将结果存储在游标对象中。
• 处理结果：使用 fetchall() 方法获取查询结果，或使用 fetchone() 方法获取单行结果。
• 提交更改：对于更新或删除操作，使用 commit() 方法提交更改。
• 关闭连接：使用 close() 方法关闭连接。

详细说明

1. 导入必要的模块

import mysql.connector

2. 建立连接

connection = mysql.connector.connect(
    host="localhost",
    user="username",
    password="password",
    database="database_name"
)

其中：

• host：数据库主机地址。
• user：数据库用户名。
• password：数据库密码。
• database_name：要连接的数据库名称。

3. 创建游标

cursor = connection.cursor()

4. 执行查询

query = "SELECT * FROM table_name"
cursor.execute(query)

5. 处理结果

results = cursor.fetchall()

6. 提交更改

cursor.execute("UPDATE table_name SET column_name = "new_value" WHERE id = 1")
connection.commit()

7. 关闭连接

cursor.close()
connection.close()

附加信息

• 查询参数化：使用占位符 (?) 和 execute() 方法的 params 参数，可以防止 SQL 注入攻击。
• 事务处理：使用 connection.begin() 和 connection.rollback() 可以控制事务。
• 异常处理：使用 try 和 except 块来处理数据库连接和操作中的异常。
• 数据库连接池：使用 mysql.connector.connect() 的 pool_name 参数可以创建连接池，从而提高效率。

示例代码

import mysql.connector

def connect_to_database():
    connection = mysql.connector.connect(
        host="localhost",
        user="username",
        password="password",
        database="database_name"
    )
    return connection

def get_all_users(connection):
    cursor = connection.cursor()
    query = "SELECT * FROM users"
    cursor.execute(query)
    results = cursor.fetchall()
    cursor.close()
    return results

def main():
    connection = connect_to_database()
    users = get_all_users(connection)
    for user in users:
        print(user)
    connection.close()

if __name__ == "__main__":
    main()

以上就是如何用python使用mysql数据库的详细内容，更多请关注编程网其它相关文章！