Python3和Python2连接MYSQL数据库稍微不同,我们这里要使用PyMySQL。
什么是 PyMySQL?
PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb。
PyMySQL 遵循 Python 数据库 API v2.0 规范,并包含了 pure-Python MySQL 客户端库。
PyMySQL 安装
在使用 PyMySQL 之前,我们需要确保 PyMySQL 已安装。
PyMySQL 下载地址:https://github.com/PyMySQL/PyMySQL。
如果还未安装,我们可以使用以下命令安装最新版的 PyMySQL
pip install PyMySQL (LINUX WINDOWS都可以用)
如果你不能使用pip,你可以使用以下的方式:(LINUX)
1、使用 git 命令下载安装包安装(你也可以手动下载):
2、如果需要制定版本号,可以使用 curl 命令来安装:
如果你在安装的过程中可能会出现"ImportError: No module named setuptools"的错误提示,意思是你没有安装setuptools,你可以访问https://pypi.python.org/pypi/setuptools 找到各个系统的安装方法。
数据库连接
连接数据库前,请先确认以下事项:
您已经创建了数据库 TESTDB.
在TESTDB数据库中您已经创建了表 TEST
EMPLOYEE表字段为 ID, NAME, AGE, SEX 和 S_LOCAL。
连接数据库TESTDB使用的用户名为 "root" ,密码为 "root",你也可以使用自己设定的用户名及其密码,Mysql数据库用户授权请使用Grant命令。
在你的计算机上已经安装了 Python MySQLdb 模块。
如果您对sql语句不熟悉,建议你还是先去看看数据库SQL基础教程吧!!!
我的数据库在LINUX的虚拟机上地址是192.168.115.128 端口是3306 版本是MYSQL-5.6.25-x86_64
数据库建库语句:
CREATE DATABASE TESTDB;
使用刚刚建立的数据库:
USE TESTDB;
建表语句:
CREATE TABLE TEST (ID INT,NAME VARCHAR(100),AGE INT,SEX CHAR(1),S_LOCAL VARCHAR(100)) CHARSET=UTF8;
查看一下表:
SHOW TABLES;
查看一下表结构:
DESC TEST;
编程实例:
查看数据库版本:
(均是在WINDOWS 7 PYCHARM 2018.2.2PRO版下开发)
以下实例链接 Mysql 的 TESTDB 数据库:
代码如下:
import pymysql
db = pymysql.connect("192.168.115.128", "root", "root", "TESTDB")
cursor = db.cursor()
cursor.execute("SELECT VERSION()")
data = cursor.fetchone()
print("Database version : %s " % data)
db.close()
执行程序:
结果出来了!!!
创建数据库表:
代码如下:
import pymysql
db = pymysql.connect("192.168.115.128", "root", "root", "TESTDB")
cursor = db.cursor()
cursor.execute("DROP TABLE IF EXISTS TEST2")
sql = """CREATE TABLE TEST2 (
ID INT ,
NAME VARCHAR(20),
AGE INT,
SEX CHAR(1),
S_LOCAL VARCHAR(100))"""
cursor.execute(sql)
db.close()
数据库里查看结果,看是否表建立成功:
查看表结构:
看我们又成功了!!!
数据库插入操作
代码如下:
import pymysql
db = pymysql.connect("192.168.115.128", "root", "root", "TESTDB")
cursor = db.cursor()
sql = """INSERT INTO TEST(ID,
NAME, AGE, SEX, S_LOCAL)
VALUES (1, '张三丰', 100, 'M', '武当山')"""
try:
# 执行sql语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
except:
# 如果发生错误则回滚
db.rollback()
db.close()
查看结果:
数据库查询操作
Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall(): 接收全部的返回结果行.
rowcount: 这是一个只读属性,并返回执行execute()方法后影响的行数
代码如下:
import pymysql
db = pymysql.connect("192.168.115.128", "root", "root", "TESTDB")
cursor = db.cursor()
sql = "SELECT * FROM TEST"
try:
# 执行SQL语句
cursor.execute(sql)
# 获取所有记录列表
results = cursor.fetchall()
for row in results:
ID = row[0]
NAME = row[1]
AGE = row[2]
SEX = row[3]
S_LOCAL = row[4]
# 打印结果
print("ID=%s,NAME=%s,AGE=%s,SEX=%s,S_LOCAL=%s" % (ID, NAME, AGE, SEX, S_LOCAL))
except:
print("Error: unable to fetch data")
db.close()
查看结果:
又成功了!
执行事务
事务机制可以确保数据一致性。
事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。
原子性(atomicity)。一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。
一致性(consistency)。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
隔离性(isolation)。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
持久性(durability)。持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。
Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。
上面的INSERT语句中已经包含了事务处理方式,请大家查看插入操作的源代码!!!
思考题!因为UPDATE和DELETE与INSERT同属DML操作,请根据INSERT语句示例自己尝试编写一下UPDATE和DELETE语句,语法不会请参考数据库SQL标准教程。
错误处理
DB API中定义了一些数据库操作的错误及异常,下表列出了这些错误和异常:
以上就是Python和MySQL数据库连接的基本操作,希望大家喜欢。
如果觉得我的文章对您有用,请点赞。您的支持将鼓励我继续创作!
赞3
添加新评论2 条评论
2019-04-23 14:18
2019-04-22 19:07