1.新增数据库表：
1 我们可以使用execute()方法来为数据库创建表，如下所示创建表EMPLOYEE： 2 3 程序实现： 4 5 import pymysql 6 7 8 9 # 打开数据库连接10 11 db = pymysql.connect(host="localhost",port=3306,user="root", password="root",db= "test",charset='utf8')12 13 14 15 # 使用cursor()方法获取操作游标16 17 cursor = db.cursor()18 19 20 21 # 创建数据表SQL语句22 23 sql = """CREATE TABLE EMPLOYEE (24 25 FIRST_NAME CHAR(20) NOT NULL,26 27 LAST_NAME CHAR(20),28 29 AGE INT,30 31 SEX CHAR(1),32 33 INCOME FLOAT )"""34 35 try:36 37 # 执行sql语句38 39 cursor.execute(sql)40 41 # 提交到数据库执行42 43 db.commit()44 45 except:46 47 # 如果发生错误则回滚48 49 db.rollback()50 51 52 53 # 关闭数据库连接54 55 db.close()
2.给表中增加数据：
1 方式一： 2 3 import pymysql 4 5 6 7 # 打开数据库连接（ip/数据库用户名/登录密码/数据库名） 8 9 db = pymysql.connect(host="localhost",port=3306,user="root", password="root",db= "test",charset='utf8')10 11 # 使用 cursor() 方法创建一个游标对象 cursor12 13 cursor = db.cursor()14 15 16 17 # SQL 插入语句18 19 sql = """INSERT INTO EMPLOYEE(FIRST_NAME,20 21 LAST_NAME, AGE, SEX, INCOME)22 23 VALUES ('xiaoneng', 'xn', 20, 'M', 3000)"""24 25 try:26 27 # 执行sql语句28 29 cursor.execute(sql)30 31 # 提交到数据库执行32 33 db.commit()34 35 except:36 37 # Rollback in case there is any error38 39 db.rollback()40 41 42 43 # 关闭数据库连接44 45 db.close() 1 方式二： 2 3 import pymysql 4 5 6 7 # 打开数据库连接（ip/数据库用户名/登录密码/数据库名） 8 9 db = pymysql.connect(host="localhost",port=3306,user="root", password="root",db= "test",charset='utf8' )10 11 # 使用 cursor() 方法创建一个游标对象 cursor12 13 cursor = db.cursor()14 15 16 17 # SQL 插入语句18 19 sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \20 21 LAST_NAME, AGE, SEX, INCOME) \22 23 VALUES ('%s', '%s', '%d', '%c', '%d' )" % \24 25 ('李四', '小四', 22, 'M', 15000)26 27 28 29 try:30 31 # 执行sql语句32 33 cursor.execute(sql)34 35 # 提交到数据库执行36 37 db.commit()38 39 except:40 41 # Rollback in case there is any error42 43 db.rollback()44 45 46 47 # 关闭数据库连接48 49 db.close() 3.查询数据：
Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall():接收全部的返回结果行.
rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。
1 查询EMPLOYEE表中salary（工资）字段大于1000的所有数据： 2 3 import pymysql 4 5 6 7 # 打开数据库连接 8 9 db = pymysql.connect(host="localhost",port=3306,user="root", password="root",db= "test",charset='utf8' )10 11 12 13 # 使用cursor()方法获取操作游标14 15 cursor = db.cursor()16 17 18 19 # SQL 查询语句20 21 sql = "SELECT * FROM EMPLOYEE \22 23 WHERE INCOME > '%d'" % (1000)24 25 try:26 27 # 执行SQL语句28 29 cursor.execute(sql)30 31 # 获取所有记录列表32 33 results = cursor.fetchall()34 35 for row in results:36 37 fname = row[0]38 39 lname = row[1]40 41 age = row[2]42 43 sex = row[3]44 45 income = row[4]46 47 # 打印结果48 49 print("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \50 51 (fname, lname, age, sex, income ))52 53 except:54 55 print("Error: unable to fecth data")56 57 58 59 # 关闭数据库连接60 61 db.close() 4.更新操作：
更新操作用于更新数据表的的数据，以下实例将 EMPLOYEE 表中的FIRST_NAME = '李四'，INCOME字段的值15000改为25000。
1 import pymysql 2 3 4 5 # 打开数据库连接 6 7 db = pymysql.connect(host="localhost",port=3306,user="root", password="root",db= "test",charset='utf8' ) 8 9 10 11 # 使用cursor()方法获取操作游标12 13 cursor = db.cursor()14 15 16 17 # SQL 更新语句18 19 sql = "UPDATE EMPLOYEE SET INCOME = 25000 WHERE FIRST_NAME = '李四'"20 21 try:22 23 # 执行SQL语句24 25 cursor.execute(sql)26 27 # 提交到数据库执行28 29 db.commit()30 31 except:32 33 # 发生错误时回滚34 35 db.rollback()36 37 38 39 # 关闭数据库连接40 41 db.close()
5.删除操作：
删除操作用于删除数据表中的数据，以下实例演示了删除数据表 EMPLOYEE 中 AGE 大于 20 的所有数据：
1 import pymysql 2 3 4 5 # 打开数据库连接 6 7 db = pymysql.connect(host="localhost",port=3306,user="root", password="root",db= "test",charset='utf8') 8 9 10 11 # 使用cursor()方法获取操作游标12 13 cursor = db.cursor()14 15 16 17 # SQL 删除语句18 19 sql = "DELETE FROM EMPLOYEE WHERE FIRST_NAME = '李四'"20 21 22 23 try:24 25 # 执行SQL语句26 27 cursor.execute(sql)28 29 # 提交到数据库执行30 31 db.commit()32 33 except:34 35 # 发生错误时回滚36 37 db.rollback()38 39 40 41 # 关闭数据库连接42 43 db.close()