欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

python 对mysql新增,修改,删除操作

程序员文章站 2023-11-26 09:10:04
网上关于操作mysql的案例有很多,大多数只介绍了使用如何执行sql操作;但对于最开始的安装都没介绍,结果导致很多开发小白,执行的时候经常碰到导包失败,本篇将会详细介绍,以代码精炼的方式给大家展示。...

一、说明

网上关于操作mysql的案例有很多,大多数只介绍了使用如何执行sql操作;但对于最开始的安装都没介绍,结果导致很多开发小白,执行的时候经常碰到导包失败,本篇将会详细介绍,以代码精炼的方式给大家展示。

二、安装mysql 库

在windons系统中,打开dos窗口,输入一下命令

pip install PyMySQL

python 对mysql新增,修改,删除操作
看到上述截图时,恭喜你mysql库安装成功。

三、mysql连接

  1. 导包
 import pymysql.cursors
  1. 连接
connection = pymysql.connect(host='localhost', port=3306, user='root', passwd='root', database='bootdo', charset='utf8')

四、查询

def get(sql):
    try:
        cursor = connection.cursor()
        cursor.execute(sql)
        results = cursor.fetchall()
        return results
    except Exception:
        print("查询失败")
    finally:
        cursor.close()  # 关闭游标连接
        connection.close()  # 关闭数据库连接


result = get('select * from t_csdn')
print(result)

打印结果

((1, '百度1', 'www.baidu.com'), (2, '新浪', 'www.sina.com'))

五、修改

def update(sql):
    try:
        cursor = connection.cursor()
        cursor.execute(sql)
        connection.commit()
    except Exception:
        print("修改失败")
    finally:
        cursor.close()  # 关闭游标连接
        connection.close()  # 关闭数据库连接


update("update t_csdn set title='百度' where id = 1")

六、插入

  1. 单个插入
 def add(sql, val):
    try:
        cursor = connection.cursor()
        cursor.execute(sql, val)
        connection.commit()
        print(cursor.rowcount)
    except Exception:
        print("插入失败")
    finally:
        cursor.close()  # 关闭游标连接
        connection.close()  # 关闭数据库连接


val = ('百度', 'www.baidu.com')
sql = 'insert into t_csdn (title, url) values (%s, %s)'
add(sql, val)
  1. 批量插入
def add(sql, val):
    try:
        cursor = connection.cursor()
        cursor.executemany(sql, val)
        connection.commit()
        print(cursor.rowcount)
    except Exception:
        print("插入失败")
    finally:
        cursor.close()  # 关闭游标连接
        connection.close()  # 关闭数据库连接


val = [('百度', 'www.baidu.com'), ('新浪', 'www.sina.com')]
sql = 'insert into t_csdn (title, url) values (%s, %s)'
add(sql, val)

七、删除

def delete(sql):
    try:
        cursor = connection.cursor()
        cursor.execute(sql)
        connection.commit()
    except Exception:
        print("删除失败")
    finally:
        cursor.close()  # 关闭游标连接
        connection.close()  # 关闭数据库连接

delete('delete from t_csdn')

总结,整个mysql的操作,用到了execute方法,对数据操作的需要commit否则无效,查询采用fetchall方法,返回元组

本文地址:https://blog.csdn.net/jun118166/article/details/107100849