一、说明
网上关于操作mysql的案例有很多,大多数只介绍了使用如何执行sql操作;但对于最开始的安装都没介绍,结果导致很多开发小白,执行的时候经常碰到导包失败,本篇将会详细介绍,以代码精炼的方式给大家展示。
二、安装mysql 库
在windons系统中,打开dos窗口,输入一下命令
pip install PyMySQL
看到上述截图时,恭喜你mysql库安装成功。
三、mysql连接
- 导包
import pymysql.cursors
- 连接
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")
六、插入
- 单个插入
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)
- 批量插入
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