pymysql的使用

一: 安装pymysql

pip3 install pymysql

二: 查询操做

import pymysql

# 打开数据库链接
db = pymysql.connect(host='localhost', user='root', password='123456', db='userinfo', port=3306)

# 使用cursor()方法获取操做游标
cur = db.cursor()

#1, 查询操做
# 编写sql,查询语句 s_info 对应的表名
sql = "select * from s_info"
try:
    cur.execute(sql)    # 执行sql语句

    # results = cur.fetchall()

    # 获取一行
    # result_one = cur.fetchone()
    # print(result_one)

    # 获取多个
    result_many = cur.fetchmany(3)
    print(result_many)
    # print(results) # 返回全部的数据一元组套元组的形式
    # print("id", "name", "pwd")
    # #遍历结果
    # for row in results:
    #     id = row[0]
    #     name = row[1]
    #     password = row[2]
    #     print(id, name, password)
except Exception as e:
    raise e
finally:
    db.close()

查询

三: 插入操做

import pymysql

#2 插入操做
db = pymysql.connect(host='localhost', user='root', password='123456', port=3306, db='userinfo')

# 使用游标
cur = db.cursor()

sql_insert =  "insert into s_info(name, pwd) values('egon', '456')"

try:
    cur.execute(sql_insert)

    db.commit()
except Exception as e:
    db.rollback()
    raise e
finally:
    cur.close()
    db.close()

插入数据

四: 修改操做

import pymysql

# 获取数据库
db = pymysql.connect(host='localhost', user='root', password='123456', db='userinfo', port=3306)

# 获取游标
cur = db.cursor()

# sql改语句
sql = "update s_info set name=%s where id=7"
try:
    cur.execute(sql, "egon")
    db.commit()
except Exception as e:
    raise e
finally:
    cur.close()
    db.close()

改操做

五: 删除操做

import pymysql

db = pymysql.connect(host='localhost', user='root', password='123456', port=3306, db='userinfo')

cur = db.cursor()

sql = "delete from s_info where id=1"

try:
    cur.execute(sql)
    db.commit()
except Exception as e:
    raise e
finally:
    cur.close()
    db.close()

View Code