前言

大家都知道在Python中如果要连接数据库，不管是MySQL、SQL Server、PostgreSQL亦或是SQLite，使用时都是采用游标的方式，所以就不得不学习Python DB-API。

Python所有的数据库接口程序都在一定程度上遵守 Python DB-API 规范。DB-API定义了一系列必须的对象和数据库存取方式，以便为各种底层数据库系统和多种多样的数据库接口程序提供一致的访问接口。由于DB-API 为不同的数据库提供了一致的访问接口， 在不同的数据库之间移植代码成为一件轻松的事情。

Python连接数据库流程：

使用connect创建connection连接

connect 方法生成一个 connect 对象, 我们通过这个对象来访问数据库。符合标准的模块都会实现 connect 方法。

connect 函数的参数如下所示：

• user Username
• password Password
• host Hostname
• database Database name
• dsn Data source name
  

数据库连接参数可以以一个 DSN 字符串的形式提供，示例：connect(dsn='host:MYDB',user='root',password=' ')
当然，不同的数据库接口程序可能有些差异，并非都是严格按照规范实现，例如MySQLdb则使用 db 参数而不是规范推荐的 database 参数来表示要访问的数据库：

MySQLdb连接时可用参数

• host: 数据库主机名.默认是用本地主机
• user: 数据库登陆名.默认是当前用户
• passwd: 数据库登陆的秘密.默认为空
• db: 要使用的数据库名.没有默认值
• port: MySQL服务使用的TCP端口.默认是3306
• charset: 数据库编码
  

psycopg2连接时可用参数：

• dbname – 数据库名称 (dsn连接模式)
• database – 数据库名称
• user – 用户名
• password – 密码
• host – 服务器地址 (如果不提供默认连接Unix Socket)
• port – 连接端口 (默认5432)
  

其中connect对象又有如下方法:

• close():关闭此connect对象, 关闭后无法再进行操作，除非再次创建连接
• commit():提交当前事务，如果是支持事务的数据库执行增删改后没有commit则数据库默认回滚
• rollback():取消当前事务
• cursor():创建游标对象
  

使用cursor创建游标对象

cursor游标对象又有如下属性和方法:

常用方法:

• close():关闭此游标对象
• fetchone():得到结果集的下一行
• fetchmany([size = cursor.arraysize]):得到结果集的下几行
• fetchall():得到结果集中剩下的所有行
• excute(sql[, args]):执行一个数据库查询或命令
• excutemany(sql, args):执行多个数据库查询或命令

常用属性:

• connection:创建此游标对象的数据库连接
• arraysize:使用fetchmany()方法一次取出多少条记录，默认为1
• lastrowid:相当于PHP的last_inset_id()
  

其他方法：

• __iter__()：创建一个可迭代对象（可选）
• next()：获取结果集的下一行（如果支持迭代的话）
• nextset()：移到下一个结果集（如果支持的话）
• callproc(func[,args])：调用一个存储过程
• setinputsizes(sizes)：设置输入最大值（必须有，但具体实现是可选的）
• setoutputsizes(sizes[,col])：设置大列 fetch 的最大缓冲区大小
  

其他属性：

• description：返回游标活动状态（包含7个元素的元组）：（name, type_code, display_size, internal_size, precision, scale, null_ok）只有 name 和 type_cose 是必需的
• rowcount：最近一次 execute() 创建或影响的行数
• messages：游标执行后数据库返回的信息元组（可选）
• rownumber：当前结果集中游标所在行的索引（起始行号为 0）

DB-API只中的错误定义

错误类的层次关系：

StandardError
|__Warning
|__Error
|__InterfaceError
|__DatabaseError
|__DataError
|__OperationalError
|__IntegrityError
|__InternalError
|__ProgrammingError
|__NotSupportedError

数据库操作示例

代码如下：

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

# *************************************************************
#  Filename @ operatemysql.py
#  Author @ Huoty
# Create date @ 2015-08-16 10:44:34
# Description @ 
# *************************************************************

import MySQLdb

# Script starts from here

# 连接数据库
db_conn = MySQLdb.connect(host = 'localhost', user= 'root', passwd = '123456')

