使用Python实现MySQL数据库的查询，有录播直播私教课视频教程

查询所有

from mysql.db_object import Database

db = Database(host="localhost",
              password="zhangdapeng520",
              database="zdppy_mysql_demo")

# 创建表
table = "test_user"
sql = """
create table test_user(
    id bigint primary key auto_increment,
    name varchar(255)
);
"""
db.delete_table(table)
db.execute(sql)

# 查看所有表
print(db.get_all_table())

# 批量插入数据
db.add(table, ["name"], ["张三"])
db.add(table, ["name"], ["李四"])
db.add(table, ["name"], ["王五"])

# 根据id获取
print(db.get_all(table))

# 删除表
db.delete_table(table)

# 查看所有表
print(db.get_all_table())

根据ID查询

from mysql.db_object import Database

db = Database(host="localhost",
              password="zhangdapeng520",
              database="zdppy_mysql_demo")

# 创建表
table = "test_user"
sql = """
create table test_user(
    id bigint primary key auto_increment,
    name varchar(255)
);
"""
db.delete_table(table)
db.execute(sql)

# 查看所有表
print(db.get_all_table())

# 批量插入数据
db.add(table, ["name"], ["张三"])
db.add(table, ["name"], ["李四"])
db.add(table, ["name"], ["王五"])

# 根据id获取
print(db.get_by_id(table, 1))

# 删除表
db.delete_table(table)

# 查看所有表
print(db.get_all_table())

根据ID列表查询

from mysql.db_object import Database

db = Database(host="localhost",
              password="zhangdapeng520",
              database="zdppy_mysql_demo")

# 创建表
table = "test_user"
sql = """
create table test_user(
    id bigint primary key auto_increment,
    name varchar(255)
);
"""
db.delete_table(table)
db.execute(sql)

# 查看所有表
print(db.get_all_table())

# 批量插入数据
db.add(table, ["name"], ["张三"])
db.add(table, ["name"], ["李四"])
db.add(table, ["name"], ["王五"])

# 根据id获取
print(db.get_by_ids(table, [1, 2, 3]))

# 删除表
db.delete_table(table)

# 查看所有表
print(db.get_all_table())

去重查询

from mysql.db_object import Database

db = Database(password="zhangdapeng520", database="zdppy_mysql_demo")

# 创建表
table = "test_user"
sql = """
create table test_user(
    id int primary key auto_increment,
    name varchar(36)
)
"""
db.delete_table(table)
db.execute(sql)

# 插入测试数据
db.add(table, ["name"], ["a"])
db.add(table, ["name"], ["a"])
db.add(table, ["name"], ["a"])
db.add(table, ["name"], ["b"])
db.add(table, ["name"], ["b"])
db.add(table, ["name"], ["c"])

# 查询数据
print(db.get_all(table))

# 去重查询name
print(db.get_all_distinct(table, "name"))