MySQL使用Python的mysql Connector插入数据

在本文中，我们将介绍如何使用Python的mysql Connector模块将数据插入MySQL中。MySQL是一种流行的关系型数据库管理系统，它是开源的，可从MySQL官方网站上免费下载。而Python是一种流行的高级编程语言，它的灵活性和易读性使得它在各种数据科学应用中非常流行。Python的 mysql Connector模块为Python语言提供了简单、可靠、高效的MySQL数据库连接和操作。在这里，我们将学习如何使用MySQL Connector模块将数据插入MySQL数据库中。

阅读更多：MySQL 教程

准备工作

安装Python

如果尚未安装Python，您可以从Python官方网站下载并安装适合您的操作系统版本。在安装完毕后，可以通过在终端窗口中键入“python -v”命令来检查Python版本。

安装MySQL数据库：

如果您尚未安装MySQL数据库，则必须下载并安装并配置MySQL。您可以从MySQL官方网站下载MySQL安装程序并执行。您还需要安装适当的MySQL驱动程序，以便Python可以连接到MySQL数据库。在这里我们将使用mysql Connector模块。

安装Python mysql Connector

可以在安装MySQL的过程中随意勾选Python Connector的选项进行安装，如果未安装，可以通过pip命令在终端中轻松安装mysql Connector。在终端窗口中输入以下命令来安装mysql Connector

pip install mysql-connector-python

连接到MySQL数据库

首先，我们需要连接到MySQL数据库。为此，我们需要提供MySQL数据库的主机名、端口号、用户名和密码。在这里我们假设数据库在本地安装，端口号为3306，用户名和密码为root。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password"
)

print(mydb)

创建数据库

在连接到MySQL数据库之后，我们可以创建新数据库。首先，我们需要创建一个mysql.connector.cursor对象并使用执行CREATE DATABASE语句创建新数据库。在这里我们创建一个名为“test”的新数据库。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password"
)

mycursor = mydb.cursor()

mycursor.execute("CREATE DATABASE test")

创建数据表

创建数据库之后，我们可以使用CREATE TABLE语句创建一个新的数据表。此语句定义了数据表的名称和每个列的名称和数据类型。在这里，我们将创建一个名为“customers”的数据表，其中包括名为“id”、“name”和“address”的三个列。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

mycursor = mydb.cursor()

mycursor.execute("CREATE TABLE customers (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), address VARCHAR(255))")

插入数据

在创建了数据表之后，我们可以使用INSERT INTO语句将数据插入数据表。INSERT INTO语句定义了要插入的数据表的名称和每个要插入的列，然后使用VALUES子句指定要插入的真实值。在这里，我们将向“customers”数据表插入三个记录，每个记录包括一个名为“name”的值和一个名为“address”的值。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

mycursor = mydb.cursor()

sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John Smith", "123 Main St")

mycursor.execute(sql, val)

mydb.commit()

print(mycursor.rowcount, "个记录插入成功。")

我们还可以使用executemany()方法在一次执行中插入多条记录。将要插入的记录作为元组列表传递给执行方法。在这里，我们将向“customers”数据表插入三个记录。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

mycursor = mydb.cursor()

sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = [
  ('Peter Parker', '10034 Queens Blvd'),
  ('Tony Stark', '10880 Malibu Point'),
  ('Bruce Wayne', '1007 Mountain Drive')
]

mycursor.executemany(sql, val)

mydb.commit()

print(mycursor.rowcount, "个记录插入成功。")

读取数据

在将数据插入数据表之后，我们可以使用SELECT语句从数据表中检索数据。首先，我们需要使用mysql.connector.cursor对象创建一个游标对象，并使用SELECT语句检索要返回的数据表中的列。在这里，我们将检索“customers”数据表中的所有列。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM customers")

myresult = mycursor.fetchall()

for x in myresult:
  print(x)

删除数据

我们可以使用DELETE语句从数据表中删除数据。使用WHERE子句指定要删除的记录，并使用mysql.connector.cursor对象执行DELETE语句。在这里，我们将删除“customers”数据表中名为“John Smith”的记录。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

mycursor = mydb.cursor()

sql = "DELETE FROM customers WHERE name = 'John Smith'"

mycursor.execute(sql)

mydb.commit()

print(mycursor.rowcount, "条记录删除成功。")

更新数据

在数据表中，我们可以使用UPDATE语句更改现有记录的值。使用SET子句指定要更改的列，以及将要更改的新值，并使用WHERE子句指定要更改的记录。在这里，我们将更新“customers”数据表中名为“Tony Stark”的地址。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

mycursor = mydb.cursor()

sql = "UPDATE customers SET address = '1503 Cottontail Ln' WHERE name = 'Tony Stark'"

mycursor.execute(sql)

mydb.commit()

print(mycursor.rowcount, "条记录更新成功。")

关闭连接

最后，当我们完成使用MySQL数据库时，我们需要使用mysql.connector.connection对象的close()方法关闭连接。在这里，我们将使用close()方法关闭对“test”数据库的连接。

import mysql.connector

mydb = mysql.connector.connect(
  host="localhost",
  port="3306",
  user="root",
  password="password",
  database="test"
)

# 执行操作...

mydb.close()

总结

在本文中，我们学习了如何使用Python的mysql Connector模块将数据插入MySQL数据库中。我们了解了如何连接到MySQL数据库，创建数据库和数据表，向数据表中插入数据，读取数据，删除数据以及更新数据。mysql Connector是Python应用开发中常用的工具之一，希望本文对您学习mysql Connector的使用有所帮助。