标签:
Python其实是可以操纵数据库的,想想如果能在python里写SQL语句,从而直接达到操纵数据库的目的,how cool!
Python的标准数据库接口为Python DB-API,针对不同的数据库要安装不同的模块,其中,MySQLdb就是用于链接MySQL数据库的接口。
安装MySQLdb,可以在 http://sourceforge.net/projects/mysql-python 上找到安装包,下载安装即可,无需多余的设置。
使用流程大致如下:
接下里分开记录数据库连接、创建数据库表、数据库插入操作、查询操作、更新操作、删除操作和错误处理
# 导入模块 import MySQLdb # 数据库连接 db = MySQLdb.connect(host= "localhost", user=‘****‘, passwd=‘****‘, db=‘****‘) |
数据库连接比较简单,格式也都是固定的,注意在连接前,确保用户拥有操纵某个数据库的权限
# -*- coding:utf-8 -*- import MySQLdb db = MySQLdb.connect(host = ‘localhost‘, user = ‘wpy‘, passwd = ‘2016‘, db = ‘testdb‘) # 获取游标 cursor = db.cursor() # cursor的execute方法可以执行SQL # 如果表EMPLOYEE存在则删除 cursor.execute(‘DROP TABLE IF EXISTS EMPLOYEE‘)
sql = ‘CREATE TABLE EMPLOYEE(\ NAME VARCHAR(10) PRIMARY KEY,\ AGE INT,\ SEX VARCHAR(1))‘ cursor.execute(sql) # 关闭游标 cursor.close() # 关闭数据库连接 db.close() |
在powershell中查看:
没有问题!
# -*- coding:utf-8 -*- import MySQLdb db = MySQLdb.connect(host = ‘localhost‘, user = ‘wpy‘, passwd = ‘2016‘, db = ‘testdb‘) # 获取游标 cursor = db.cursor()
# 插入一条记录 sql = "INSERT INTO EMPLOYEE(NAME, AGE, SEX) VALUES (‘Simon‘, 20, ‘M‘)" try: cursor.execute(sql) # 一定要commit()一下数据库才会被更新 db.commit() except: db.rollback()
# 插入多条记录 values = [(‘Lucy‘, 21, ‘W‘), (‘Tom‘, 19, ‘M‘)] # 必须是%s,且没有引号,%d是不行的 sql = "INSERT INTO EMPLOYEE(NAME, AGE, SEX) VALUES (%s, %s, %s)" try: cursor.executemany(sql, values) db.commit() except: db.rollback()
# 关闭游标 cursor.close() # 关闭数据库连接 db.close() |
结果如下:
# -*- coding:utf-8 -*- import MySQLdb db = MySQLdb.connect(host = ‘localhost‘, user = ‘wpy‘, passwd = ‘2016‘, db = ‘testdb‘) # 获取游标 cursor = db.cursor()
# SQL查询语句 sql = "SELECT * FROM EMPLOYEE WHERE AGE >= ‘%d‘" % (20)
try: cursor.execute(sql) # 获取所有记录 rows = cursor.fetchall() for row in rows: print ‘Name:‘, row[0], ‘Age:‘, row[1], ‘Sex:‘, row[2] except: print ‘Error, return nothing.‘ # 关闭游标 cursor.close() # 关闭数据库连接 db.close() |
结果如下:
Cursor还有两个方法,fetchone()和fetchmany(size=)
fetchmany(size=)比较简单,可以控制返回的行数
fetchone()的意义在于逐行获取,因为每使用一次fetch,游标的位置就会发生改变,结果也看得出来,不过这也正是游标的意义所在了
# -*- coding:utf-8 -*- import MySQLdb db = MySQLdb.connect(host = ‘localhost‘, user = ‘wpy‘, passwd = ‘2016‘, db = ‘testdb‘) # 获取游标 cursor = db.cursor()
# SQL更新语句 sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE AGE >= ‘%d‘" % (20)
try: cursor.execute(sql) db.commit() except: db.rollback() # 关闭游标 cursor.close() # 关闭数据库连接 db.close() |
数据库更新操作还是比较简单,注意别忘了db.commit()
# -*- coding:utf-8 -*- import MySQLdb db = MySQLdb.connect(host = ‘localhost‘, user = ‘wpy‘, passwd = ‘2016‘, db = ‘testdb‘) # 获取游标 cursor = db.cursor()
# SQL删除语句 sql = "DELETE FROM EMPLOYEE WHERE AGE < ‘%d‘" % (20)
try: cursor.execute(sql) db.commit() except: db.rollback() # 关闭游标 cursor.close() # 关闭数据库连接 db.close() |
比较简单,不多说
总结:MySQLdb的语法还是比较简单的,步骤也很单一,除了SQL不同之外,整体框架大体上没有发生太大的改变。还是那句话,SQL是根本,只有掌握好SQL才能执行更为复杂的操作。
其实MySQLdb的语法远不止这些,不过这些就已经够用,如果想深入学习,可以参考官方网站http://dev.mysql.com/doc/connector-python/en/
参考资料:http://www.runoob.com/python/python-mysql.html
http://www.cnblogs.com/coser/archive/2012/01/12/2320741.html
标签:
原文地址:http://www.cnblogs.com/lucifer25/p/5782007.html