python中mysqldb模块_python中MySQLdb模块用法实例

本文实例讲述了python中MySQLdb模块用法。分享给大家供大家参考。具体用法分析如下:

MySQLdb其实有点像php或asp中连接数据库的一个模式了,只是MySQLdb是针对mysql连接了接口,我们可以在python中连接MySQLdb来实现数据的各种操作。

python连接mysql的方案有oursql、PyMySQL、 myconnpy、MySQL Connector 等,不过本篇要说的确是另外一个类库MySQLdb,MySQLdb 是用于Python链接Mysql数据库的接口,它实现了 Python 数据库 API 规范 V2.0,基于 MySQL C API 上建立的。可以从:https://pypi.python.org/pypi/MySQL-python 进行获取和安装,而且很多发行版的linux源里都有该模块,可以直接通过源安装。

一、数据库连接

MySQLdb提供了connect方法用来和数据库建立连接,接收数个参数,返回连接对象:

复制代码 代码如下:

conn=MySQLdb.connect(host="localhost",user="root",passwd="jb51",db="test",charset="utf8")

比较常用的参数包括:

host:数据库主机名.默认是用本地主机

user:数据库登陆名.默认是当前用户

passwd:数据库登陆的秘密.默认为空

db:要使用的数据库名.没有默认值

port:MySQL服务使用的TCP端口.默认是3306

charset:数据库编码

更多关于参数的信息可以查这里 http://mysql-python.sourceforge.net/MySQLdb.html

然后,这个连接对象也提供了对事务操作的支持,标准的方法:

commit() 提交

rollback() 回滚

看一个简单的查询示例如下:

复制代码 代码如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打开数据库连接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# 使用execute方法执行SQL语句

cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取一条数据库。

data = cursor.fetchone()

print "Database version : %s " % data

# 关闭数据库连接

db.close()

脚本执行结果如下:

Database version : 5.5.40

二、cursor方法执行与返回值

cursor方法提供两类操作:1.执行命令,2.接收返回值 。

cursor用来执行命令的方法

复制代码 代码如下:

//用来执行存储过程,接收的参数为存储过程名和参数列表,返回值为受影响的行数

callproc(self, procname, args)

//执行单条sql语句,接收的参数为sql语句本身和使用的参数列表,返回值为受影响的行数

execute(self, query, args)

//执行单挑sql语句,但是重复执行参数列表里的参数,返回值为受影响的行数

executemany(self, query, args)

//移动到下一个结果集

nextset(self)

cursor用来接收返回值的方法

//接收全部的返回结果行.

fetchall(self)

//接收size条返回结果行.如果size的值大于返回的结果行的数量,则会返回cursor.arraysize条数据

fetchmany(self, size=None)

//返回一条结果行

fetchone(self)

//移动指针到某一行.如果mode='relative',则表示从当前所在行移动value条,如果mode='absolute',则表示从结果集的第一行移动value条

scroll(self, value, mode='relative')

//这是一个只读属性,并返回执行execute()方法后影响的行数

rowcount

三、数据库操作

1、创建database tables

如果数据库连接存在我们可以使用execute()方法来为数据库创建表,如下所示创建表EMPLOYEE:

复制代码 代码如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打开数据库连接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# 如果数据表已经存在使用 execute() 方法删除表。

cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 创建数据表SQL语句

sql = """CREATE TABLE EMPLOYEE (

FIRST_NAME  CHAR(20) NOT NULL,

LAST_NAME  CHAR(20),

AGE INT,

SEX CHAR(1),

INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接

db.close()

2、数据库插入操作

复制代码 代码如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打开数据库连接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 插入语句

sql = """INSERT INTO EMPLOYEE(FIRST_NAME,

LAST_NAME, AGE, SEX, INCOME)

VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""

try:

# 执行sql语句

cursor.execute(sql)

# 提交到数据库执行

db.commit()

except:

# Rollback in case there is any error

db.rollback()

# 关闭数据库连接

db.close()

这里是一个单sql 执行的示例,cursor.executemany的用法感兴趣的读者可以参看相关的aws主机资产管理系统示例。

上例也可以写成通过占位符传参的方式进行执行,如下:

复制代码 代码如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打开数据库连接

db = MySQLdb.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 插入语句

sql = "INSERT INTO EMPLOYEE(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()

也可以以变量的方式传递参数,如下:

复制代码 代码如下:

..................................

