安装pymysql
|
1 |
pip3 install pymysql |
db.py文件
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 |
import pymysql # 打开数据库连接 def get_conn(): return pymysql.connect(host="localhost",user="root",password="root",database="bot",charset="utf8") def sql_read(sql): db=get_conn() try: # 使用 cursor() 方法创建一个游标对象 cursor # 使用pymysql.cursors.DictCursor方法返回字典 cursor = db.cursor(pymysql.cursors.DictCursor) # 使用 execute() 方法执行 SQL 查询 cursor.execute(sql) # 使用 fetchone() 方法获取单条数据. # 使用 fetchall() 方法获取全部数据. #data = cursor.fetchone() return cursor.fetchall() finally: #关闭链接 db.close() def sql_write(sql): db=get_conn() try: cursor = db.cursor() cursor.execute(sql) #写操作需要commit才能生效 db.commit() finally: db.close() |
引用db.py文件进行测试
|
1 2 3 4 5 |
import db #db.sql_write("update test set data='修改后的数据' where id=43") datas=db.sql_read("select * from test") for row in datas: print(row['id'],row['name']) |
近期评论