zdppy_mcrud操作MySQL数据库教程

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)