user_id = "test"

password = "password123"

con.execute('insert into Login values("%s", "%s")' % \

(user_id, password))

..................................

3、数据库查询操作

以查询EMPLOYEE表中salary(工资)字段大于1000的所有数据为例:

复制代码 代码如下:

#!/usr/bin/python

# encoding: utf-8

import MySQLdb

# 打开数据库连接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用cursor()方法获取操作游标

cursor = db.cursor()

# SQL 查询语句

sql = "SELECT * FROM EMPLOYEE \

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()

以上脚本执行结果如下:

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

4、数据库更新操作

更新操作用于更新数据表的的数据,以下实例将 test表中的 SEX 字段全部修改为 'M',AGE 字段递增1:

复制代码 代码如下:

# encoding: utf-8

#!/usr/bin/python

import MySQLdb

# 打开数据库连接

db = MySQLdb.connect("localhost","root","361way","test" )

# 使用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()

5、执行事务

事务机制可以确保数据一致性。事务应该具有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()

对于支持事务的数据库, 在Python数据库编程中,当游标建立之时,就自动开始了一个隐形的数据库事务。commit()方法游标的所有更新操作,rollback()方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

希望本文所述对大家的Python程序设计有所帮助。

本文标题: python中MySQLdb模块用法实例

本文地址: http://www.cppcns.com/shujuku/mysql/115899.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/490367.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

g++编译多个文件

假设现在有一个add.cpp,add.h,main.cpp这三个文件,文件内容如下: add.cpp: add.h: main.cpp: 我需要将add.cpp和main.cpp这两个文件进行编译,有以下两种方法: g -c add.cpp g -c main.cpp g main.o add.o -o test ./test 第二种…

【数字孪生】工业互联网和数字孪生

来源:产业智能官《崛起的超级智能》一书主要阐述当今天人类为人工智能的春天到来而兴奋,为人工智能是否超越人类而恐慌的时候,一个更为庞大、远超人类预期的智能形态正在崛起,种种迹象表明50年来,互联网正在从网状结构…

javascript数组扁平化处理

