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

一、说明

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

二、安装mysql 库

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

pip install PyMySQL

看到上述截图时，恭喜你mysql库安装成功。

三、mysql连接

1. 导包

 import pymysql.cursors

2. 连接

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)

3. 批量插入

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