백엔드 개발 파이썬 튜토리얼 再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 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

뜨거운 도구

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

무시할 수없는 데비안 로그의 주요 정보는 무엇입니까? 무시할 수없는 데비안 로그의 주요 정보는 무엇입니까? Apr 02, 2025 am 08:12 AM

데비안 시스템의 로그 파일은 시스템 관리자와 개발자가 문제를 진단하고 시스템의 작동 상태를 모니터링 할 수있는 귀중한 리소스입니다. 이 기사는 무시할 수없는 몇 가지 주요 로그 정보에 중점을 둘 것입니다. 코어 시스템 로그 (일반적으로/var/log/syslog 또는/var/log/message에 위치)이 로그는 시스템 시작 및 종료 이벤트 : 로그 커널 버전, 하드웨어 감지 결과 등을 포함하여 시스템의 핵심 활동을 기록하여 시작 실패 또는 종료 예외를 추적하는 데 도움이됩니다. 하드웨어 실패 경고 : 디스크 오류, 메모리 문제 등과 같은 잠재적 하드웨어 문제를 즉시 감지합니다. 서비스 상태 변경 : 서비스 시작을 기록하고, 이벤트를 중지 및 다시 시작하여 서비스의 건강 모니터링을 용이하게합니다. 사용자 로그인/로그 아웃 기록 :

Python 3.6에 피클 파일을로드 할 때 '__builtin__'모듈을 찾을 수없는 경우 어떻게해야합니까? Python 3.6에 피클 파일을로드 할 때 '__builtin__'모듈을 찾을 수없는 경우 어떻게해야합니까? Apr 02, 2025 am 07:12 AM

Python 3.6에 피클 파일로드 3.6 환경 보고서 오류 : modulenotfounderror : nomodulename ...

웹 사이트에서 데비안 문자열을 적용하는 방법 웹 사이트에서 데비안 문자열을 적용하는 방법 Apr 02, 2025 am 08:21 AM

이 기사에서는 데비안 시스템에서 웹 사이트 성능을 최적화하는 방법에 대해 설명합니다. "Debiantrings"는 표준 용어가 아니며 웹 사이트 성능을 향상시키기 위해 데비안 시스템에 사용되는 도구 또는 기술을 참조 할 수 있습니다. 다음은 실용적인 팁입니다. 1. Pagoda 패널을 사용하여 웹 서버 및 PHP 환경 구성의 설치 및 구성 프로세스를 단순화하는 것이 좋습니다. Nginx1.22.1을 웹 서버로, PHP8.2를 스크립트 통역사로, 데이터베이스 시스템으로 MySQL10.7.3-mariadb를 설치하는 것이 좋습니다. FileInfo, Opcache, Memcached, Red와 같은 필요한 PHP 확장을 활성화하십시오.

데비안 문자열은 여러 브라우저와 호환됩니다 데비안 문자열은 여러 브라우저와 호환됩니다 Apr 02, 2025 am 08:30 AM

"Debiantrings"는 표준 용어가 아니며 구체적인 의미는 여전히 불분명합니다. 이 기사는 브라우저 호환성에 직접 언급 할 수 없습니다. 그러나 "Debiantrings"가 Debian 시스템에서 실행되는 웹 응용 프로그램을 지칭하는 경우 브라우저 호환성은 응용 프로그램 자체의 기술 아키텍처에 따라 다릅니다. 대부분의 최신 웹 응용 프로그램은 크로스 브라우저 호환성에 전념합니다. 이는 웹 표준에 따라 웹 표준과 잘 호환 가능한 프론트 엔드 기술 (예 : 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 파서를 사용하여 댓글을 수정하기위한 파이썬 샘플 코드를 제공하지만 사용 된 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