[大数据]Python连接MySQL数据库

一、准备模块

python连接SQL数据库首先需要用到 ”pymysql“ 模块，这里使用pip install指令来安装步骤如下：

1、在安装的python的路径下找到Scripts文件夹并打开，在路径上面写成“cmd”后回车

2、进入这个界面后输入pip install pymysql 开始安装

?二、连接数据库

用pymysql模块中的connect连接数据库，同时用cursor()函数创建游标，用于接收返回的结果。

代码：

import pymysql
# ---------连接--------------
connect = pymysql.connect(host='localhost',   # 本地数据库
                          user='root',
                          password='123456',
                          db='sys',
                          charset='utf8') #服务器名,账户,密码，数据库名称
cur = connect.cursor()
print(cur)

注：user与password是你数据库的用户名与密码，db为数据库名称没有可不填。

这里返回了一个游标实例对象，说明已经成功了。

三、对数据库进行操作

前面连接完成后就可以使用cur.execute()函数对数据库进行一个操作啦

下面附上几个案例：

# --------------------创建表-----------------
try:
    create_sqli = "create table sys (id int, name varchar(30),phone int);"
    cur.execute(create_sqli)
except Exception as e:
    print("创建数据表失败:", e)
else:
    print("创建数据表成功;")

# ---------------插入---------
try:
    insert_sqli = "insert into sys values(001, 'xiaoming',123456789);"
    cur.execute(insert_sqli)
except Exception as e:
    print("插入数据失败:", e)
else:
    # 如果是插入数据， 一定要提交数据， 不然数据库中找不到要插入的数据;
    connect.commit()
    print("插入数据成功;")

运行成功后就可以在电脑上的数据库中查找到相应的变化啦，最后记得关闭数据库的连接

#  ---------------------关闭数据库
cur.close()  # 关闭游标
connect.close()  # 关闭数据库连接

完整代码：

import pymysql
# ---------连接--------------
connect = pymysql.connect(host='localhost',
                          user='root',
                          password='123456',
                          db='sys',
                          charset='utf8') #服务器名,账户,密码,数据库名
cur = connect.cursor()

# --------------------创建表-----------------
try:
    create_sqli = "create table sys (id int, name varchar(30),phone int);"
    cur.execute(create_sqli)
except Exception as e:
    print("创建数据表失败:", e)
else:
    print("创建数据表成功;")

# ---------------插入---------
try:
    insert_sqli = "insert into sys values(001, 'xiaoming',123456789);"
    cur.execute(insert_sqli)
except Exception as e:
    print("插入数据失败:", e)
else:
    # 如果是插入数据， 一定要提交数据， 不然数据库中找不到要插入的数据;
    connect.commit()
    print("插入数据成功;")


#  ---------------------关闭数据库
cur.close()  # 关闭游标
connect.close()  # 关闭数据库连接