怎么连接数据库并执行sql查询操作记录

连接数据库并执行SQL查询操作是软件开发中一个非常常见的需求，不同的编程语言提供了各自的库和框架来简化这一过程，以下将介绍如何使用Python语言连接MySQL数据库，并执行基本的SQL查询操作。

网站建设哪家好，找成都创新互联！专注于网页设计、网站建设、微信开发、重庆小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了根河免费建站欢迎大家使用！

准备工作

在开始之前，确保已经安装了mysql-connector-python，这是Python连接MySQL的驱动，可以通过pip进行安装：

pip install mysql-connector-python

建立连接

连接到MySQL数据库需要使用mysql.connector模块中的connect()方法，你需要提供数据库的主机地址（或IP）、数据库名称、用户名和密码。

import mysql.connector
config = {
    'user': 'your_username',
    'password': 'your_password',
    'host': 'localhost',   or the IP address of your database server
    'database': 'your_database',
    'raise_on_warnings': True
}
cnx = mysql.connector.connect(**config)

执行SQL查询

一旦建立了连接，就可以创建一个游标对象，通过这个游标可以执行SQL语句。

cursor = cnx.cursor()
query = "SELECT * FROM your_table"
cursor.execute(query)

获取结果

对于查询操作（如SELECT），可以使用游标的fetchall()或fetchone()方法来获取结果。

rows = cursor.fetchall()
for row in rows:
    print(row)
或者逐行获取
row = cursor.fetchone()
while row is not None:
    print(row)
    row = cursor.fetchone()

关闭连接

完成所有数据库操作后，应该关闭游标和连接以释放资源。

cursor.close()
cnx.close()

异常处理

在实际应用中，应当对可能出现的异常进行处理，例如连接失败、执行语句错误等。

try:
    cnx = mysql.connector.connect(**config)
    cursor = cnx.cursor()
    cursor.execute(query)
    rows = cursor.fetchall()
    for row in rows:
        print(row)
except mysql.connector.Error as err:
    print(f"Something went wrong: {err}")
finally:
    cursor.close()
    cnx.close()

参数化查询

为了防止SQL注入攻击，推荐使用参数化查询，即在SQL语句中使用占位符，并在执行时提供参数。

query = "SELECT * FROM employees WHERE hire_date > %s"
hire_start = datetime.datetime(2005, 1, 1)
cursor.execute(query, (hire_start,))