首页 后端开发 Python教程 再Python程序中操作MySQL的基本方法

再Python程序中操作MySQL的基本方法

Jun 06, 2016 am 11:13 AM
mysql python

Python操作Mysql

最近在学习python,这种脚本语言毫无疑问的会跟数据库产生关联,因此这里介绍一下如何使用python操作mysql数据库。我python也是零基础学起,所以本篇博客针对的是python初学者,大牛可以选择绕道。

另外,本篇基于的环境是Ubuntu13.10,使用的python版本是2.7.5。
MYSQL数据库

MYSQL是一个全球领先的开源数据库管理系统。它是一个支持多用户、多线程的数据库管理系统,与Apache、PHP、Linux共同组成LAMP平台,在web应用中广泛使用,例如Wikipedia和YouTube。MYSQL包含两个版本:服务器系统和嵌入式系统。
环境配置

在我们开始语法学习之前,还需要按装mysql和python对mysql操作的模块。

安装mysql:

sudo apt-get install mysql-server

登录后复制

安装过程中会提示你输入root帐号的密码,符合密码规范即可。

接下来,需要安装python对mysql的操作模块:

sudo apt-get install python-mysqldb

登录后复制

这里需要注意:安装完python-mysqldb之后,我们默认安装了两个python操作模块,分别是支持C语言API的_mysql和支持Python API的MYSQLdb。稍后会重点讲解MYSQLdb模块的使用。

接下来,我们进入MYSQL,创建一个测试数据库叫testdb。创建命令为:

create database testdb;

登录后复制


然后,我们创建一个测试账户来操作这个testdb数据库,创建和授权命令如下:

create user 'testuser'@'127.0.0.1' identified by 'test123';
grant all privileges on testdb.* to 'testuser'@'127.0.0.1';

_mysql module

登录后复制

_mysql模块直接封装了MYSQL的C语言API函数,它与python标准的数据库API接口是不兼容的。我更推荐大家使用面向对象的MYSQLdb模块才操作mysql,这里只给出一个使用_mysql模块的例子,这个模块不是我们学习的重点,我们只需要了解有这个模块就好了。

#!/usr/bin/python
# -*- coding: utf-8 -*-

import _mysql
import sys

try:
  con = _mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb')
  con.query("SELECT VERSION()")
  result = con.use_result()

  print "MYSQL version : %s " % result.fetch_row()[0]

except _mysql.Error, e:
  print "Error %d: %s %s" % (e.args[0], e.args[1])
  sys.exit(1)

finally:
  if con:
    con.close()

登录后复制

这个代码主要是获取当前mysql的版本,大家可以模拟敲一下这部分代码然后运行一下。
MYSQLdb module

MYSQLdb是在_mysql模块的基础上进一步进行封装,并且与python标准数据库API接口兼容,这使得代码更容易被移植。Python更推荐使用这个MYSQLdb模块来进行MYSQL操作。

#!/usr/bin/python
# -*- coding: utf-8 -*-

import MySQLdb as mysql

try:
  conn = mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb')
  cur = conn.cursor()
  cur.execute("SELECT VERSION()")

  version = cur.fetchone()
  print "Database version : %s" % version

except mysql.Error, e:
  print "Error %d:%s" % (e.args[0], e.args[1])
  exit(1)

finally:
  if conn:
    conn.close()

登录后复制


我们导入了MySQLdb模块并把它重命名为mysql,然后调用MySQLdb模块的提供的API方法来操作数据库。同样也是获取当前主机的安装的mysql版本号。
创建新表

接下来,我们通过MySQLdb模块创建一个表,并在其中填充部分数据。实现代码如下:

#!/usr/bin/python

# -*- coding: utf-8 -*-

import MySQLdb as mysql

conn = mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb');

with conn:
  cur = conn.cursor()
  cur.execute("DROP TABLE IF EXISTS writers");
  cur.execute("CREATE TABLE writers(id INT PRIMARY KEY AUTO_INCREMENT, name varchar(25))")
  cur.execute("insert into writers(name) values('wangzhengyi')")
  cur.execute("insert into writers(name) values('bululu')")
  cur.execute("insert into writers(name) values('chenshan')")

登录后复制

这里使用了with语句。with语句会执行conn对象的enter()和__exit()方法,省去了自己写try/catch/finally了。