最近看jQuery源码$.map方法的实现,返回值利用了一个扁平化处理 return ret.concat.apply( [], ret ) 这有个疑问,不知道为什么不直接返回ret 根据这个返回值处理,推测ret可能不是一阶数组,例如[1,2,[3,4]]这样的; var ret [1,2,[…

k折交叉验证法python实现_Jason Brownlee专栏| 如何解决不平衡分类的k折交叉验证-不平衡分类系列教程(十)...

作者:Jason Brownlee编译:Florence Wong – AICUG本文系AICUG翻译原创,如需转载请联系(微信号:834436689)以获得授权在对不可见示例进行预测时,模型评估涉及使用可用的数据集来拟合模型,并评估其表现性能。…

linux的find命令满屏权限不够提示

用find命令是如果是普通用户通常会输出一堆“权限不够”的提示,这会影响到我们找出有用的信息,为了将这些错误忽略,可以采用重定向: find / -name add.h 2> /dev/null

AI“换脸”打开潘多拉魔盒,如何应对?

来源:科学网近日,一款名为“ZAO”的换脸APP引发舆论关注。用户上传照片,就可以把影视剧主角的脸替换成用户自己的脸。在过把“明星瘾”的同时,也让大众关注到“换脸”带来的个人信息泄露风险。信息时代,“脸面”不仅仅…

stm32超声波测距代码_超声波模块另类用法,悬浮,你也能做到

今天,给大家介绍一个「超酷的DIY声波悬浮」研究项目。虽然超声波悬浮,不能像磁悬浮那样悬浮比较重的物品。不过能把小泡沫球、水滴或者蚂蚁这样的小物体悬浮起来也是很有意思的。制作这样一个简易的超声波悬浮器并不需要多少成本,而且材料很容…

vim:去掉响铃

vim在移动字符出界&#xff08;上下左右&#xff09;包括按<ESC>建都会响铃&#xff0c;有时候真的很烦。 在网上搜了一下&#xff0c;原来是visualbell来控制的&#xff0c;在vim里使用命令:help visualbell&#xff0c;原来禁止命令是:novb 好了&#xff0c;在.vimrc文…

【AI战略】2019年美国国家人工智能战略报告(中文翻译版)

来源&#xff1a;AI城市智库人工智能(AI)拥有巨大的希望&#xff0c;几乎可以使社会的各个方面受益&#xff0c;包括经济&#xff0c;医疗保健&#xff0c; 安全&#xff0c;法律&#xff0c;运输&#xff0c;甚至技术本身。2019年2月11日&#xff0c;总统签署了行政命令13859…

函数对象

若一个类重载了运算符“&#xff08;&#xff09;”&#xff0c;则该类的对象就成为函数对象。函数对象可以用于标准库算法。函数对象和函数指针很相似&#xff0c;但也有区别。当函数对象使用模板时可以赋值给函数指针。 #include <iostream #include <vector> #incl…

linux vim下删除一行和多行

删除一行&#xff1a; 在命令模式下将光标移至要删除的行位置&#xff0c;按下dd 删除n行&#xff1a; 假设要删除5行&#xff0c;在命令模式下将光标移至要删除的行的开始位置&#xff0c;按下5dd

python如何查看有什么模块_在python中如何查看模块功能

在python中查看模块功能的方法&#xff1a;1、在python命令行输入help()函数进入help帮助文档界面&#xff1b;2、键入【modules】列出当前所有安装的模块&#xff1b;3、键入相应的模块名称即可得到该模块的功能信息。python的一个优势是有着大量自带和在线的模块(module)资源…

拍下首张黑洞照片的团队获300万美元奖金:2020年科学突破奖揭晓

来源&#xff1a;科学突破奖科学突破奖2019 年 9 月 5 日&#xff0c;2020 年度突破奖&#xff08;Breakthrough Prize&#xff09;揭晓。突破奖&#xff0c;又被誉为“科学界的奥斯卡”&#xff0c;现已经入第八个年头。突破奖每年都会表彰在生命科学&#xff0c;基础物理学和…

linux vim复制和粘贴

复制&#xff1a; 在命令行模式下将光标移至要复制的行&#xff0c;按下yy即可复制该行&#xff0c;如果要复制5行&#xff0c;按下5yy即可复制从光标这行开始的5行 粘贴&#xff1a; 在命令行模式下将光标移至粘贴处&#xff0c;按下p

C#获取ip的示例

界面 using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Text;using System.Windows.Forms; namespace TestIP{ public partial class Form1 : Form { public Form1() { InitializeComponent()…

硬盘序列号查询软件_【西数硬盘购买指南】干货——西数移动硬从购买到验证体会心得...

玩摄影有两年多了&#xff0c;所以照片和视频越来越多。上个月618活动&#xff0c;有入手了一块移动硬盘。买多是&#xff1a;西部数据My Passport Ultra移动硬盘4T下面从购买到验证全过程来说图片来源网络图片来源网络一、天猫截图上一篇文章&#xff1a;【希捷硬盘购买指南】…

多角度解析特斯拉电动车技术到底领先了多少?|厚势

来源&#xff1a;Astroys厚势按&#xff1a;不管是豪华车、传统车还是新造车势力造的电动车&#xff0c;都以对标特斯拉为荣。是什么让特斯拉成为电动车的图腾&#xff1f;特斯拉的电动车技术到底领先多少&#xff1f;本文 8000 余字&#xff0c;多个角度进行分析解读。在人们的…

Logistic回归的牛顿法及DFP、BFGS拟牛顿法求解

牛顿法 1 # coding:utf-82 import matplotlib.pyplot as plt3 import numpy as np4 5 def dataN(length):#生成数据6 x np.ones(shape (length,3))7 y np.zeros(length)8 for i in np.arange(0,length/100,0.02):9 x[100*i][0]110 x[100*i][1]…

vim复制一个文件的多行到另一个文件

vim打开一个文件后复制多行&#xff0c;退出这个文件之后&#xff0c;打开另一个文件想复制到这个文件&#xff0c;却发现在上一个文件中复制的内容不见了 所以vim复制一个文件的多行到另一个文件的正确做法是要同时打开两个文件 比如要把add.cpp的内容复制到main.cpp 首先v…

memcached客户端_分布式算法真是吊炸天 – memcached - 第287篇

相关历史文章&#xff08;阅读本文之前&#xff0c;您可能需要先看下之前的系列 &#xff09;色谈Java序列化&#xff1a;女孩子慎入 - 第280篇烦不烦&#xff0c;别再问我时间复杂度了&#xff1a;这次不色&#xff0c;女孩子进来吧 - 第281篇双向链表&#xff0c;比西天还远&…