# -*- coding:utf-8 -*-

from config import SqlEngine
from config.models import DbKafka

ka = DbKafka(name="hi", json_str="hello")
# print(SqlEngine.add(ka))
# print(SqlEngine.add_all([ka]))
# print(SqlEngine.query_first(DbKafka))
# print(SqlEngine.update(DbKafka, [DbKafka.name == 'hi'], {DbKafka.name: "hi2"}))


# print(SqlEngine.query_all(DbKafka))
# print(SqlEngine.query_all(DbKafka, [], [DbKafka.id.asc()]))
print(SqlEngine.query_page(DbKafka, [], [DbKafka.name.desc()], 0, 3))