Python中如何使用MySQL连接器？

pip install mysql-connector-python

import mysql.connector

# 连接到MySQL数据库
connection = mysql.connector.connect(
    host="localhost",
    user="yourusername",
    password="yourpassword",
    database="yourdatabase"
)

# 创建游标对象
cursor = connection.cursor()

# 执行SQL查询
cursor.execute("SELECT * FROM yourtable")

# 获取查询结果
results = cursor.fetchall()

# 打印结果
for row in results:
    print(row)

# 关闭游标和连接
cursor.close()
connection.close()

import mysql.connector
from mysql.connector import Error

try:
    connection = mysql.connector.connect(
        host="localhost",
        user="yourusername",
        password="yourpassword",
        database="yourdatabase"
    )

    if connection.is_connected():
        cursor = connection.cursor()
        cursor.execute("SELECT * FROM yourtable")
        results = cursor.fetchall()
        for row in results:
            print(row)

except Error as e:
    print(f"Error connecting to MySQL database: {e}")

finally:
    if connection.is_connected():
        cursor.close()
        connection.close()
        print("MySQL connection is closed")

import mysql.connector

connection = mysql.connector.connect(
    host="localhost",
    user="yourusername",
    password="yourpassword",
    database="yourdatabase"
)

try:
    cursor = connection.cursor()
    cursor.execute("START TRANSACTION")

    # 执行多个SQL语句
    cursor.execute("INSERT INTO yourtable (column1, column2) VALUES ('value1', 'value2')")
    cursor.execute("UPDATE anothertable SET column3 = 'value3' WHERE condition")

    connection.commit()  # 提交事务
    print("Transaction committed successfully")

except mysql.connector.Error as error:
    connection.rollback()  # 回滚事务
    print(f"Failed to execute transaction: {error}")

finally:
    if connection.is_connected():
        cursor.close()
        connection.close()
        print("MySQL connection is closed")

import mysql.connector
from mysql.connector import pooling

# 创建连接池
dbconfig = {
    "database": "yourdatabase",
    "user": "yourusername",
    "password": "yourpassword",
    "host": "localhost"
}

connection_pool = mysql.connector.pooling.MySQLConnectionPool(
    pool_name="mypool",
    pool_size=5,
    **dbconfig
)

# 从连接池中获取连接
connection = connection_pool.get_connection()
cursor = connection.cursor()

try:
    cursor.execute("SELECT * FROM yourtable")
    results = cursor.fetchall()
    for row in results:
        print(row)

finally:
    cursor.close()
    connection.close()

cursor.execute("SELECT * FROM yourtable WHERE id = %s", (id,))