python调用mysql数据库

时间: 2024-06-17 10:05:35 浏览: 157

PDF

python操作mysql数据库

Python操作MySQL数据库是一种常见的任务，尤其在Web开发和数据分析中。Python提供了多种库来与MySQL交互，其中最常用的是PyMySQL，因为Python 3已经不支持原来的mysqldb模块。我们来看一下如何在MySQL中进行基本的操作。创建一个支持中文字符集的数据库可以使用如下命令： ```sql CREATE DATABASE zcl CHARSET utf8; ``` 查看表结构可以使用`DESCRIBE`命令，例如： ```sql DESC students; ``` 显示创建表的SQL语句： ```sql SHOW CREATE TABLE students; ``` 删除数据库： ```sql DROP DATABASE zcl; ``` 添加新的字段： ```sql ALTER TABLE students ADD COLUMN nal CHAR(64); ``` 接下来，我们将重点讨论Python连接和操作MySQL数据库。在Python中，我们使用PyMySQL库。需要通过pip安装PyMySQL： ``` pip3 install pymysql ``` 之后，可以使用以下代码建立数据库连接并插入数据： ```python import pymysql # 建立连接 conn = pymysql.connect(host='127.0.0.1', user='root', passwd='root', db='zcl') # 创建游标 cur = conn.cursor() # 插入数据 reCount = cur.execute('INSERT INTO students(name, sex, age, tel, nal) VALUES (%s, %s, %s, %s, %s)', ('Jack', 'man', 25, 1351234, "CN")) reCount = cur.execute('INSERT INTO students(name, sex, age, tel, nal) VALUES (%s, %s, %s, %s, %s)', ('Mary', 'female', 18, 1341234, "USA")) # 提交事务 conn.commit() # 关闭游标和连接 cur.close() conn.close() # 输出插入记录数 print(reCount) ``` 获取数据同样简单，可以通过游标的方法`fetchone()`, `fetchmany(size)`, 和 `fetchall()`： ```python # 获取数据 cur = conn.cursor() reCount = cur.execute('SELECT * FROM students') # 获取一条数据 res = cur.fetchone() # 获取3条数据 res2 = cur.fetchmany(3) # 获取所有数据 res3 = cur.fetchall() # 输出结果 print(res) print(res2) print(res3) # 提交事务 conn.commit() # 关闭游标和连接 cur.close() conn.close() ``` 在处理事务时，如果在数据提交前发生错误，可以通过调用`conn.rollback()`来撤销事务。需要注意的是，一旦数据被提交，就不能再进行回滚。例如： ```python # 插入数据并回滚 try: cur.execute('INSERT INTO students...') conn.commit() except Exception as e: print(f"Error occurred: {e}") conn.rollback() ``` 以上就是Python使用PyMySQL库操作MySQL数据库的基本步骤和常见操作。在实际应用中，可能还需要处理更多复杂情况，如错误处理、连接池管理等，但这些基础操作为理解Python与MySQL的交互奠定了基础。

在Python中，可以使用MySQL官方提供的Python驱动程序——mysql-connector-python来连接MySQL数据库。具体步骤如下： 1. 安装mysql-connector-python：可以通过pip命令进行安装，命令如下： ``` pip install mysql-connector-python ``` 2. 连接MySQL数据库：可以使用connect()函数来连接MySQL数据库，代码如下： ```python import mysql.connector mydb = mysql.connector.connect( host="localhost", user="yourusername", password="yourpassword", database="mydatabase" ) print(mydb) ``` 3. 执行SQL语句：可以使用cursor()方法来获取操作游标，然后使用execute()方法来执行SQL语句，代码如下： ```python mycursor = mydb.cursor() mycursor.execute("SELECT * FROM customers") myresult = mycursor.fetchall() for x in myresult: print(x) ``` 4. 关闭数据库连接：使用close()方法关闭数据库连接，代码如下： ```python mydb.close() ```

阅读全文

相关推荐

CSDN会员

开通CSDN年卡参与万元壕礼抽奖

海量 VIP免费资源千本正版电子书商城会员专享价千门课程&专栏

全年可省5,000元立即开通