利用python建立与数据库的连接

2020-12-2 碧玉叶 网络新天地

import pymysql
#封装的增删改
def change_data(sql1,host='localhost',user='root',
                pwd='123456',database='milor'):
    '''
    :param sql1: 传入的sql语句
    :param host: 数据库host,localhost为本地服务器
    :param user: 用户名
    :param pwd: 密码
    :param database: 连接的数据库
    :return: 没有返回值
    '''
    # con = 将服务器地址,用户名,密码传给connect方法 建立连接
    con = pymysql.connect(host,user,pwd)
    # cur: 创建数据库游标对象
    cur = con.cursor()
    # 拼接字符串sql
    sql = 'use '+database
    # 执行进入数据库sql
    cur.execute(sql)
    # 执行传入的sql1命令
    cur.execute(sql1) # 返回值是受影响的行数
    # 提交数据
    st = con.commit()
    print(st)
    # 关闭游标连接
    cur.close()
    # 关闭数据库连接
    con.close()

#封装的查询 注释和上面一样,多了个返回查询结果(记得接收)
def select_data(sql1,host='localhost',user='root',
                pwd='123456',database='milor'):
    con = pymysql.connect(host,user,pwd)
    cur = con.cursor()
    sql = 'use '+database
    cur.execute(sql)
    cur.execute(sql1) # 查询之后会将结果 封装到游标中
    data = cur.fetchall() # 取出所有数据
    con.commit()
    cur.close()
    con.close()
    return data  #将数据返回给调用者



记录一哈,方便以后自己直接复制使用

发表评论:

Powered by emlog 用文字记录生活的点滴