pymysql连接数据库

import pymysql

# 创建数据库连接
def create_connection():
    try:
        # 连接数据库，需要提供数据库的主机地址、用户名、密码、数据库名称等信息
        connection = pymysql.connect(
            host='localhost',  # 数据库主机地址
            user='root',       # 数据库用户名
            password='password',  # 数据库密码
            database='test_db',  # 要连接的数据库名称
            charset='utf8mb4',  # 字符编码
            cursorclass=pymysql.cursors.DictCursor  # 使用字典游标
        )
        print("连接成功")
        return connection
    except pymysql.MySQLError as e:
        print(f"连接失败: {e}")
        return None

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

# 示例：查询数据
def query_data():
    connection = create_connection()
    if connection:
        try:
            with connection.cursor() as cursor:
                # 执行SQL查询语句
                sql = "SELECT * FROM users"
                cursor.execute(sql)
                # 获取所有记录
                result = cursor.fetchall()
                for row in result:
                    print(row)
        finally:
            close_connection(connection)

if __name__ == "__main__":
    query_data()

解释说明：

1. 导入pymysql模块：首先需要导入pymysql模块。
2. 创建数据库连接：使用pymysql.connect()方法创建一个数据库连接。需要提供主机地址、用户名、密码、数据库名称等信息。
3. 关闭数据库连接：在操作完成后，务必关闭数据库连接以释放资源。
4. 执行查询：通过cursor.execute()方法执行SQL查询，并使用cursor.fetchall()获取所有查询结果。
5. 异常处理：在连接数据库和执行查询时，使用try-except块捕获并处理可能的异常。

这个示例展示了如何使用pymysql连接到MySQL数据库并执行简单的查询操作。