Python中pymysql模块详解:安装、连接、执行SQL语句等常见操作
    		       		warning:
    		            这篇文章距离上次修改已过452天,其中的内容可能已经有所变动。
    		        
        		                
                
import pymysql
 
# 连接数据库
connection = pymysql.connect(host='localhost',
                             user='user',
                             password='passwd',
                             database='db',
                             charset='utf8mb4',
                             cursorclass=pymysql.cursors.DictCursor)
 
try:
    with connection.cursor() as cursor:
        # 创建一个新表
        sql = """
        CREATE TABLE `users` (
            `id` int(11) NOT NULL AUTO_INCREMENT,
            `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
            `password` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
            PRIMARY KEY (`id`)
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
        """
        cursor.execute(sql)
 
        # 插入一条记录
        sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"
        cursor.execute(sql, ('webmaster@example.com', 'very-secret'))
 
        # 查询记录
        cursor.execute("SELECT * FROM `users`")
        results = cursor.fetchall()
        for row in results:
            print(row)
 
    # 提交事务
    connection.commit()
 
except pymysql.MySQLError as e:
    # 处理异常
    print(f"Error: {e}")
 
finally:
    # 关闭连接
    connection.close()这段代码展示了如何使用pymysql模块连接MySQL数据库,创建一个新表,插入一条记录,查询记录,以及如何处理可能发生的异常和在最后关闭数据库连接。这是一个典型的数据库交互流程,对于学习如何在Python中操作MySQL数据库有很好的教育价值。
评论已关闭