salary real);‘’')
db.commit()
db.commit()
return True
except:
db.rollback()
return False
if createTable(db):
print(‘create table success’)
else:
print(‘create table failed’)
使用navicat工具查看：
[](()面试题二 之 向MySQL表中插入数据： coding=utf-8 author_ = 孤寒者from pymysql import *
def connectDB():
‘’’
连接本地MySQL数据库，指定连接的库为test库。
:return:
‘’’
db = connect(host=‘localhost’, user=‘root’, password=‘123456’, port=3306, db=‘test’)
return db
db = connectDB()
print(type(db))
def insertRecords(db):
cursor = db.cursor()
try:
cursor.execute(“delete from persons”)
cursor.execute(‘’’
insert into persons(id,name,age,address,salary)
values(1, ‘GuHanZhe’, 18, ‘China’, 9999)
‘’')
cursor.execute(‘’’
insert into persons(id,name,age,address,salary)
values(2, ‘XiaoZhang’, 55, ‘China’, 9)
‘’')
db.commit()
return True
except Exception as e:
print(e)
db.rollback()
return False
if insertRecords(db):
print(“成功插入记录”)
else:
print(“插入记录失败”)
使用navicat工具查看：
[](()面试题三 之 查询MySQL中的数据： coding=utf-8 author_ = 孤寒者from pymysql import *
def connectDB():
‘’’
《一线大厂Java面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》无偿开源 威信搜索公众号【编程进阶路】
连接本地MySQL数据库，指定连接的库为test库。
:return:
‘’’
db = connect(host=‘localhost’, user=‘root’, password=‘123456’, port=3306, db=‘test’)
return db
db = connectDB()
def selectRecords(db):
cursor = db.cursor()
sql = ‘select name,age,salary from persons order by age desc’
cursor.execute(sql)
results = cursor.fetchall()
print(results)
print(type(results)) # 打印发现是元组类型
selectRecords(db)
db.close()
-
我们发现查询数据输出类型是元组类型，如果我们想要将字段名和查询出的数据一一对应该怎么做呢？
-
这里就需要用到两个很常用的函数dict()和zip()，如下：
import json
from pymysql import *
def connectDB():
‘’’
连接本地MySQL数据库，指定连接的库为test库。
:return:
‘’’
db = connect(host=‘localhost’, user=‘root’, password=‘123456’, port=3306, db=‘test’)
return db
db = connectDB()
