records库操作SQL查询MySQL数据库

 import records
 # root:数据库用户名
 # root:数据密码
 # localhost:数据库地址
 # 3306:数据库端口号
 # mytest:数据库名称
 db = records.Database('mysql://root:root@localhost:3306/mytest?charset=utf8')

# 查询数据
rows = db.query("select * from user")
for r in rows:
    print(r.id, r.mobile, r.passwd)

# 获取第一条数据
print(rows.first())
# 以字典形式获取第一个
print(rows.first(as_dict=True))
# 查询唯一的一个
print(rows.one())
# 获取所有数据
print("all方法获取所有数据:", rows.all())
# 转为json
# print(rows.as_dict())
print(rows.all(as_dict=True))
# 排序字典
print(rows.first(as_ordereddict=True))
# 导出为具体格式，支持： csv、yaml、json、xls、df（DataFrame）
print(rows.export("yaml"))
# 转为表格形式
print(rows.dataset)
# 数据导出到excel文件
with open("user.xlsx","wb") as f:
    f.write(rows.export("xlsx"))

# 支持variable定义变量，通过参数传入完成动态传值，在需要动态加载数据的时候非常有用:
user = {"mobile": "", "passwd": ""}
sql = 'insert into user(mobile,passwd) values (:mobile,:passwd)'
res = db.query(sql, **user)
# 获取返回结果
# print(res.pending)
if res.pending:
    print("插入成功")
else:
    print("插入失败")

users = [
    {"mobile": "", "passwd": ""},
    {"mobile": "", "passwd": ""},
    {"mobile": "", "passwd": ""}
]
sql = 'insert into user(mobile,passwd) values (:mobile,:passwd)'
res = db.bulk_query(sql, users)