Python操作MySQL数据库的必备模块mysqlpython（mysql_python）

Python操作MySQL数据库的必备模块——mysql_python

在Python中使用MySQL数据库是一项必备的技能，而mysql_python就是我们在Python中操作MySQL的必备模块之一。mysql_python模块可以通过Python的pip安装，直接使用import语句导入模块即可。在本文中，我们将介绍一些基本的mysql_python模块的使用方法，并提供一些示例代码来帮助读者更好地了解mysql_python模块的使用。

1. 连接MySQL

在使用mysql_python模块之前，我们需要先连接MySQL。要连接MySQL，我们需要提供MySQL服务器的名称，用户名和密码。以下是用mysql_python连接MySQL的示例代码：

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")
# 使用fetchone()方法获取数据
data = cursor.fetchone()
print("Database version : %s " % data)

# 关闭数据库
db.close()

上面的代码中，我们使用MySQLdb.connect()方法连接了MySQL。此方法获取四个参数：主机名、用户名、密码和数据库名称。打开连接后，我们使用cursor()方法获取一个游标。游标是用于操作数据库的对象。我们通过执行SQL语句并使用fetchone()方法获取结果。

2. 创建表

创建表是操作MySQL的常见任务之一。以下是创建表的示例代码：

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 如果存在表就删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 创建新的表
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()

在上面的代码中，我们使用DROP TABLE语句删除了EMPLOYEE表（如果它存在的话），然后使用CREATE TABLE语句创建了一个新的EMPLOYEE表。

3. 插入数据

接下来，我们将演示如何向EMPLOYEE表中添加数据。以下是向表中添加数据的示例代码：

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 提交修改
    db.commit()
except:
    # 发生错误时回滚
    db.rollback()
# 关闭数据库连接
db.close()

上面的代码中，我们创建了一条INSERT语句并使用execute()方法执行该语句。如果执行成功，我们使用commit()方法将更改提交到数据库。如果发生错误，则使用rollback()方法将更改回滚。

4. 查询数据

接下来，让我们来看一下如何从EMPLOYEE表中查询数据。以下是查询EMPLOYEE表中数据的示例代码：

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > '%d'" % (1000)
try:
    # 执行SQL语句
    cursor.execute(sql)
    # 获取所有记录列表
    results = cursor.fetchall()
    for row in results:
        fname = row[0]
        lname = row[1]
        age = row[2]
        sex = row[3]
        income = row[4]
        # 打印结果
        print("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
                (fname, lname, age, sex, income ))
except:
    print("Error: unable to fetch data")

# 关闭数据库连接
db.close()

在上面的代码中，我们使用execute()方法执行SELECT语句，并使用fetchall()方法获取所有记录。这些记录将存在一个元组的列表中。然后，我们对列表进行迭代并使用正确的列名称获取每条记录的列值。

总结：

mysql_python模块是Python操作MySQL数据库的必备模块之一。在本文中，我们介绍了如何使用mysql_python连接MySQL、创建表、插入数据和查询数据。mysql_python提供了许多方法和功能，大大简化了在Python中操作MySQL的过程。若有更复杂的操作需求，还是需要熟练掌握SQL语言来完成相应的操作。