执行完成后,我们可以通过mysql-client客户端查看是否插入成功,查询语句:

select * from writers;

登录后复制

查询结果如下:

2015729102658336.jpg (965×174)

查询数据

刚才往表里插入了部分数据,接下来,我们从表中取出插入的数据,代码如下:

#!/usr/bin/python

import MySQLdb as mysql

conn = mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb');

with conn:
  cursor = conn.cursor()
  cursor.execute("select * from writers")
  rows = cursor.fetchall()

  for row in rows:
    print row

登录后复制


查询结果如下:

(1L, 'wangzhengyi')
(2L, 'bululu')
(3L, 'chenshan')

登录后复制

dictionary cursor

我们刚才不论是创建数据库还是查询数据库,都用到了cursor。在MySQLdb模块有许多种cursor类型,默认的cursor是以元组的元组形式返回数据的。当我们使用dictionary cursor时,数据是以python字典形式返回的。这样我们就可以通过列名获取查询数据了。

还是刚才查询数据的代码,改为dictionary cursor只需要修改一行代码即可,如下所示:

#!/usr/bin/python

import MySQLdb as mysql

conn = mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb');

with conn:
  cursor = conn.cursor(mysql.cursors.DictCursor)
  cursor.execute("select * from writers")
  rows = cursor.fetchall()

  for row in rows:
    print "id is %s, name is %s" % (row['id'], row['name'])

登录后复制

使用dictionary cursor,查询结果如下:

id is 1, name is wangzhengyi
id is 2, name is bululu
id is 3, name is chenshan

登录后复制


预编译

之前写过php的同学应该对预编译很了解,预编译可以帮助我们防止sql注入等web攻击还能帮助提高性能。当然,python肯定也是支持预编译的。预编译的实现也比较简单,就是用%等占位符来替换真正的变量。例如查询id为3的用户的信息,使用预编译的代码如下:

#!/usr/bin/python

import MySQLdb as mysql

conn = mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb');

with conn:
  cursor = conn.cursor(mysql.cursors.DictCursor)
  cursor.execute("select * from writers where id = %s", "3")
  rows = cursor.fetchone()
  print "id is %d, name is %s" % (rows['id'], rows['name'])

登录后复制

我这里使用了一个%s的占位符来替换“3”,代表需要传入的是一个字符串类型。如果传入的不是string类型,则会运行报错。
事务

事务是指在一个或者多个数据库中对数据的原子操作。在一个事务中,所有的SQL语句的影响要不就全部提交到数据库,要不就全部都回滚。

对于支持事务机制的数据库,python接口在创建cursor的时候就开始了一个事务。可以通过cursor对象的commit()方法来提交所有的改动,也可以使用cursor对象的rollback方法来回滚所有的改动。

我这里写一个代码,对不存在的表进行插入操作,当抛出异常的时候,调用rollback进行回滚,实现代码如下:

#!/usr/bin/python

# -*- coding: utf-8 -*-

import MySQLdb as mysql


try:
  conn = mysql.connect('127.0.0.1', 'testuser', 'test123', 'testdb');
  cur = conn.cursor()
  cur.execute("insert into writers(name) values('wangzhengyi4')")
  cur.execute("insert into writers(name) values('bululu5')")
  cur.execute("insert into writerss(name) values('chenshan6')")

  conn.commit()

except mysql.Error, e:
  if conn:
    conn.rollback()
    print "Error happens, rollback is call"

finally:
  if conn:
    conn.close()

登录后复制

执行结果如下:

Error happens, rollback is call

登录后复制

因为前两条数据是正确的插入操作,但是因为整体回滚,所以数据库里也没有wangzhengyi4和bululu5这两个数据的存在。

本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover

AI Clothes Remover

用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool

Undress AI Tool

免费脱衣服图片

Clothoff.io

Clothoff.io

AI脱衣机

AI Hentai Generator

AI Hentai Generator

免费生成ai无尽的。

热门文章

R.E.P.O.能量晶体解释及其做什么(黄色晶体)
2 周前 By 尊渡假赌尊渡假赌尊渡假赌
仓库:如何复兴队友
1 个月前 By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险:如何获得巨型种子
4 周前 By 尊渡假赌尊渡假赌尊渡假赌

热工具

记事本++7.3.1

记事本++7.3.1

好用且免费的代码编辑器

