python入门：MySQL数据库的增删改查

就像Java连接数据库需要JDBC一样,连接数据库的时候,Python也需要相应的支持.

Python2的话,一般用mysqldb；而Python3的时候,就需要使用PyMySQL这个组件了,本文我们选择PyMySQL进行简单讲解.安装的话,使用Pycharm来弄的话非常简单,具体办法可以参照前文,再次不赘述.

• 准备工作

  与数据库连接之前,需要了解数据库的基本信息,这其中包含：

1. 数据库服务器的IP,端口(mysql默认3306)

2. 访问的用户名/暗码

3. 数据库的名称

本文使用的信息如下：localhost(本机)、admin/123456、home.下面请大家跟着这些例子来体会一下python进行数据库的增删改查.至于commit和rollback的概念,这里面有利用到,后续的篇章中会详细讲解.

1.创建用户表(user)

import pymysql# 打开数据库连接db = pymysql.connect("localhost", "admin", "123456", "home")# 使用 cursor() 办法创建一个游标对象 cursorcursor = db.cursor()# 使用 execute() 办法执行 SQL,如果表存在则删除cursor.execute("DROP TABLE IF EXISTS USER")# 使用预处理语句创建表sql = """CREATE TABLE USER (NAME CHAR(20) NOT NULL,AGE INT, SEX CHAR(1) )"""cursor.execute(sql)# 关闭数据库连接db.close()

2.INSERT/UPDATE/DELETE操作

import pymysql# 打开数据库连接db = pymysql.connect("localhost", "admin", "123456", "home")# 使用 cursor() 办法创建一个游标对象 cursorcursor = db.cursor()# SQL 插入语句sql = """INSERT INTO USER(NAME, AGE, SEX) VALUES ('Andy', 20, 'M')""" try:# 执行sql语句cursor.execute(sql)# 提交到数据库执行db.commit()except:# 如果发生错误则回滚db.rollback()# 关闭数据库连接db.close()

注：update和delete操作留给大家去思考.

3.SELECT操作

import pymysql# 打开数据库连接db = pymysql.connect("localhost", "admin", "123456", "home")# 使用 cursor() 办法创建一个游标对象 cursorcursor = db.cursor()# SQL 查询语句sql = "SELECT * FROM USER \ WHERE NAME like 'A%'" try:# 执行SQL语句cursor.execute(sql)# 获取所有记录列表results = cursor.fetchall()for row in results:name = row[0]age = row[1]sex = row[2]# 打印结果print ("name=%s,age=%d,sex=%s" % \(name, age, sex ))except:print ("Error: unable to fetch data")# 关闭数据库连接db.close()