【独家】MySQL与Python的集成教程(二）

　　四、Python操作MySQL数据库

　　在Python中操作MySQL数据库，我们需要用到MySQL Connector/Python，这是MySQL官方提供的Python连接接口。以下将介绍如何使用Python连接MySQL数据库，以及如何进行基本的增、删、改、查操作。

　　1.连接MySQL数据库

　　首先，需要确保已经正确安装了MySQL Connector/Python。安装地址：http://dev.mysql.com/downloads/connector/python/

　　安装完成后，可以通过以下代码测试连接：

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1', database='your_database')

　　cnx.close()

　　```

　　2.创建数据库

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1')

　　cursor = cnx.cursor()

　　query = "CREATE DATABASE IF NOT EXISTS my_database"

　　cursor.execute(query)

　　cnx.commit()

　　cursor.close()

　　cnx.close()

　　```

　　3.删除数据库

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1')

　　cursor = cnx.cursor()

　　query = "DROP DATABASE IF EXISTS my_database"

　　cursor.execute(query)

　　cnx.commit()

　　cursor.close()

　　cnx.close()

　　```

　　4.创建表

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1', database='my_database')

　　cursor = cnx.cursor()

　　query = "CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(50), age INT)"

　　cursor.execute(query)

　　cnx.commit()

　　cursor.close()

　　cnx.close()

　　```

　　5.插入数据

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1', database='my_database')

　　cursor = cnx.cursor()

　　query = "INSERT INTO users (name, age) VALUES (%s, %s)"

　　val = ('Alice',25)

　　cursor.execute(query, val)

　　cnx.commit()

　　cursor.close()

　　cnx.close()

　　```

　　6.查询数据

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1', database='my_database')

　　cursor = cnx.cursor()

　　query = "SELECT * FROM users"

　　cursor.execute(query)

　　rows = cursor.fetchall()

　　for row in rows：

　　print(row)

　　cursor.close()

　　cnx.close()

　　```

　　7.更新数据

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user='your_username', password='your_password', host='127.0.0.1', database='my_database')

　　cursor = cnx.cursor()

　　query = "UPDATE users SET age = %s WHERE id = %s"

　　val = (26,1)

　　cursor.execute(query, val)

　　cnx.commit()

　　cursor.close()

　　cnx.close()

　　```

　　8.删除数据

　　```python

　　import mysql.connector

　　cnx = mysql.connector.connect(user

（编辑：南京站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!