Python＿DB_Api

python DB API

内容

建立连接connection

数据库交互对象cursor

数据库异常类exception

流程

创建connection

获取cursor

执行查询、执行命令、获取数据、处理数据

关闭cursor 关闭connection

import MySQLdb
print MySQLdb

Python 开发mysql

Python 代码（包含SQL语句）+ Eclipse +Mysql for python

Mysql 服务器 + SQLyog

DB Api -数据库连接对象connection

连接对象：建立Python客户端与数据库的网络连接

创建方法：MySQLdb.Connect(参数)

host 字符串 mysql服务器地址

port 数字 mysql服务器端口号

user 字符串 用户名

password字符串 密码

db 字符串 数据库名称

charset字符串 连接编码

connection 对象支持方法

cursor() 使用该连接创建并返回游标

commit() 提交当前事务

rollback() 回滚当前事务

close() 关闭连接

实例

import MySQLdb

conn = MySQLdb.Connect(
host='127.xxx',
port=3306,
user='root',
passwd='xxxx'
db='testli'
charset='utf8'
)

cursor=conn.cursor()

print conn
print corsor

cursor.close()
conn.close()

数据库游标对象cursor

游标对象： 用于执行查询和获取结果

cursor对象支持的方法：

execute(op[,args]) 执行一个数据库查询和命令

fetchone() 取得结果的下一行

fetchmany(size) 获取结果集的下几行

fetchall() 获取结果集中剩下的所有行

rowcount 最近一次execute返回数据的行数或者影响行数

close() 关闭游标对象

execute方法：执行SQL、将结果从数据库获取到客户端

execute(sql)     执行SQL（数据库）   结果   缓存到本地客户端

fetch*() 方法：移动rownumber，返回数据，操作对象是本地缓存数据

fetchone()
fetchmany(3)
fetchall()

实例 select查询数据

步骤：

1. 创建connection

2. 获取cursor

3. 使用cursor.execute() 执行select语句

4. 使用cursor.fetch*() 获取并处理数据

5. 关闭cursor 关闭connection

新建table

CREATE TABLE 'user'(
'userid' INT(11) NOT NULL  AUTO_INCREMENT,
'username' VARCHAR(100) DEAULT NULL,
PRIMARY KEY ('userid)
)ENGINE=INNODB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8

进行操作测试

import MySQLdb

conn = MySQLdb.Connect(
host='127.xxx',
port=3306,
user='root',
passwd='xxxx'
db='testli'
charset='utf8'
)

cursor=conn.cursor()

sql="select * from user"
cursor.execute(sql)

print corsor.row.count

rs = cursor.fetchone()
print rs

rs = cursor.fetchmany(3)
print rs

rs = cursor.fetchall()
print rs

cursor.close()
conn.close()

结果：

9
(1L,u'name1')
((2L,u'name2'),(3L,u'name3'),(4L,u'name4'))
((5L,u'name5'),(6L,u'name6'),(7L,u'name7'),(8L,u'name8'),(9L,u'name9'))

传递变量

import MySQLdb

conn = MySQLdb.Connect(
host='127.xxx',
port=3306,
user='root',
passwd='xxxx'
db='testli'
charset='utf8'
)

cursor=conn.cursor()

sql="select * from user"
cursor.execute(sql)

rs = cursor.fetchall()
for row in rs:
print "userid=%s,username=%s" % row

cursor.close()
conn.close()

结果：

userid=1,username=name1
userid=2,username=name2
userid=3,username=name3
userid=4,username=name4
userid=5,username=name5
userid=6,username=name6
userid=7,username=name7
userid=8,username=name8
userid=9,username=name9

实例 insert、update/delete更新数据库

1. 创建connection，并获取cursor；
2. 使用cursor.execute()执行insert/update/delete语句；
3. 判断是否出现异常，IF FALSE，使用conn.commit()提交事务；IF True，使用conn.rollback() 回滚事务；
4. 关闭cursor   关闭connection

事务：访问和更新数据库的一个程序执行单元

原子性：事务中包括的诸操作要么都做，要么都不做；

一致性： 事务必须使数据库从一致性状态变到另一个一致性状态

隔离性：一个事务的执行不能被其他事务干扰

持久性：事务一旦提交，它对数据库的改变就是永久性的

开发中怎样使用事务？

关闭自动commit：设置conn.autocommit(False)

正常结束事务：conn.commit()

异常结束事务：con.rollback()

import MySQLdb

conn = MySQLdb.Connect(
host='127.xxx',
port=3306,
user='root',
passwd='xxxx'
db='testli'
charset='utf8'
)

cursor=conn.cursor()

sql_insert="insert into user(userid,username) values(10,'name10)"
sql_update="update user set username='name91' where userid = 9"
sql_delete="delete from user where userid<3"

cursor.execute(sql_insert)
print cursor.rowcount
cursor.execute(sql_update)
print cursor.rowcount
cursor.execute(sql_delete)
print cursor.rowcount

conn.commit()

cursor.close()
conn.close()