在Python 3.6中,可以使用各种数据库驱动库来连接数据库。对于MySQL,可以使用mysqlconnectorpython
库;对于PostgreSQL,可以使用psycopg2
库;对于SQLite,可以使用内置的sqlite3
库。首先需要安装相应的库,然后使用库提供的API进行数据库连接和操作。
在现代软件开发中,数据库连接和操作是基本技能之一,本文将详细介绍使用 Python 3.6 连接和操作数据库的过程,Python 提供了多种方式来连接数据库,本文将重点介绍使用 PyMySQL 和 mysqlconnectorpython 驱动程序连接 MySQL 数据库的方法。
要使用 Python 连接数据库,首先需要安装适当的数据库驱动,对于 MySQL 数据库,常用的驱动有 PyMySQL 和 mysqlconnectorpython。
PyMySQL 是一个纯 Python 写的 MySQL 客户端,可以很好地与 Python 3.x 版本兼容,安装过程非常简单,可以通过 pip 工具来安装:
```bash
pip3 install PyMySQL
```
如果系统不支持 pip,可以从 GitHub 上克隆 PyMySQL 的源代码,然后进行安装:
```bash
git clone https://github.com/PyMySQL/PyMySQL
cd PyMySQL
python3 setup.py install
```
mysqlconnectorpython 是 MySQL 官方提供的驱动,同样支持 Python 3.x,安装命令如下:
```bash
pip install mysqlconnectorpython
```
如果遇到权限问题或指定安装目录的需求,可以参考官方文档调整安装命令。
安装完数据库驱动之后,接下来需要用 Python 代码连接到数据库,以下是使用 PyMySQL 和 mysqlconnector 连接本地 MySQL 数据库的示例:
```python
import pymysql
# 建立连接
connection = pymysql.connect(host='localhost',
user='testuser',
password='test123',
database='TESTDB',
charset='utf8mb4')
# 创建一个游标对象
cursor = connection.cursor()
```
```python
import mysql.connector
# 建立连接
connection = mysql.connector.connect(host='localhost',
user='testuser',
password='test123',
database='TESTDB')
# 创建一个游标对象
cursor = connection.cursor()
```
连接数据库后,通常需要进行创建表、插入数据、查询数据等操作,以下举例说明如何创建表和插入数据:
```python
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
sql_create_table = """
CREATE TABLE EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT
)
"""
cursor.execute(sql_create_table)
connection.close()
```
```python
sql_insert = "INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, INCOME) VALUES (%s, %s, %s, %s, %s)"
data = ('Mac', 'Mohan', 20, 'M', 2000)
cursor.execute(sql_insert, data)
connection.commit() # 提交事务
```
```python
cursor.execute("SELECT * FROM EMPLOYEE")
rows = cursor.fetchall()
for row in rows:
print(row)
```
```python
sql_update = "UPDATE EMPLOYEE SET INCOME = %s WHERE FIRST_NAME = %s"
update_data = (5000, 'Mac')
cursor.execute(sql_update, update_data)
connection.commit() # 提交事务
```
```python
sql_delete = "DELETE FROM EMPLOYEE WHERE FIRST_NAME = %s"
delete_data = ('Mac',)
cursor.execute(sql_delete, delete_data)
connection.commit() # 提交事务
```
```python
cursor.close()
connection.close()
```
在进行数据库操作时,异常处理和事务控制非常重要,能够保证数据的一致性和完整性,以下是一个包含异常处理的插入操作示例:
try: cursor.execute(sql_insert, data) connection.commit()except Exception as e: print("发生错误:", e) connection.rollback() # 回滚事务finally: cursor.close() connection.close()
通过上述步骤,你应该能够顺利地使用 Python 3.6 连接和操作 MySQL 数据库,下面归纳一下整个过程中的关键点和注意事项:
选择合适的数据库驱动:根据 Python 版本和数据库类型选择适当的驱动。
正确安装数据库驱动:使用 pip 工具或者源码安装,确保驱动与 Python 版本兼容。
安全连接信息:数据库连接信息应保密,避免硬编码在代码中。
异常处理:对数据库操作进行异常处理,确保程序健壮性。
事务控制:使用 commit() 和 rollback() 方法进行事务控制,保证数据一致性。
FAQs
A1: 这个错误通常表示用户名或密码错误,或者用户没有权限访问指定的数据库,你需要确认以下几点:
确保输入的用户名和密码正确无误。
确保该用户有权限访问该数据库,可以使用 GRANT 命令为用户授权。
如果问题依旧存在,尝试在数据库管理工具中直接连接,看是否能成功,这样可以排除是代码问题还是数据库配置问题。
A2: 这个错误可能由几个原因导致:
查询执行时间太长,导致连接超时,可以优化查询语句或增加连接超时时间。
网络不稳定导致连接中断,检查网络连接,确保网络稳定。
MySQL 服务未运行或崩溃,检查 MySQL 服务状态,并尝试重启服务。
谢谢观看,如果有任何问题或建议,请留言评论,也请关注我们的更多内容,点赞支持!