1、数据库操作

1.1准备工作:

1、安装一个mysql数据库软件
2、创建一个数据库，test
3、在python的环境安装一个模块：

MySQLdb

1.2 安装mysql的连接包

第一种：工具安装
Python3.x版本：Pip install mysqlclient
Python2.x 版本：pip install mysql-python

错误
在win7-64bit的环境下会有错误：unable to find vcvarsall.bat
解决方案：
基本等于误解
第二种：手动安装
（1）先wheel
需要下载安装包：
http://www.lfd.uci.edu/~gohlke/pythonlibs/
根据对应的python版本下载安装包
Pip instal xxxxxxx.whl
（2）安装mysqlclient
下载地址：
http://www.lfd.uci.edu/~gohlke/pythonlibs/

下载后的内容：

选择版本：
在网上有很多安装mysql的操作方法，简单概述就是：
Python2.x 安装mysql-python （如果是Python2.x就安装mysql-python）
Python3.x 安装mysqlclient （如果是Python3.x就安装mysqlclient）
安装步骤：

1.2.1 首先要在cmd下安装wheel包：

D:\baiduDownload\software\python>pip install wheel

1.2.2 接着进入*.whl安装包所在的目录，用cd命令

D:\baiduDownload\software\python>cd /D D:/baiduDownload/software/python

1.2.3 使用 pip install *.whl安装mysqlclient

D:\baiduDownload\software\python>pip install mysqlclient

2、编写python操作数据的代码

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取一条数据库。
data = cursor.fetchone()
print("Database version : %s " % data)
# 关闭数据库连接
db.close()

运行结果：

3、python创建数据库表

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")
#使用cursor()方法获取操作游标
cursor = db.cursor()
# 如果数据表已经存在使用 execute() 方法删除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 创建数据表SQL语句
sql = """CREATE TABLE EMPLOYEE (FIRST_NAME  CHAR(20) NOT NULL,LAST_NAME  CHAR(20),AGE INT,SEX CHAR(1),INCOME FLOAT)"""
cursor.execute(sql)
# 关闭数据库连接
db.close()

4、插入数据

import MySQLdb
#打开数据库连接
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,LAST_NAME, AGE, SEX, INCOME)VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:# 执行sql语句cursor.execute(sql)# 提交到数据库执行db.commit()
except:# Rollback in case there is any errordb.rollback()
# 关闭数据库连接
db.close()

上面的代码可以写成：

import MySQLdb
#打开数据连接
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \LAST_NAME, AGE, SEX, INCOME) \VALUES ('%s', '%s', '%d', '%c', '%d' )" % \('Mac', 'Mohan', 20, 'M', 2000)
try:# 执行sql语句cursor.execute(sql)# 提交到数据库执行db.commit()
except:# 发生错误时回滚db.rollback()
# 关闭数据库连接
db.close()

5、查询数据

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。
fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
fetchall():接收全部的返回结果行.
rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

import MySQLdb
#打开数据库连接
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \WHERE INCOME > '%d'" % (1000)
try:# 执行SQL语句cursor.execute(sql)# 获取所有记录列表results = cursor.fetchall()for row in results:fname = row[0]lname = row[1]age = row[2]sex = row[3]income = row[4]# 打印结果print("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \(fname, lname, age, sex, income ))
except:print("Error: unable to fecth data")
# 关闭数据库连接
db.close()

执行后的结果:

6 更新数据库内容

import MySQLdb
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:# 执行SQL语句cursor.execute(sql)# 提交到数据库执行db.commit()
except:# 发生错误时回滚db.rollback()
# 关闭数据库连接
db.close()

执行后前的结果是：

更新后的结果：

7 数据库删除操作

删除作用于删除数据表中的数据
删除数据表EMPLOYEE中AGE大于20的所有数据：

import MySQLdb
# 打开数据库连接
db = MySQLdb.connect("192.168.106.100","root","123456","bigdata")
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20)
try:# 执行SQL语句cursor.execute(sql)# 提交修改db.commit()
except:# 发生错误时回滚db.rollback()
# 关闭连接
db.close()

数据删除前的操作：

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！