Python数据库连接如何处理复杂的SQL语句

在Python中处理复杂的SQL语句，通常需要使用一个数据库连接库。最常用的库有sqlite3（适用于SQLite数据库）、pymysql（适用于MySQL数据库）和psycopg2（适用于PostgreSQL数据库）。这里以SQLite和MySQL为例，介绍如何处理复杂的SQL语句。

1. SQLite数据库（使用sqlite3库）：

import sqlite3

# 连接到数据库
conn = sqlite3.connect('example.db')
cursor = conn.cursor()

# 创建一个复杂的SQL语句，例如创建一个带有索引的表
create_table_sql = '''
CREATE TABLE IF NOT EXISTS users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    username TEXT NOT NULL UNIQUE,
    email TEXT NOT NULL UNIQUE,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    INDEX idx_username (username),
    INDEX idx_email (email)
);
'''

# 执行SQL语句
cursor.execute(create_table_sql)

# 提交更改并关闭连接
conn.commit()
conn.close()

2. MySQL数据库（使用pymysql库）：

首先，确保已经安装了pymysql库，如果没有安装，可以使用以下命令安装：

pip install pymysql

然后，使用以下代码连接到MySQL数据库并执行复杂的SQL语句：

import pymysql

# 连接到数据库
conn = pymysql.connect(host='localhost', user='your_username', password='your_password', database='example_db')
cursor = conn.cursor()

# 创建一个复杂的SQL语句，例如创建一个带有索引的表
create_table_sql = '''
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(255) NOT NULL UNIQUE,
    email VARCHAR(255) NOT NULL UNIQUE,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    INDEX idx_username (username),
    INDEX idx_email (email)
);
'''

# 执行SQL语句
cursor.execute(create_table_sql)

# 提交更改并关闭连接
conn.commit()
conn.close()

在这两个示例中，我们创建了一个带有索引的users表。你可以根据需要修改SQL语句以执行更复杂的操作，例如插入、更新、删除和查询数据。