Python写入MySQL数据库的三种方式详解

Python是一种广泛应用的语言，常用于数据分析和处理，而MySQL是一种成熟、稳定、高效的关系型数据库，Python与MySQL结合使用，可以实现完整的数据处理流程。在本文中，我们将详细讲解Python写入MySQL数据库的三种方式。

1. 使用Python MySQL Connector库

通过Python MySQL Connector库可以实现Python与MySQL数据库的连接，并对数据库进行增、删、改、查 等操作。

以下是Python写入MySQL数据库的示例代码：

import mysql.connector

# 连接数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="root",
  password="123456",
  database="mydatabase"
)

# 新建游标
mycursor = mydb.cursor()

# 执行SQL语句
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)

# 提交到数据库
mydb.commit()

# 输出插入数据的行数
print(mycursor.rowcount, "record inserted.")

在上述代码中，我们首先通过MySQL Connector库连接数据库，然后新建游标，执行INSERT语句，并将数据提交到数据库。在每次执行数据库操作时，都需要先进行连接，创建游标，并在完成使用后关闭连接。

2. 使用pymysql库

pymysql是python的一个用于连接MySQL数据库的第三方库，与mysql-connector-python库类似，它也能够实现Python连接MySQL数据库并对数据库进行增、删、改、查等操作。

以下是Python写入MySQL数据库的示例代码：

import pymysql

# 连接数据库
mydb = pymysql.connect(
  host="localhost",
  user="root",
  password="123456",
  database="mydatabase"
)

# 新建游标
mycursor = mydb.cursor()

# 执行SQL语句
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
val = ("John", "Highway 21")
mycursor.execute(sql, val)

# 提交到数据库
mydb.commit()

# 输出插入数据的行数
print(mycursor.rowcount, "record inserted.")

在上述代码中，我们首先通过pymysql库连接数据库，在完成增、删、改、查操作后，同样需要对连接关闭。

3. 使用SQLAlchemy库

SQLAlchemy是Python的一个最流行的ORM(Object-Relational Mapping)库，可以将Python中的对象映射到数据库中的记录，并且能够自动生成SQL语句。

以下是Python写入MySQL数据库的示例代码：

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

# 连接数据库
engine = create_engine('mysql+pymysql://root:123456@localhost/mydatabase')
Base = declarative_base()

# 创建数据表类
class Customer(Base):
    __tablename__ = 'customers'
    id = Column(Integer, primary_key=True)
    name = Column(String(50))
    address = Column(String(50))

# 创建Session
Session = sessionmaker(bind=engine)
session = Session()

# 插入数据
customer = Customer(name='John', address='Highway 21')
session.add(customer)
session.commit()

# 输出插入数据的id
print('customer id:', customer.id)

在上述代码中，我们首先使用SQLAlchemy中的create_engine()方法连接数据库，然后使用declarative_base()方法基于声明式创建数据表类，并使用sessionmaker()方法创建Session，再执行插入数据操作，并提交数据。最后输出插入数据的id。

通过以上三种方式，我们可以轻松实现Python写入MySQL数据库的功能，具体实现方式根据实际需求选择即可。