01 创建数据库连接
.env配置文件
ZDPPY_MCRUD_HOST=192.168.234.130
ZDPPY_MCRUD_PORT=3306
ZDPPY_MCRUD_USERNAME=root
ZDPPY_MCRUD_PASSWORD=zhangdapeng520
ZDPPY_MCRUD_DATABASE=zdppy_mcrud_demo
连接到MySQL数据库:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()
print(db.get_all_database())
02 创建表格和删除表格
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表格
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)
print(db.get_all_table())# 删除表
db.delete_table(table)
print(db.get_all_table())
03 新增数据
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)
print(db.get_all_table())# 新增数据
db.add("user",["id", "name", "age"],[1, "张强", 18],
)
print(db.get_all("user"))# 删除表
db.delete_table(table)
print(db.get_all_table())
04 批量新增数集
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)
print(db.get_all_table())# 新增数据
# 同时新增张三、李四、王五三个用户
db.add_many(table,["id", "name", "age"],[[1, "张三", 18],[2, "李四", 24],[3, "王五", 35],],
)
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
print(db.get_all_table())
05 练习
用户表:ID、name姓名,age年龄。
生成100个随机的用户,并查询user表中所有的用户信息。
核心代码:
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.age(),])
db.add_many(table,["id", "name", "age"],data,
)
users = db.get_all(table, limit=100)
print(len(users))
for user in users:print(user)
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.age(),])
db.add_many(table,["id", "name", "age"],data,
)
users = db.get_all(table, limit=100)
print(len(users))
for user in users:print(user)# 删除表
db.delete_table(table)
06 修改数据
核心代码:
db.update(table,1,["name"],["张三"],
)
完整代码:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
# 同时新增张三、李四、王五三个用户
db.add_many(table,["id", "name", "age"],[[1, "张三123", 18],[2, "李四", 24],[3, "王五", 35],],
)# 查询
users = db.get_all(table)
for user in users:print(user)# 更新
db.update(table,1,["name"],["张三"],
)# 查询
print("-----------------")
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
07 练习
用户表:ID、name姓名,age年龄。
新增用户:1、张强,22
查询所有用户
修改用户:将ID为1的用户的年龄改为18岁
查询所有用户
核心代码:
db.update(table,4,["age"],[18],
)
完整代码:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
db.add_many(table,["id", "name", "age"],[[1, "张三123", 18],[2, "李四", 24],[3, "王五", 35],[4, "张强", 35],],
)# 查询
users = db.get_all(table)
for user in users:print(user)# 更新
db.update(table,4,["age"],[18],
)# 查询
print("-----------------")
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
08 删除数据
核心代码:
db.delete(table,1,
)
完整代码:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
# 同时新增张三、李四、王五三个用户
db.add_many(table,["id", "name", "age"],[[1, "张三123", 18],[2, "李四", 24],[3, "王五", 35],],
)# 查询
users = db.get_all(table)
for user in users:print(user)# 删除
db.delete(table,1,
)# 查询
print("-----------------")
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
09 练习
用户表:ID、name姓名,age年龄。
新增用户:1、张强,22
新增用户:2、李四,24
新增用户:3、王五,35
查询所有用户
删除用户:将ID为3的用户删除
删除用户:将ID为2的用户删除
查询所有用户
核心代码:
db.add_many(table,["id", "name", "age"],[[1, "张强", 22],[2, "李四", 24],[3, "王五", 35],],
)db.delete(table,3,
)
db.delete(table,2,
)
完整代码:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
# 同时新增张三、李四、王五三个用户
db.add_many(table,["id", "name", "age"],[[1, "张强", 22],[2, "李四", 24],[3, "王五", 35],],
)# 查询
users = db.get_all(table)
for user in users:print(user)# 删除
db.delete(table,3,
)
db.delete(table,2,
)# 查询
print("-----------------")
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
10 根据ID查询数据
核心代码:
user = db.get_by_id(table, 1)
完整代码:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
db.add_many(table,["id", "name", "age"],[[1, "张三", 18],[2, "李四", 24],[3, "王五", 35],],
)# 查询
user = db.get_by_id(table, 1)
print(user)# 删除表
db.delete_table(table)
11 练习
用户表:ID、name姓名,age年龄。
生成100个随机的用户,并查询user表中所有的用户信息。
查询ID为33用户的用户名和年龄是什么,以及他的添加时间是什么时候。
核心代码:
# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.age(),])
db.add_many(table,["id", "name", "age"],data,
)# 根据ID查询
user = db.get_by_id(table, 33)
print(user)
print("姓名:", user.get("name"))
print("年龄:", user.get("age"))
print("添加时间:", user.get("add_time"))
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.age(),])
db.add_many(table,["id", "name", "age"],data,
)# 根据ID查询
user = db.get_by_id(table, 33)
print(user)
print("姓名:", user.get("name"))
print("年龄:", user.get("age"))
print("添加时间:", user.get("add_time"))# 删除表
db.delete_table(table)
12 根据ID列表查询
核心代码:
# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.age(),])
db.add_many(table,["id", "name", "age"],data,
)# 根据ID列表查询
users = db.get_by_ids(table, [33, 66, 99])
for user in users:print(user)print("姓名:", user.get("name"))print("年龄:", user.get("age"))print("添加时间:", user.get("add_time"))print("===============================")
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.age(),])
db.add_many(table,["id", "name", "age"],data,
)# 根据ID列表查询
users = db.get_by_ids(table, [33, 66, 99])
for user in users:print(user)print("姓名:", user.get("name"))print("年龄:", user.get("age"))print("添加时间:", user.get("add_time"))print("===============================")# 删除表
db.delete_table(table)
13 练习
用户表:ID、name姓名,gender性别,age年龄。
生成100个随机的用户,并查询user表中所有的用户信息。
查询ID为1,2,100的用户的用户名,性别和年龄是什么。
核心代码:
# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 根据ID列表查询
users = db.get_by_ids(table, [1, 2, 100])
for user in users:print(user)print("姓名:", user.get("name"))print("年龄:", user.get("age"))print("性别:", user.get("gender"))print("===============================")
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 根据ID列表查询
users = db.get_by_ids(table, [1, 2, 100])
for user in users:print(user)print("姓名:", user.get("name"))print("年龄:", user.get("age"))print("性别:", user.get("gender"))print("===============================")# 删除表
db.delete_table(table)
14 根据ID列表删除
核心代码:
db.delete_by_ids(table, [1, 2, 100])
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 10):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 根据ID列表删除
db.delete_by_ids(table, [1, 2, 100])# 查询所有
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
15 练习
用户表:ID、name姓名,gender性别,age年龄。
生成100个随机的用户,并查询user表中所有的用户信息。
删除ID小于98的用户信息。
查询所有的用户。
核心代码:
# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 根据ID列表删除
ids = list(range(1, 99))
db.delete_by_ids(table, ids)
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 根据ID列表删除
ids = list(range(1, 99))
db.delete_by_ids(table, ids)# 查询所有
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
16 根据条件删除
假如我现在想要删除姓名是张三的用户,这个时候我们就需要使用delete_by
这样的一个方法,根据条件去删除数据。
核心代码:
db.delete_by(table, {"name": "张三"})
完整代码:
import env
import mcrudenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","age int"
]
db.add_table(table, columns)# 新增数据
db.add_many(table,["id", "name", "age"],[[1, "张三", 18],[2, "李四", 24],[3, "王五", 35],],
)# 删除
db.delete_by(table, {"name": "张三"})# 查询
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
17 练习
用户表:ID、name姓名,gender性别,age年龄。
生成100个随机的用户,并查询user表中所有的用户信息。
删除年龄为33岁的用户信息。
查询所有的用户。
核心代码:
db.delete_by(table, {"age": 33})
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 根据ID列表删除
db.delete_by(table, {"age": 33})# 查询所有
users = db.get_all(table)
for user in users:print(user)# 删除表
db.delete_table(table)
18 根据条件更新
我们想要将年龄是33岁的用户,把他们的年龄,统一改成34岁,这个时候就需要用update_by这个方法。
核心代码:
db.update_by(table, {"age": 33}, ["age"], [34])
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):data.append([str(i),rand.user.name(),rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 更新
db.update_by(table, {"age": 33}, ["age"], [34])# 查询所有
users = db.get_all(table)
for user in users:if user.get("age") == 34:print(user)# 删除表
db.delete_table(table)
19 练习
用户表:ID、name姓名,gender性别,age年龄。
生成100个随机的用户,其中有10个用户叫张三,并查询user表中所有的用户信息。
将姓名是张三的用户,年龄改为33。
查询所有的用户。
核心代码:
# 新增数据
data = []
for i in range(1, 101):name = rand.user.name()if i < 11:name = "张三"data.append([str(i),name,rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 更新
db.update_by(table, {"name": "张三"}, ["age"], [33])# 查询所有
users = db.get_all(table, limit=100)
for user in users:if user.get("name") == "张三":print(user)
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):name = rand.user.name()if i < 11:name = "张三"data.append([str(i),name,rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 更新
db.update_by(table, {"name": "张三"}, ["age"], [33])# 查询所有
users = db.get_all(table, limit=100)
for user in users:if user.get("name") == "张三":print(user)# 删除表
db.delete_table(table)
20 根据条件查询
就比如说上个练习,其中有10个叫张三的用户,那我就想把名字叫张三的查询出来,这个时候就可以用get_by条件查询。
核心代码:
users = db.get_by(table, {"name": "张三"})
for user in users:print(user)
完整代码:
import env
import mcrud
import randenv.load(".env")
db = mcrud.new_env()# 创建表
table = "user"
columns = ["name varchar(255)","gender varchar(6)", # 男 女 保密"age int"
]
db.add_table(table, columns)# 新增数据
data = []
for i in range(1, 101):name = rand.user.name()if i < 11:name = "张三"data.append([str(i),name,rand.user.gender(),rand.user.age(),])
db.add_many(table,["id", "name", "gender", "age"],data,
)# 更新
db.update_by(table, {"name": "张三"}, ["age"], [33])# 查询
users = db.get_by(table, {"name": "张三"})
for user in users:print(user)# 删除表
db.delete_table(table)