用Python轻松连接MySQL数据库，实现高效数据管理

发布时间：2023-05-20

在现代的信息化时代，海量的数据已经成为各个行业中必不可少的资源。如何高效地管理这些数据，发掘其中的潜在价值，已然成为了每一个从事数据管理工作的人的必修课。而在数据管理的过程中，数据库就是最为常用和最为重要的工具之一。本文将通过实例讲解如何使用Python连接MySQL数据库，来实现高效数据管理。

一、MySQL数据库以及Python MySQL Connector驱动

1、MySQL数据库

MySQL是一种开源的关系型数据库管理系统，在数据存储和基础设施方面非常的稳定，擅长处理大量数据，广泛应用于Web应用程序中。MySQL支持的数据类型非常丰富，而且由于其开源的特性，可以被各种操作系统和平台使用。

2、Python MySQL Connector驱动

Python MySQL Connector是Python连接MySQL数据库的一个驱动，可以通过Python语言操作MySQL数据库的数据，具有开源、高效、稳定等特点。而且，Python MySQL Connector支持和兼容Python的各种版本，使用Python MySQL Connector可以轻松实现Python与MySQL之间的数据交互，可用于数据库查询、数据读写等操作。

二、Python连接MySQL数据库的基本步骤

Python连接MySQL数据库的过程主要分为三个步骤：

1、安装MySQL驱动

在Python连接MySQL之前，我们需要先在Python中安装MySQL驱动。移步到Python官网(https://www.python.org/downloads/)下载并安装对应版本的Python。MySQL驱动支持Python 2.7，3.4及以上版本。

2、连接到MySQL服务器

使用Python MySQL Connector中的connect函数可以连接到MySQL服务器。在连接时需要提供MySQL服务器的地址、用户名和密码等信息。以下是连接到MySQL服务器格式示例：

import mysql.connector
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword"
)
print(mydb)

3、创建和管理MySQL数据库

可以使用Python MySQL Connector新建和管理MySQL数据库。在MySQL中，可以使用CREATE DATABASE语句创建新的数据库，语法如下：

import mysql.connector
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword"
)
mycursor = mydb.cursor()
mycursor.execute("CREATE DATABASE mydatabase")

三、Python读写MySQL数据库的操作

Python连接到MySQL服务器之后，就可以进行数据库的操作。Python MySQL Connector提供了一种与MySQL数据库进行交互的自然方式，即使用光标对象（“cursor object”）。光标对象通过execute()方法执行MySQL查询，然后返回结果。

1、查询数据

可以使用Python MySQL Connector查询MySQL数据库中的数据。如果需要查询整个表，可以使用SELECT语句。以下是一个查询数据的例子：

import mysql.connector
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM customers")
myresult = mycursor.fetchall()
for x in myresult:
  print(x)

2、插入数据

可以使用Python MySQL Connector向MySQL数据库中插入数据。需要使用INSERT INTO语句，语法如下：

import mysql.connector
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)
mycursor = mydb.cursor()
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record inserted.")

3、更新数据

可以使用Python MySQL Connector更新MySQL数据库中的数据。使用UPDATE语句来更新数据，语法如下：

import mysql.connector
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)
mycursor = mydb.cursor()
sql = "UPDATE customers SET address = 'Canyon 123' WHERE name = 'John'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) affected")

4、删除数据

可以使用Python MySQL Connector删除MySQL数据库中的数据。使用DELETE语句删除某些记录，语法如下：

import mysql.connector
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)
mycursor = mydb.cursor()
sql = "DELETE FROM customers WHERE address = 'Mountain 21'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) deleted")

四、实战：Python实现MySQL数据库的增删改查

在学习了Python MySQL Connector的基本使用方法之后，我们可以通过实际代码操作MySQL数据库，实现数据的增删改查功能。 以下是一个简单的示例，实现增加、删除、修改和查询MySQL数据库中的数据：

import mysql.connector
# 创建连接对象
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)
# 创建光标对象
mycursor = mydb.cursor()
# 创建表
mycursor.execute("CREATE TABLE customers (name VARCHAR(255), address VARCHAR(255))")
# 插入数据
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, "record inserted.")
# 查询数据
mycursor.execute("SELECT * FROM customers")
myresult = mycursor.fetchall()
for x in myresult:
  print(x)
# 更新数据
sql = "UPDATE customers SET address = 'Canyon 123' WHERE name = 'John'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) affected")
# 删除数据
sql = "DELETE FROM customers WHERE address = 'Mountain 21'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, "record(s) deleted")

通过上述代码，我们可以轻松的对MySQL数据库进行增删改查的操作，从而实现高效的数据管理。

推荐文章