# 如果已经创建了数据库，可以直接用如下方式连接数据库
#db_conn = MySQLdb.connect(host = "localhost", user = "root",passwd = "123456", db = "testdb")

"""
connect方法常用参数:
 host: 数据库主机名.默认是用本地主机
 user: 数据库登陆名.默认是当前用户
 passwd: 数据库登陆的秘密.默认为空
 db: 要使用的数据库名.没有默认值
 port: MySQL服务使用的TCP端口.默认是3306
 charset: 数据库编码
"""

# 获取操作游标 
cursor = db_conn.cursor()

# 使用 execute 方法执行SQL语句
cursor.execute("SELECT VERSION()")

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

print "Database version : %s " % dbversion

# 创建数据库
cursor.execute("create database if not exists dbtest")

# 选择要操作的数据库
db_conn.select_db('dbtest');

# 创建数据表SQL语句
sql = """CREATE TABLE if not exists employee(
   first_name CHAR(20) NOT NULL,
   last_name CHAR(20),
   age INT, 
   sex CHAR(1),
   income FLOAT )"""

try:
 cursor.execute(sql)
except Exception, e:
 # Exception 是所有异常的基类，这里表示捕获所有的异常
 print "Error to create table:", e

# 插入数据
sql = """INSERT INTO employee(first_name,
   last_name, age, sex, income)
   VALUES ('%s', '%s', %d, '%s', %d)"""

# Sex: Male男, Female女

employees = ( 
  {"first_name": "Mac", "last_name": "Mohan", "age": 20, "sex": "M", "income": 2000},
  {"first_name": "Wei", "last_name": "Zhu", "age": 24, "sex": "M", "income": 7500},
  {"first_name": "Huoty", "last_name": "Kong", "age": 24, "sex": "M", "income": 8000},
  {"first_name": "Esenich", "last_name": "Lu", "age": 22, "sex": "F", "income": 3500},
  {"first_name": "Xmin", "last_name": "Yun", "age": 31, "sex": "F", "income": 9500},
  {"first_name": "Yxia", "last_name": "Fun", "age": 23, "sex": "M", "income": 3500}
  )

try:
 # 清空表中数据
 cursor.execute("delete from employee")
 # 执行 sql 插入语句
 for employee in employees:
  cursor.execute(sql % (employee["first_name"], \
   employee["last_name"], \
   employee["age"], \
   employee["sex"], \
   employee["income"]))
 # 提交到数据库执行
 db_conn.commit()
 # 对于支持事务的数据库， 在Python数据库编程中，
 # 当游标建立之时，就自动开始了一个隐形的数据库事务。
 # 用 commit 方法能够提交事物
except Exception, e:
 # Rollback in case there is any error
 print "Error to insert data:", e
 #b_conn.rollback()

print "Insert rowcount:", cursor.rowcount
# rowcount 是一个只读属性，并返回执行execute(方法后影响的行数。)

# 数据库查询操作:
# fetchone()  得到结果集的下一行 
# fetchmany([size=cursor.arraysize]) 得到结果集的下几行 
# fetchall()  返回结果集中剩下的所有行 
try:
 # 执行 SQL
 cursor.execute("select * from employee")

 # 获取一行记录
 rs = cursor.fetchone()
 print rs

 # 获取余下记录中的 2 行记录
 rs = cursor.fetchmany(2)
 print rs

 # 获取剩下的所有记录
 ars = cursor.fetchall()
 for rs in ars:
  print rs
 # 可以用 fetchall 获得所有记录，然后再遍历
except Exception, e:
 print "Error to select:", e

# 数据库更新操作
sql = "UPDATE employee SET age = age + 1 WHERE sex = '%c'" % ('M')
try:
 # 执行SQL语句
 cursor.execute(sql)
 # 提交到数据库执行
 db_conn.commit()
 cursor.execute("select * from employee")
 ars = cursor.fetchall()
 print "After update: ------"
 for rs in ars:
  print rs
except Exception, e:
 # 发生错误时回滚
 print "Error to update:", e
 db.rollback()

# 关闭数据库连接
db_conn.close()

其他参考文档：

https://www.python.org/dev/peps/pep-0249/

