5.1 Pymysql库

本节主题：5.1 Pymysql库

课程讲师：Charlie

观看地址：点我进入

1 本节要点

2 课前准备

2.1 课程所需库

服务器输入

sudo pip3 install pymysql

本地主机输入

pip install pymysql

3 课程内容

3.1 Pymysql

3.1.1 数据查询

使用Navicat在数据库中创建表单，并随意添加一些数据后，我们尝试在数据库查询表单内所有的数据：

import pymysql

# 连接database
conn = pymysql.connect(host='116.62.221.174',user="user1",password="123456",database="jdy_api",charset="utf8")

# 得到一个可以执行SQL语句的光标对象
cursor = conn.cursor()

sql = "SELECT * FROM personinformation"

try:
    # 执行SQL语句
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    print(e)
    conn.rollback()

#获得返回的数据
data = cursor.fetchall()

# 关闭光标对象
cursor.close()

# 关闭数据库连接
conn.close()

print(data)

3.1.2 定义插入数据的函数

import pymysql

 
def insert_into_mysql(a,c,b):

    # 连接database
    conn = pymysql.connect(host='116.62.221.174',user="user1",password="123456",database="jdy_api",charset="utf8")

    # 得到一个可以执行SQL语句的光标对象
    cursor = conn.cursor()

    sql = "insert into personinformation values ('%s','%s','%s')" % (a,b,c)
    print(sql)
    try:
        # 执行SQL语句
        cursor.execute(sql)
        conn.commit()
    except Exception as e:
        print(e)
        conn.rollback()

    #获得返回的数据
    result = cursor.fetchone()

    # 关闭光标对象
    cursor.close()

    # 关闭数据库连接
    conn.close()

    print(result)

3.2 开发思路

import json

request_data = {"data": [{"aaa": 123, "bbb":234}]}
data_ = request_data['data']
data_0 = data_[0]
_id= data_0["_id"]