pymysql用法_基本用法

pymysql基本用法

成都创新互联公司秉承实现全网价值营销的理念，以专业定制企业官网，网站建设、成都网站制作，重庆小程序开发公司，网页设计制作，成都做手机网站，成都全网营销推广帮助传统企业实现“互联网+”转型升级专业定制企业官网,公司注重人才、技术和管理，汇聚了一批优秀的互联网技术人才,对客户都以感恩的心态奉献自己的专业和所长。

在Python中，pymysql是一个流行的库，用于连接和操作MySQL数据库，它提供了一组丰富的API，使得开发者能够以简洁的方式执行SQL查询和管理数据库，以下是pymysql的基本用法介绍：

安装

确保安装了pymysql库，如果没有安装，可以通过pip进行安装：

pip install pymysql

连接数据库

要连接到MySQL数据库，首先需要创建一个连接，这通常涉及到数据库的地址、端口号、用户名称以及密码。

import pymysql
创建连接
connection = pymysql.connect(host='localhost',
                             user='username',
                             password='password',
                             db='database_name',
                             charset='utf8mb4',
                             cursorclass=pymysql.cursors.DictCursor)

创建游标

连接创建后，下一步是创建一个游标对象，游标用于执行SQL语句并获取结果。

创建游标
try:
    with connection.cursor() as cursor:
        # 执行SQL语句
        pass
finally:
    # 关闭连接
    connection.close()

执行SQL语句

通过游标对象，可以执行各种SQL语句，如SELECT、INSERT、UPDATE和DELETE。

执行SQL语句
sql = "SELECT * FROM table_name"
cursor.execute(sql)
获取所有记录列表
results = cursor.fetchall()
for row in results:
    print(row)

插入数据

插入数据到表中也很简单，只需要构造适当的INSERT语句。

插入数据
sql = "INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')"
cursor.execute(sql)
connection.commit()

更新和删除数据

更新和删除数据的操作与插入类似，只是使用UPDATE和DELETE语句。

更新数据
sql = "UPDATE table_name SET column1 = 'new_value' WHERE condition"
cursor.execute(sql)
connection.commit()
删除数据
sql = "DELETE FROM table_name WHERE condition"
cursor.execute(sql)
connection.commit()

事务处理

pymysql支持事务处理，这对于保持数据的完整性非常重要。

开始事务
connection.begin()
try:
    # 执行一系列SQL语句
    pass
except:
    # 发生错误时回滚事务
    connection.rollback()
else:
    # 没有错误时提交事务
    connection.commit()
finally:
    # 关闭连接
    connection.close()

异常处理

在操作数据库时，可能会遇到各种异常，如连接失败或SQL语句错误。pymysql提供了异常类来处理这些情况。

try:
    # 数据库操作代码
    pass
except pymysql.Error as e:
    print("数据库操作错误：", e)