SublimeText3汉化版

SublimeText3汉化版

中文版,非常好用

禅工作室 13.0.1

禅工作室 13.0.1

功能强大的PHP集成开发环境

Dreamweaver CS6

Dreamweaver CS6

视觉化网页开发工具

SublimeText3 Mac版

SublimeText3 Mac版

神级代码编辑软件(SublimeText3)

Debian日志中有哪些关键信息不可忽视 Debian日志中有哪些关键信息不可忽视 Apr 02, 2025 am 08:12 AM

Debian系统的日志文件是系统管理员和开发者诊断问题、监控系统运行状态的宝贵资源。本文将重点介绍一些不容忽视的关键日志信息。核心系统日志(通常位于/var/log/syslog或/var/log/messages)这些日志记录了系统的核心活动,包括:系统启动和关机事件:记录内核版本、硬件检测结果等,帮助追踪启动失败或关机异常。硬件故障警报:例如磁盘错误、内存问题等,及时发现硬件潜在问题。服务状态变化:记录服务的启动、停止和重启事件,方便监控服务运行状况。用户登录/注销记录:

Python 3.6加载Pickle文件报错"__builtin__"模块未找到怎么办? Python 3.6加载Pickle文件报错"__builtin__"模块未找到怎么办? Apr 02, 2025 am 07:12 AM

Python3.6环境下加载Pickle文件报错:ModuleNotFoundError:Nomodulenamed...

Debian Strings在网站中如何应用 Debian Strings在网站中如何应用 Apr 02, 2025 am 08:21 AM

本文探讨如何在Debian系统上优化网站性能。“DebianStrings”并非标准术语,可能指的是Debian系统中用于提升网站性能的工具或技术。以下是一些实用技巧:一、Web服务器及PHP环境配置建议使用宝塔面板简化安装和配置过程。推荐安装Nginx1.22.1作为Web服务器,PHP8.2作为脚本解释器,以及MySQL10.7.3-MariaDB作为数据库系统。务必启用必要的PHP扩展,例如fileinfo、opcache、memcached、red

Debian Strings能否兼容多种浏览器 Debian Strings能否兼容多种浏览器 Apr 02, 2025 am 08:30 AM

“DebianStrings”并非标准术语,其具体含义尚不明确。本文无法直接评论其浏览器兼容性。然而,如果“DebianStrings”指的是在Debian系统上运行的Web应用,则其浏览器兼容性取决于应用本身的技术架构。大多数现代Web应用都致力于跨浏览器兼容性。这依赖于遵循Web标准,并使用兼容性良好的前端技术(如HTML、CSS、JavaScript)以及后端技术(如PHP、Python、Node.js等)。为了确保应用与多种浏览器兼容,开发者通常需要进行跨浏览器测试,并使用响应式

Beego ORM中如何指定模型关联的数据库? Beego ORM中如何指定模型关联的数据库? Apr 02, 2025 pm 03:54 PM

在BeegoORM框架下,如何指定模型关联的数据库?许多Beego项目需要同时操作多个数据库。当使用Beego...

XML如何修改注释内容 XML如何修改注释内容 Apr 02, 2025 pm 06:15 PM

对于小型XML文件,可直接用文本编辑器替换注释内容;对于大型文件,建议借助XML解析器进行修改,确保效率和准确性。删除XML注释时需谨慎,保留注释通常有助于代码理解和维护。进阶技巧中提供了使用XML解析器修改注释的Python示例代码,但具体实现需根据使用的XML库进行调整。修改XML文件时注意编码问题,建议使用UTF-8编码并指定编码格式。

XML修改内容需要编程吗 XML修改内容需要编程吗 Apr 02, 2025 pm 06:51 PM

修改XML内容需要编程,因为它需要精准找到目标节点才能增删改查。编程语言有相应库来处理XML,提供API像操作数据库一样进行安全、高效、可控的操作。

如何选择MySQL和Redis数据一致性的方案:延迟双删与先改数据库再删缓存的区别与适用场景? 如何选择MySQL和Redis数据一致性的方案:延迟双删与先改数据库再删缓存的区别与适用场景? Apr 02, 2025 am 11:57 AM

关于MySQL和Redis数据一致性的两种方案:延迟双删与先改数据库再删缓存在处理MySQL和Redis的数据一致性问题时,�...

See all articles