Python 操作 MySQL 数据库_Mysql数据库

本文主要介绍了如何使用Python操作MySQL数据库,包括连接数据库、执行SQL语句、获取查询结果等基本操作。通过学习这些内容,读者可以掌握使用Python进行数据库开发的基本技能。

Python操作MySQL数据库简介

Python是一种广泛使用的高级编程语言,具有丰富的库和框架,在Python中,我们可以使用多种方式来操作MySQL数据库,例如使用原生的MySQL Connector/Python库,或者使用第三方库如PyMySQL、SQLAlchemy等,这些库提供了丰富的功能,可以帮助我们轻松地连接、查询、插入、更新和删除数据库中的数据。

Python 操作 MySQL 数据库_Mysql数据库
(图片来源网络,侵删)

二、安装MySQL Connector/Python库

在使用Python操作MySQL数据库之前,我们需要先安装MySQL Connector/Python库,可以通过以下命令进行安装:

pip install mysqlconnectorpython

连接MySQL数据库

安装好MySQL Connector/Python库后,我们可以使用以下代码连接到MySQL数据库:

import mysql.connector
创建连接对象
cnx = mysql.connector.connect(user='用户名', password='密码', host='主机地址', database='数据库名')
创建游标对象
cursor = cnx.cursor()

执行SQL语句

在连接成功后,我们可以使用游标对象执行SQL语句,以下是一些常用的SQL语句示例:

1、查询数据:

sql = "SELECT * FROM table_name"
cursor.execute(sql)
result = cursor.fetchall()
for row in result:
    print(row)

2、插入数据:

sql = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)"
values = ('value1', 'value2')
cursor.execute(sql, values)
cnx.commit()

3、更新数据:

Python 操作 MySQL 数据库_Mysql数据库
(图片来源网络,侵删)
sql = "UPDATE table_name SET column1 = %s, column2 = %s WHERE condition"
values = ('new_value1', 'new_value2')
cursor.execute(sql, values)
cnx.commit()

4、删除数据:

sql = "DELETE FROM table_name WHERE condition"
cursor.execute(sql)
cnx.commit()

关闭连接和游标

在完成数据库操作后,我们需要关闭游标和连接,释放资源,可以使用以下代码:

cursor.close()
cnx.close()

使用PyMySQL库操作MySQL数据库

除了使用MySQL Connector/Python库外,我们还可以使用PyMySQL库来操作MySQL数据库,首先需要安装PyMySQL库:

pip install pymysql

然后可以使用以下代码连接到MySQL数据库:

import pymysql
创建连接对象
cnx = pymysql.connect(host='主机地址', user='用户名', password='密码', database='数据库名')

我们可以使用游标对象执行SQL语句,以及关闭连接和游标,与MySQL Connector/Python库类似,这里不再赘述。

七、使用SQLAlchemy库操作MySQL数据库

SQLAlchemy是一个功能强大的Python ORM(对象关系映射)库,可以帮助我们更方便地操作数据库,首先需要安装SQLAlchemy库:

Python 操作 MySQL 数据库_Mysql数据库
(图片来源网络,侵删)
pip install sqlalchemy

然后可以使用以下代码连接到MySQL数据库:

from sqlalchemy import create_engine, Table, MetaData, select, update, delete, insert, text, func, and_, or_, not_, exists, nullsfirst, nullslast, asc, desc, bindparam, String, Integer, Float, Date, Time, datetime, DateTime, SmallInteger, LargeBinary, Text, Blob, Numeric, UnicodeText, Unicode, NoneType, boolean, true, false, NoneType.instance, cast, case, when, otherwise, between, union_all, union_distinct, intersect_all, intersect_distinct, except_all, except_distinct, like_all, like_distinct, any_true, any_false, array_agg, array_join, array_slice, array_sort, array_reverse, json_array_agg, json_array_elements_text, json_array_elements_binary, json_array_elements_objectid, json_array_elements_int64, json_array_elements_float64, json_array_elements_datetime64tzinfo, json_array_elements_bool64, json_array_elements_string64, json_array_elements_unicode64, json_array_elements_any64, json_array_elements_numeric64, json_array_elements_date64tzinfo, json_array_elements_time64tzinfo, json_array_elements_datetime64tzinfo2dtype(), jsonpath(), coalesce(), greatest(), least(), stringify(), typecast(), length(), collate(), nullif(), current_timestamp(), current_date(), current_time(), now(), interval(), extract(), year(), month(), day(), hour(), minute(), second(), quarter(), weekday(), isocalendar().create_engine('mysql+pymysql://用户名:密码@主机地址:端口号/数据库名?charset=utf8mb4') # 注意添加charset参数以支持中文字符集,否则可能会出现乱码问题。

下面是一个简单的介绍,展示了使用 Python 操作 MySQL 数据库时可能用到的一些基本命令和操作。

操作类型 Python 代码示例 描述
安装MySQL驱动 pip install mysqlconnectorpython 安装MySQL连接器

| 连接数据库 | “`python

import mysql.connector

db = mysql.connector.connect(

host="localhost",

user="yourusername",

password="yourpassword",

database="mydatabase"

“` | 创建与MySQL数据库的连接 |

创建游标对象 cursor = db.cursor() 游标用于执行SQL命令

| 执行SQL查询 | “`python

cursor.execute("SELECT * FROM yourtable")

“` | 在数据库上执行SQL查询 |

| 获取查询结果 | “`python

results = cursor.fetchall()

for row in results:

print(row)

“` | 获取查询结果,并遍历输出 |

| 插入数据 | “`python

sql = "INSERT INTO yourtable (name, age) VALUES (%s, %s)"

val = ("John", 21)

cursor.execute(sql, val)

db.commit()

“` | 向表中插入数据,并提交 |

| 更新数据 | “`python

sql = "UPDATE yourtable SET age = %s WHERE name = %s"

val = (22, "John")

cursor.execute(sql, val)

db.commit()

“` | 更新表中数据,并提交 |

| 删除数据 | “`python

sql = "DELETE FROM yourtable WHERE name = %s"

name = ("John’,)

cursor.execute(sql, name)

db.commit()

“` | 从表中删除数据,并提交 |

| 查询预处理 | “`python

sql = "SELECT * FROM yourtable WHERE age = %s"

age = (21,)

cursor.execute(sql, age)

“` | 使用预处理语句进行查询 |

| 错误处理 | “`python

try:

# 数据库操作

except mysql.connector.Error as e:

print("Error:", e)

“` | 捕获并处理可能出现的错误 |

关闭游标 cursor.close() 关闭游标对象
断开连接 db.close() 关闭数据库连接

请注意,这些示例代码是根据一般场景提供的,实际使用时你可能需要根据你的具体需求和环境进行适当的修改,特别是在处理数据库连接和执行SQL命令时,要确保你的代码是安全的,避免SQL注入等安全风险。

原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/690955.html

本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。

(0)
未希新媒体运营
上一篇 2024-06-15 16:10
下一篇 2024-06-15 16:11

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注

产品购买 QQ咨询 微信咨询 SEO优化
分享本页
返回顶部
云产品限时秒杀。精选云产品高防服务器,20M大带宽限量抢购 >>点击进入