Python操作MySQL基本环境搭建及增删改查实现

2016-10-13 12:59 1075 0

摘要: 安装Python鉴于上一篇关于Python的文章已经有关于Python安装的介绍了，这里就不花笔墨多说了。安装MySQLMySQL介绍MySQL是一个关系型数据库管理系统，由瑞典MySQL AB 公司开发，目前属于Oracle旗下产品。MySQL是一款 ...

安装Python

鉴于上一篇关于Python的文章已经有关于Python安装的介绍了，这里就不花笔墨多说了。

安装MySQL

MySQL介绍

MySQL是一个关系型数据库管理系统，由瑞典MySQL AB 公司开发，目前属于Oracle旗下产品。MySQL是一款优秀的开源产品，正是由于其开源性使其逐渐成为现今商业数据库的主流选择之一。

具体安装流程（Win版）

由于博主目前只在Win平台测试，所以这里只介绍Win版的安装流程。

首先下载mysql-5.6.33-winx64（下载地址）,mysql5.7以上版本在安装的过程中会出现一些问题，所以本人选择了5.6版本。安装的过程一直下一步就行；
然后配置系统环境变量。找到“系统-高级系统设置-环境变量”，在Path的最后加上数据库内的bin文件夹目录如“;D:\mysql-5.6.33-winx64\bin”（注意一定要加分号）；
到根目录下打开my-default.ini文件，将“# basedir = …… # datadir = ……”修改为“basedir = D:\mysql-5.6.33-winx64 datadir = D:\mysql-5.6.33-winx64\data”；
打开cmd（一定要管理员权限！）转到“D:\mysql-5.6.33-winx64\bin”目录，输入“mysqld -install”。等到出现“Service successfully installed.”之后就继续输入“net start mysql”。这样mysql就启动了。

使用pymysql包

下面就是正是使用Python来操作mysql的第一步了。打开cmd，直接输入pip install PyMySql，等它安装完毕就OK了，就是这么简单。

利用Mysql WorkBench可视化数据库

对于数据库，如果用命令行的话有时可能会比较麻烦，这时可以考虑使用GUI界面代替CLI。官方提供了MySql WorkBench（点击下载）。使用WorkBench我们可以轻易地查看本地数据库的一些状态、数据库的操作等等，具体使用不多说了，这里只说一下新建数据库和数据表。点击图标栏第四个图标（create a new schema in the connected server），设置好相关参数就可以创建数据库。在Schema工具栏中，选择你要添加表的数据库，右键Tables选择“Create Table”，写好字段和数据类型，即可完成数据表的创建。

实现基本的数据库的增删改查

下面开始写代码。

具体代码如下：

import pymysql
def connDB():
    #连接数据库
    conn=pymysql.connect(host='localhost',user='root',passwd='',db='first')
    cur=conn.cursor()
    return (conn,cur)

def exeUpdate(conn,cur,sql):
    #更新语句，可执行Update，Insert语句
    sta=cur.execute(sql)
    conn.commit()
    return (sta)

def exeDelete(conn,cur,IDs):
    #删除语句，可批量删除
    for eachID in IDs.split(' '):
        sta=cur.execute('delete from students where Id=%d'%int(eachID))
    conn.commit()
    return (sta)

def exeQuery(cur,sql):
    #查询语句
    cur.execute(sql)
    result = cur.fetchone()
    return (result)

def connClose(conn,cur):
    #关闭所有连接
    cur.close()
    conn.close()

conn = connDB()[0]
cur = connDB()[1]
exeUpdate(conn,cur,"INSERT INTO first_note (idfirst_note, note_title , note_content ) VALUES (0,'Title','This is the content');")
print(exeQuery(cur,"SELECT note_title ,note_content FROM first_note;"))
connClose()

这里有几个地方说明一下：

创建：我们通过 conn=pymysql.connect(host='localhost',user='root',passwd='',db='first') 方法获取一个connection对象。connection对象类似于数据操作过程中的管道，我们数据操作都是在connection之上进行的。（有过网络编程经验的朋友一下就理解了），然后再通过 cur=conn.cursor() 获取游标，游标对象则类似于管道中的载体，进行数据的传送。有了cur我们才能直接操作数据库。

增删查改：代码中我们把增删查改分成四个函数，事实上这四个操作都是调用cur.execute()进行的，也就是直接使用SQL语言进行数据库操作。如果有必要我们应该对它们再次封装便于使用。具体代码看上面。

关闭：最后我们使用 cur.close() conn.close() 分别关闭游标和connection对象，这样就结束了一次数据操作。