批量执行sql语句的方法可以适用于大批量数据的导入、更新等操作,以提高效率。以下是实现批量执行sql语句的方法:
准备工作
在执行sql语句之前,需要首先连接到数据库,可以使用以下代码:
import pymysql
conn = pymysql.connect(
host='localhost',
port=3306,
user='root',
password='root',
database='test',
charset='utf8'
)
cursor = conn.cursor()
方法一:使用executemany()函数
executemany()
函数可以一次性执行多个sql语句,适用于需要多次插入数据的情况。示例如下:
# 假设有一个学生列表需要插入到数据库中,可以使用以下代码实现:
students = [('Tom', 'M', 18), ('Jerry', 'F', 19), ('Lucy', 'F', 17), ('Mike', 'M', 20)]
# 构造插入语句
insert_sql = "INSERT INTO students(name, gender, age) values (%s, %s, %s)"
# 执行插入语句
cursor.executemany(insert_sql, students)
# 提交事务
conn.commit()
# 关闭连接
cursor.close()
conn.close()
方法二:使用executescript()函数
executescript()
函数可以一次性执行多条sql语句,适用于需要执行多个sql语句的情况。示例如下:
# 假设需要执行一些批量更新的操作,可以使用以下代码实现:
update_sql = """
UPDATE students SET age = age + 1 WHERE gender = 'M';
UPDATE students SET age = age + 1 WHERE gender = 'F';
"""
# 执行更新语句
cursor.executescript(update_sql)
# 提交事务
conn.commit()
# 关闭连接
cursor.close()
conn.close()
以上就是两种实现批量执行sql语句的方法,请根据实际情况选择使用。
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:批量执行sql语句的方法 - Python技术站