python mysqldb_python学习-使用MySQLdb操作mysql数据库
操作环境为python2.7 centos7
一、MySQLdb的安装与配置
MySQLdb是用于Python连接mysql数据库的接口,它实现了Python数据库api规范2.0。
按照以下方式安装yum install epel-release
yum install python-pip
yum install python-devel
yum install mysql-devel
pip install MySQL-python
安装完模块后,使用时导入模块名即可import MySQLdb
二、数据库准备
创建一个数据库为了准备研究使用
1、创建数据库TESTDB
2、在TESTDB数据库中创建表EMPLOYEE
3、EMPLOYEE表字段为ID,FIRST_NAME,LAST_NAME,AGE,SEX
4、连接数据TESTDB使用用用户名为"testuser",密码“test123"
创建完数据表配置命令如下ctreate database TESTDB charset utf8;
use TESTDB;
create table EMPLOYEE(
ID int primary key auto_increment,
FIRST_NAME varchar(10) not null,
LAST_NAME varchar(10) not null,
AGE int not null,
SEX varchar(10) not null
);
desc EMPLOYEE;
创建数据库用户create user 'testuser'@'localhost' identified by 'test123';#创建用户
grant all privileges on TESTDB.* to 'testuser'@'%' identified by 'test123' with grant option;#指定用户testuser可以从任何位置访问TESTDB数据下的任何表,拥有全部权限
flush privileges;
revoke drop on *.* from 'testuser'@'%'; #移除用户testuser从任何位置删除权限
flush privileges;
验证是否能偶远程登陆
至此,数据库准备完毕
三、MySQLdb基本方法
3.1connect函数
host:数据库服务的地址,默认通过UNINX socket访问本地数据库;
user:登陆数据库的用户名
passwd 登陆数据的密码
db 创建数据库连接以后选择的数据库
port 连接数据库连接的端口号 ,默认3306
unix_socket:UNIX socket的路径
connect_timeout:连接超时时间
read_default_file 读取Mysql的配置文件中的配置进行连接
3.2Conection类的成员
通过正确的参数调用MySQLdb的connect函数,将会返回Connection类的对象。常用方法如下:
begin:开始事务
commit:提交事务
rollback:回滚事务
cursor:返回一个cursor对象
autocommint:设置事务是否自动提交
set_character_set:设置字符集编码;
get_server_info:获取数据库版本信息
3.3cusor类成员
cursor对象表示数据库游标,用于执行sql语句并获取sql语句的执行结果。常用方法如下
execute:执行语句
close 关闭游标
fetchall:获取sql语句的所有记录
fetchmany :获取sql语句的多条记录
fetchone:获取sql语句的一条记录
owncount:常量,表示sql语句的结果集中返回了多少条记录
arraysize:变量,保存了当前获取记录的下标
四、连接数据库基本操作
4.1数据库连接import MySQLdb
# 打开数据库连接
db = MySQLdb.connect('localhost','testuser','test123','TESTDB',charset='utf8')
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 使用execute方法执行SQL语句
cursor.execute('SELECT VERSION()')
# 使用 fetchone() 方法获取一条数据
data = cursor.fetchone()
print "Database version : %s " % data
# 关闭数据库连接db.close()
db.close()
执行完以上语句后,输出结果如下
4.2创建数据库表EMPLOYEE_1
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 如果数据表已经存在使用 execute() 方法删除表。
#cursor.execute("DROP TABLE IF EXISTS EMPLOYEE_1")
# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE_1 (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
# 关闭数据库连接
db.close()
此时查看表已经被创建
4.3数据库插入操作
以下为使用sql insert语句向表EMPLOYEE_1插入记录:
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = "INSERT INTO EMPLOYEE_1(FIRST_NAME, \
LAST_NAME, AGE, SEX, INCOME) \
VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
('Mac', 'Mohan', 20, 'M', 2000)
try:
# 执行sql语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
except:
# 发生错误时回滚
db.rollback()
# 关闭数据库连接
db.close()
可以看到,数据已经插入了
4.4执行事务
事务机制可以确保数据一致性。
事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。原子性(atomicity)。一个事务是一个不可分割的工作单位,事务中包括的诸操作要么都做,要么都不做。
一致性(consistency)。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
隔离性(isolation)。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰。
持久性(durability)。持续性也称永久性(permanence),指一个事务一旦提交,它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。
Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:
# 执行SQL语句
cursor.execute(sql)
# 向数据库提交
db.commit()
except:
# 发生错误时回滚
db.rollback()
4.5数据库查询操作
Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall():接收全部的返回结果行.
rowcount: 这是一个只读属性,并返回执行execute()方法后影响的行数。#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE_1 \
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 fecth data"
# 关闭数据库连接
db.close()
查询EMPLOYEE_1表中salary(工资)字段大于1000的所有数据:
4.5数据库更新操作
新操作用于更新数据表的的数据,以下实例将 EMPLOYEE_1 表中的 SEX 字段为 'M' 的 AGE 字段递增 1:#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
# 执行SQL语句
cursor.execute(sql)
# 提交到数据库执行
db.commit()
except:
# 发生错误时回滚
db.rollback()
# 关闭数据库连接
db.close()
六、错误处理
以下为常见异常及解释
python mysqldb_python学习-使用MySQLdb操作mysql数据库相关推荐
- Python 使用MySQLdb操作 MySQL数据库
引言:本文主要介绍通过MySQLdb实现Python对MySQL数据库的访问和操作. 一.MySQLdb安装: windows下直接下载 MySQL-python-1.2.4b4.win32-py ...
- python连接数据库的技术_Python操作MySQL数据库的三种方法
(1) 什么是MySQLdb? MySQLdb 是用于 Python 连接 MySQL 数据库的接口,它实现了 Python 数据库 API 规范 V2.0,基于 MySQL C API 上建立的. ...
- python使用pymysql包,操作mysql数据库,包括安装及使用(附代码)
(本文书写的初衷,大家想简单是使用数据库,而不想深入了解时,可以直接使用) 1.安装 # Ubuntu20以上版本适用# 安装python包pip install pymysql# 安装数据库sudo ...
- 老鱼Python数据分析——篇三:操作MySQL数据库
Python操作数据库非常的方便. 不同的数据库你需要下载不同的DB API模块,例如你需要访问Oracle数据库和Mysql数据,你需要下载Oracle和MySQL数据库模块. DB-API 是一个 ...
- 1899-11-30 php mysql_PHP学习十一--PHP操作MYSQL数据库
1.PHP访问Mysql数据库的一般步骤 连接MySQL服务器 选择MySQL数据库 请求 执行SQL语句 请求 MySQL数 ...
- jmeter+mysql+set_jmeter学习指南之操作 mysql 数据库
JMeter 通过 JDBC Connection Configuration 和 JDBC Request 可以连接数据库,并进行增删改查操作,支持各种常见的数据库,本文以最常用的 MySQL 数据 ...
- MySQLdb操作mysql数据库的两个细节
2019独角兽企业重金招聘Python工程师标准>>> 一.安装 下载最新的mysqlclient-1.3.10.tar.gz解压后: 如果是apt方式安装mysql(甚至不需下载源 ...
- Go语言学习笔记—golang操作MySQL数据库
文章目录 一 准备数据库和表 二 安装配置mysql驱动 三 获得数据库连接 3.1 导入包 3.2 获得连接 3.3 初始化连接 四 插入数据 五 查询数据 5.1 单行查询 5.2 多行查询 六 ...
- 递归、os.walk、内置函数、lambda、hashlib模块、md5加密、python安装第三方模块、操作mysql数据库...
#递归就是函数自己调自己,一般递归都会有在什么情况下结束递归,一业可以有结束条件#递归最多死循环999次,递归不能设定次数# count=0# def abc():# global count# co ...
最新文章
- 不快乐工作场所的生存法则
- [2018/11/14]思考
- 基于 abp vNext 和 .NET Core 开发博客项目 - 统一规范API,包装返回模型
- 安卓布局工具---Hierarchy Viewer
- wxWidgets:wxDataObjectComposite类用法
- (网页)Uncaught ReferenceError: pageImport is not defined
- 螺旋矩阵 IIPython解法
- mysql延迟关联为什么快_MySQL 覆盖索引与延迟关联详解
- 子进程 已安装 post-installation 脚本 返回错误状态 1 dpkg: 依赖关系问题使得 mysql-server 的配置工作不能继续: mysql-server 依赖于 mysq
- android界面设计字体大小,Andoird用户界面设计上手指南:设置字体大小
- 联发科技嵌入式_【MTK联发科技嵌入式面试】联发科技校招最新面试经验-看准网...
- (5)vivado不能生成bit文件(学无止境)
- 二级 办公软件高级应用技术_塔河县(局)工会举办电脑办公应用技术培训班...
- 模型预测控制的缺点_模型预测控制(MPC)与最优控制的理论分析 | NeurIPS 2020
- bat windows10系统垃圾清理---
- GIMP制作电子签名
- 名字作诗,拯救诗歌的最后一根稻草
- 今天七夕给大家送个“对象”吧!拿走不谢!
- 硬盘柱面损坏怎么办_电脑硬盘坏了怎么办?不花一分钱就能成功修复!
- LeanCloud 将加入心动/TapTap