python链接数据库mysql查询
时间: 2025-07-05 15:03:25 浏览: 0
### Python连接MySQL数据库并执行查询
#### 导入必要的库
为了能够使用Python与MySQL数据库进行交互,需要先安装`pymysql`库。可以通过pip工具完成安装。
```bash
pip install pymysql
```
接着,在脚本中引入此库以便后续操作[^2]。
#### 建立数据库连接
定义一个名为`connect_to_database`的函数用来建立同MySQL服务器之间的链接,并接收四个参数——主机名(`host`)、用户名(`user`)、密码(`password`)以及目标数据库名称(`database`)。如果成功建立了连接,则返回对应的数据库连接实例;反之则抛出异常提示错误信息[^4]。
```python
import pymysql
def connect_to_database(host, user, password, database):
try:
connection = pymysql.connect(
host=host,
user=user,
password=password,
database=database
)
print("数据库连接成功")
return connection
except pymysql.Error as error:
print(f"数据库连接失败:{error}")
```
#### 执行SQL查询命令
创建另一个辅助函数`execute_sql_query`接受两个输入参数:一个是之前获得的数据连接对象(`connection`),另外一个是待执行的具体SQL语句字符串(`query`)。该函数内部会调用游标的`execute()`方法运行传入的SQL指令,并利用`fetchall()`收集所有匹配记录作为列表形式的结果集返回给调用者。
```python
def execute_sql_query(connection, query):
with connection.cursor() as cursor:
cursor.execute(query)
result_set = cursor.fetchall()
return result_set
```
#### 主程序逻辑控制
最后,在主模块入口处测试上述功能是否正常工作。这里尝试打开指定表内的全部行数据并通过循环逐项展示出来。当一切处理完毕之后记得断开现有的网络链路以节省系统资源。
```python
if __name__ == "__main__":
conn = connect_to_database("localhost", "root", "", "testdb")
sql_statement = "SELECT * FROM users"
records = execute_sql_query(conn, sql_statement)
for record in records:
print(record)
conn.close()
```
阅读全文
相关推荐















