python操作mysql数据库
Python 规范数据库接口为 Python DB-API,Python DB-API为开发人员供应了数据库运用编程接口。
Python 数据库接口支撑非常多的数据库,你可以选择合适你项目的数据库:
GadFly
mSQL
MySQL
PostgreSQL
Microsoft SQL Server 2000
Informix
Interbase
Oracle
Sybase
你可以访问Python数据库接口及API查看具体的支撑数据库列表。
不同的数据库你需求下载不同的DB API模块,例如你需求访问Oracle数据库和Mysql数据,你需求下载Oracle和MySQL数据库模块。
DB-API 是一个规范. 它界说了一系列有必要的方针和数据库存取方法, 以便为林林总总的底层数据库系统和多种多样的数据库接口程序供应共同的访问接口 。
Python的DB-API,为大多数的数据库完成了接口,运用它联接各数据库后,就可以用相同的方法操作各数据库。
Python DB-API运用流程:
引入 API 模块。
获取与数据库的联接。
施行SQL语句和存储进程。
关闭数据库联接。
什么是MySQLdb?
MySQLdb 是用于Python链接Mysql数据库的接口,它完成了 Python 数据库 API 规范 V2.0,根据 MySQL C API 上建立的。
怎样设备MySQLdb?
为了用DB-API编写MySQL脚本,有必要保证现已设备了MySQL。仿制以下代码,并施行:
#!/usr/bin/python
-- coding: UTF-8 --
import MySQLdb
假定施行后的输出效果如下所示,意味着你没有设备 MySQLdb 模块:
Traceback (most recent call last):
File “test.py”, line 3, in
import MySQLdb
ImportError: No module named MySQLdb
设备MySQLdb,请访问 http://sourceforge.net/projects/mysql-python ,(Linux途径可以访问:https://pypi.python.org/pypi/MySQL-python)从这儿可选择合适您的途径的设备包,分为预编译的二进制文件和源代码设备包。
假定您选择二进制文件发行版其他话,设备进程基本设备提示即可完成。假定从源代码进行设备的话,则需求切换到MySQLdb发行版其他顶级目录,并键入下列指令:
$ gunzip MySQL-python-1.2.2.tar.gz
$ tar -xvf MySQL-python-1.2.2.tar
$ cd MySQL-python-1.2.2
$ python setup.py build
$ python setup.py install
留心:请保证您有root权限来设备上述模块。
数据库联接
联接数据库前,请先招认以下事项:
您现已创立了数据库 TESTDB.
在TESTDB数据库中您现已创立了表 EMPLOYEE
EMPLOYEE表字段为 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
联接数据库TESTDB运用的用户名为 “testuser” ,暗码为 “test123”,你可以可以自己设定或许直接运用root用户名及其暗码,Mysql数据库用户授权请运用Grant指令(cvi-Logistics)。
在你的机子上现已设备了 Python MySQLdb 模块。
假定您对sql语句不熟悉,可以访问我们的 SQL基础教程
实例:
以下实例链接Mysql的TESTDB数据库:
#!/usr/bin/python
-- coding: UTF-8 --
import MySQLdb
翻开数据库联接
db = MySQLdb.connect(“localhost”,“testuser”,“test123”,“TESTDB” )
运用cursor()方法获取操作游标
cursor = db.cursor()
运用execute方法施行SQL语句
cursor.execute(“SELECT VERSION()”)
运用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()
print "Database version : %s " % data
关闭数据库联接
db.close()
施行以上脚本输出效果如下:
Database version : 5.0.45
创立数据库表
假定数据库联接存在我们可以运用execute()方法来为数据库创立表,如下所示创立表EMPLOYEE:
#!/usr/bin/python
-- coding: UTF-8 --
import MySQLdb
翻开数据库联接
db = MySQLdb.connect(“localhost”,“testuser”,“test123”,“TESTDB” )
运用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()
数据库刺进操作
以下实例运用施行 SQL INSERT 语句向表 EMPLOYEE 刺进记载:
#!/usr/bin/python
-- coding: 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 (‘Mac’, ‘Mohan’, 20, ‘M’, 2000)”""
try:
施行sql语句
cursor.execute(sql)
提交到数据库施行
db.commit()
except:
Rollback in case there is any error
db.rollback()
关闭数据库联接
db.close()
以上比方也可以写成如下方式:
#!/usr/bin/python
-- coding: 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()
实例:
以下代码运用变量向SQL语句中传递参数:
…
user_id = “test123”
password = “password”
con.execute(‘insert into Login values("%s", “%s”)’ %
(user_id, password))
…
数据库查询操作
Python查询Mysql运用 fetchone() 方法获取单条数据, 运用fetchall() 方法获取多条数据。
fetchone(): 该方法获取下一个查询效果集。效果集是一个方针
fetchall():接收悉数的回来效果行.
rowcount: 这是一个只读特征,并回来施行execute()方法后影响的行数。
实例:
查询EMPLOYEE表中salary(薪酬)字段大于1000的悉数数据:
#!/usr/bin/python
-- coding: UTF-8 --
import MySQLdb
翻开数据库联接
db = MySQLdb.connect(“localhost”,“testuser”,“test123”,“TESTDB” )
运用cursor()方法获取操作游标(dongfengtooLs)
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
数据库更新操作
更新操效果于更新数据表的的数据,以下实例将 TESTDB表中的 SEX 字段悉数修改为 ‘M’,AGE 字段递加1:
#!/usr/bin/python
-- coding: UTF-8 --
import MySQLdb
翻开数据库联接
db = MySQLdb.connect(“localhost”,“testuser”,“test123”,“TESTDB” )
运用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()
施行事务
事务机制可以保证数据共同性。
事务应该具有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()方法回滚其时游标的悉数操作。每一个方法都开端了一个新的事务。