http://wiki.python.org/moin/DatabaseInterfaces

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流。

# python  # db  # api  # 2.0  # 连接数据库  # python使用mysqldb连接数据库操作方法示例详解  # python连接数据库的方法  # python mysqldb连接数据库  # 跟老齐学Python之通过Python连接数据库  # Python使用sqlalchemy模块连接数据库操作示例  # 学习python之编写简单简单连接数据库并执行查询操作  # Python 3.x 连接数据库示例（pymysql 方式）  # Python使用Flask-SQLAlchemy连接数据库操作示例  # 解决python3 Pycharm上连接数据库时报错的问题  # Python与数据库交互：入门指南  # 可选  # 都是  # 又有  # 数据库查询  # 行号  # 要使  # 为空  # 默认值  # 几行  # 行数  # 是一个  # 迭代  # 大家都  # 多个  # 就不  # 可以用  # 遍历  # 之时  # 然后再 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： php在windows下怎么调试_phpwindows环境调试操作说明【操作】  Laravel模型关联查询教程_Laravel Eloquent一对多关联写法  如何在建站之星绑定自定义域名？  C++用Dijkstra(迪杰斯特拉)算法求最短路径  重庆市网站制作公司,重庆招聘网站哪个好？  如何快速搭建高效可靠的建站解决方案？  Laravel如何实现邮箱地址验证功能_Laravel邮件验证流程与配置  Windows10如何更改计算机工作组_Win10系统属性修改Workgroup  如何做网站制作流程,*游戏网站怎么搭建？  如何自定义safari浏览器工具栏？个性化设置safari浏览器界面教程【技巧】  如何在七牛云存储上搭建网站并设置自定义域名？  VIVO手机上del键无效OnKeyListener不响应的原因及解决方法  Claude怎样写约束型提示词_Claude约束提示词写法【教程】  济南网站建设制作公司,室内设计网站一般都有哪些功能？  如何彻底删除建站之星生成的Banner？  Laravel Eloquent关联是什么_Laravel模型一对一与一对多关系精讲  宙斯浏览器视频悬浮窗怎么开启 边看视频边操作其他应用教程  微信小程序 HTTPS报错整理常见问题及解决方案  手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办？  韩国服务器如何优化跨境访问实现高效连接？  nodejs redis 发布订阅机制封装实现方法及实例代码  深圳网站制作公司好吗,在深圳找工作哪个网站最好啊？  Laravel如何与Vue.js集成_Laravel + Vue前后端分离项目搭建指南  如何快速启动建站代理加盟业务？  非常酷的网站设计制作软件,酷培ai教育官方网站？  Mybatis 中的insertOrUpdate操作  Laravel如何实现URL美化Slug功能_Laravel使用eloquent-sluggable生成别名【方法】  如何用AI一键生成爆款短视频文案？小红书AI文案写作指令【教程】  如何彻底卸载建站之星软件？  Laravel如何集成第三方登录_Laravel Socialite实现微信QQ微博登录  如何续费美橙建站之星域名及服务？  如何在IIS7上新建站点并设置安全权限？  如何打造高效商业网站？建站目的决定转化率  香港服务器租用每月最低只需15元？  Laravel怎么实现模型属性的自动加密  大型企业网站制作流程,做网站需要注册公司吗？  如何在阿里云部署织梦网站？  Python正则表达式进阶教程_复杂匹配与分组替换解析  javascript中数组（Array)对象和字符串（String)对象的常用方法总结  历史网站制作软件,华为如何找回被删除的网站？  如何快速上传建站程序避免常见错误？  Python企业级消息系统教程_KafkaRabbitMQ高并发应用  如何快速生成凡客建站的专业级图册？  Laravel如何使用.env文件管理环境变量？（最佳实践）  如何用5美元大硬盘VPS安全高效搭建个人网站？  如何在云主机上快速搭建网站？  小视频制作网站有哪些,有什么看国内小视频的网站，求推荐？  如何挑选优质建站一级代理提升网站排名？  Laravel如何设置定时任务（Cron Job）_Laravel调度器与任务计划配置  北京网站制作公司哪家好一点,北京租房网站有哪些？