MySQL数据库的接口程序下载地址:https://sourceforge.net/projects/mysql-python/
操作数据库的大致步骤如下:
1:首先先创建一个数据库的连接对象connection;
2:然后用连接对象创建游标对象;
3:用游标对象操作数据库(比如:增删查改);
4:最后提交事务或回滚事务。
连接对象connection有以下方法:
cursor() ------------------------------- 创建并返回游标
commit() ------------------------------- 提交当前事务
rollback() ------------------------------- 回滚当前事务
close() -------------------------------- 关闭连接
游标对象cursor有以下方法:
execute() --------------------------------- 执行数据库查询和命令
fetchone() --------------------------------- 取得结果集的下一行
fetchmany() --------------------------------- 取得结果集的下几行
fetchall() --------------------------------- 取得结果集中剩下的所有行
rowcount --------------------------------- 最近一次execute()返回数据的行数或影响行数
close() --------------------------------- 关闭游标对象
提交事务:当你操作了数据库(增删查改)之后,就一定要提交事务,不然你之前的操作不会有结果。
回滚事务:如果操作数据库出现异常的时候,就可以用回滚事务,使之恢复到没有操作数据库之前。
下面用代码来加深理解:
1 #-*- coding:utf-8 -*- 2 import MySQLdb 3 4 con = MySQLdb.Connect( 5 host = "你的数据库主机地址", 6 user = "你的数据库用户名", 7 passwd = "你的数据库密码", 8 db = "你的数据库名", 9 port = 3306, 10 charaet = "编码类型" 11 12 ) 13 14 cur = con.cursor()
上面创建了连接对象,然后用连接对象创建了游标对象,步骤1、2就完成了。接着来操作数据库,这是我数据库一个表(user)的数据:
接着代码:
1 sql = "select * from user" 2 cur.execute(sql) 3 4 print cur.rowcount 5 6 print cur.fetchone() 7 8 print cur.fetchmany(1) 9 10 print cur.fetchall() 11 12 cur.close() 13 con.close()
打印结果如下:
3
(u‘name1‘, u‘1‘)
((u‘name2‘, u‘2‘),)
((u‘name3‘, u‘3‘),)
我想代码不言而明,因为里面代码的一些方法在上面已经告知了用处。注意:操作完后要关闭游标对象和连接对象(用close()方法)
接着操作,增:
1 sql = ‘inser into user(username, password) values("name4","4")‘ 2 cur.execute(sql) 3 4 cur.close() 5 con.close()
运行上面代码发现数据库并没有增加记录(自动提交已关闭),这时就要提交事务(用commit()方法),在上面代码的第三行加上这句代码:con.commit()并运行代码发现数据库添加了一条记录。如图:
-------------------接下来的改和删就不演示了,改下SQL语句就可以的,接下来看下回滚事务-------------------------------
1 insert_sql = ‘insert into user(username, password) values("name5", "5")‘ 2 del_sql = "delete from user where word=‘5‘" 3 try: 4 5 cur.execute(insert_sql) 6 7 cur.execute(del_sql) 8 9 con.commit() 10 except: 11 con.rollback() 12 13 cur.close() 14 con.close()
上面代码有两个SQL语句,一个是增加username=name5,password=5,一个是删除word字段等于5的记录,但是我的表中并没有word这个字段。所以增的语句会执行成功,删的语句会执行失败。我把执行这两条语句放到try块里,全部执行成功就提交事务,一旦哪条执行失败就捕获错误并回滚事务。运行了代码后发现,数据库不变。这里虽然增执行成功了,但在删执行失败了,就回滚了事务。所以回滚事务就恢复到了没有操作数据库之前(这里就是没有执行增之前),所以数据库的数据不变。
操作数据库并不难,只要你会SQL语句!