Python标准数据库接口为PythonDB-API,PythonDB-API为开发人员提供了数据库应用编程接口。
Python数据库接口支持非常多的数据库,你可以选择适合你项目的数据库:
不同的数据库你需要下载不同的DBAPI模块,例如你需要访问Oracle数据库和Mysql数据,你需要下载Oracle和MySQL数据库模块。
DB-API是一个规范.它定义了一系列必须的对象和数据库存取方式,以便为各种各样的底层数据库系统和多种多样的数据库接口程序提供一致的访问接口。
Python的DB-API,为大多数的数据库实现了接口,使用它连接各数据库后,就可以用相同的方式操作各数据库。
PythonDB-API使用流程:
MySQLdb是用于Python链接Mysql数据库的接口,它实现了Python数据库API规范V2.0,基于MySQLCAPI上建立的。
为了用DB-API编写MySQL脚本,必须确保已经安装了MySQL。复制以下代码,并执行:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb如果执行后的输出结果如下所示,意味着你没有安装MySQLdb模块:
如果您选择二进制文件发行版本的话,安装过程基本安装提示即可完成。如果从源代码进行安装的话,则需要切换到MySQLdb发行版本的顶级目录,并键入下列命令:
$gunzipMySQL-python-1.2.2.tar.gz$tar-xvfMySQL-python-1.2.2.tar$cdMySQL-python-1.2.2$pythonsetup.pybuild$pythonsetup.pyinstall注意:请确保您有root权限来安装上述模块。
连接数据库前,请先确认以下事项:
以下实例链接Mysql的TESTDB数据库:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#使用execute方法执行SQL语句cursor.execute("SELECTVERSION()")#使用fetchone()方法获取一条数据data=cursor.fetchone()print"Databaseversion:%s"%data#关闭数据库连接db.close()执行以上脚本输出结果如下:
Databaseversion:5.0.45创建数据库表如果数据库连接存在我们可以使用execute()方法来为数据库创建表,如下所示创建表EMPLOYEE:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#如果数据表已经存在使用execute()方法删除表。cursor.execute("DROPTABLEIFEXISTSEMPLOYEE")#创建数据表SQL语句sql="""CREATETABLEEMPLOYEE(FIRST_NAMECHAR(20)NOTNULL,LAST_NAMECHAR(20),AGEINT,SEXCHAR(1),INCOMEFLOAT)"""cursor.execute(sql)#关闭数据库连接db.close()数据库插入操作以下实例使用执行SQLINSERT语句向表EMPLOYEE插入记录:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#SQL插入语句sql="""INSERTINTOEMPLOYEE(FIRST_NAME,LAST_NAME,AGE,SEX,INCOME)VALUES('Mac','Mohan',20,'M',2000)"""try:#执行sql语句cursor.execute(sql)#提交到数据库执行db.commit()except:#Rollbackincasethereisanyerrordb.rollback()#关闭数据库连接db.close()以上例子也可以写成如下形式:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#SQL插入语句sql="INSERTINTOEMPLOYEE(FIRST_NAME,\LAST_NAME,AGE,SEX,INCOME)\VALUES(%s,%s,%s,%s,%s)"%\('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('insertintoLoginvalues(%s,%s)'%\(user_id,password))..................................数据库查询操作Python查询Mysql使用fetchone()方法获取单条数据,使用fetchall()方法获取多条数据。
查询EMPLOYEE表中salary(工资)字段大于1000的所有数据:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#SQL查询语句sql="SELECT*FROMEMPLOYEE\WHEREINCOME>%s"%(1000)try:#执行SQL语句cursor.execute(sql)#获取所有记录列表results=cursor.fetchall()forrowinresults:fname=row[0]lname=row[1]age=row[2]sex=row[3]income=row[4]#打印结果print"fname=%s,lname=%s,age=%s,sex=%s,income=%s"%\(fname,lname,age,sex,income)except:print"Error:unabletofetchdata"#关闭数据库连接db.close()以上脚本执行结果如下:
fname=Mac,lname=Mohan,age=20,sex=M,income=2000数据库更新操作更新操作用于更新数据表的的数据,以下实例将EMPLOYEE表中的SEX字段为'M'的AGE字段递增1:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#SQL更新语句sql="UPDATEEMPLOYEESETAGE=AGE+1WHERESEX='%c'"%('M')try:#执行SQL语句cursor.execute(sql)#提交到数据库执行db.commit()except:#发生错误时回滚db.rollback()#关闭数据库连接db.close()删除操作删除操作用于删除数据表中的数据,以下实例演示了删除数据表EMPLOYEE中AGE大于20的所有数据:
#!/usr/bin/python#-*-coding:UTF-8-*-importMySQLdb#打开数据库连接db=MySQLdb.connect("localhost","testuser","test123","TESTDB",charset='utf8')#使用cursor()方法获取操作游标cursor=db.cursor()#SQL删除语句sql="DELETEFROMEMPLOYEEWHEREAGE>%s"%(20)try:#执行SQL语句cursor.execute(sql)#提交修改db.commit()except:#发生错误时回滚db.rollback()#关闭连接db.close()执行事务事务机制可以确保数据一致性。
事务应该具有4个属性:原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。
PythonDBAPI2.0的事务提供了两个方法commit或rollback。
#SQL删除记录语句sql="DELETEFROMEMPLOYEEWHEREAGE>%s"%(20)try:#执行SQL语句cursor.execute(sql)#向数据库提交db.commit()except:#发生错误时回滚db.rollback()对于支持事务的数据库,在Python数据库编程中,当游标建立之时,就自动开始了一个隐形的数据库事务。
commit()方法游标的所有更新操作,rollback()方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。
DBAPI中定义了一些数据库操作的错误及异常,下表列出了这些错误和异常: