Python使用Peewee创建数据库的实现示例

from peewee import *
# test为数据库名，并需安装mysql库
db = MySQLDatabase("test", **{'charset': 'utf8', 'use_unicode': True, 'host': 'localhost', 'user': 'root', 'password': '***'})
# 基类
class BaseModel(Model):
    class Meta:
        database = db
# 表类
class Test(BaseModel):
    id = IntegerField(primary_key=True)
    name = CharField()
    gender = CharField()
    class Meta:
    	# 表名
        table_name = 'Test'
# 创建表
def create_table(table):
    if not table.table_exists():
        table.create_table()
# 删除表
def drop_table(table):
    if table.table_exists():
        table.drop_table()
# 创建一张Test表
create_table(Test)

#  数据库文件路径
db_path = "../database/test.db"
db = SqliteDatabase(db_path)
# PostgreSQL数据库则调用PostgresqlDatabase方法即可
# db = PostgresqlDatabase('test', user='postgres')

t = Tset(name="test", gender="男")
t.save()
# 或者
t = Test()
t.name = "test"
t.gender = "男"
t.save()
# insert() 只插入数据，不返回对象实例
Test.insert(name="test", gender="男").excute()
# insert_many() 插入多行，rows为元组或字典列表，fields为需要插入的字段名list列表
rows = [
	{"name": "test1", "gender": "男"},
	{"name": "test2", "gender": "女"}
]
insert_many(rows, fields=None).execute()
# 或
rows = [
	{"test1", "男"},
	{"test2", "女"}
]
fields = ["name", "gender"]
insert_many(rows, fields=fields).execute()

# where()是条件，execute()是执行
Test.delete().where(Test.name == "test").execute()
# 已经实例化的数据, 使用delete_instance()
t = Tset(name="test", gender="男").save()
t.delete_instance()

# 查询单条数据，多条件用逗号或逻辑运算符隔开，也支持其它比较符（大于小于等）
t = Test.get(Test.name == "test")
# 使用where().get()查询
t = Test.select().where(Test.name == "test").get()
# 查询多条数据
tests = Test.select().where(Test.gender == "男")
# 迭代结果
for t in tests:
    t.save()
# in操作
tests = Test.select().where(Test.gender.in_(["男"]))
# 通过id获取
t = Test.get_by_id(1)
# 尝试获取，不存在则创建，t为实例，created为是否创建
# 参数name为自定义查询条件，dafaults并非查询条件，而是创建字段
t, created = Test.get_or_create(name="test", defaults={"gender": "男"})
# {"gender": "男"}也可以写作dict(gender="男")
# 查询结果转字典dicts
t = Test.select().dicts()
# 只返回元组迭代器tuples
t = Test.select().tuples()

tests = Test.select().where(Test.name.contains("t"))

# 已经实例化的数据，直接修改对象属性并save()
t = Tset(name="test", gender="男").save()
t.gender = "女"
t.save()
# 查询后并用update()更新
t = Tset.update({Tset.gender: "女"}).where(Person.name == "test")
t.execute()
# 查询出对象并修改属性
t = Test.get(Test.name == 'test')
t.gender = "女"
t.save()

# 使用order_by()进行排序，多个字段用分号隔开
tests = Test.select().order_by(Test.id)
# 升序（默认）
tests = Test.select().order_by(Test.id.asc())
tests = Test.select().order_by(+Test.id)
# 降序
tests = Test.select().order_by(Test.id.desc())
tests = Test.select().order_by(-Test.id)
# 使用count()进行统计
n = Test.select().count()
# 执行原生语句
name = "test"
gender = "男"
Test.raw('SELECT * FROM test WHERE name= %s and gender = %s', name, gender)
# fn操作
# 1.Avg 平均值
# 2.Sum 和
# 3.Max 最大值
# 4.Min 最小值
# 5.Count 合计
# 6.Substr 切片
t= Test.select(fn.MAX(Test.id))