test_sql.py 484 B

123456789101112131415
  1. # -*- coding:utf-8 -*-
  2. from config import SqlEngine
  3. from config.models import DbKafka
  4. ka = DbKafka(name="hi", json_str="hello")
  5. # print(SqlEngine.add(ka))
  6. # print(SqlEngine.add_all([ka]))
  7. # print(SqlEngine.query_first(DbKafka))
  8. # print(SqlEngine.update(DbKafka, [DbKafka.name == 'hi'], {DbKafka.name: "hi2"}))
  9. # print(SqlEngine.query_all(DbKafka))
  10. # print(SqlEngine.query_all(DbKafka, [], [DbKafka.id.asc()]))
  11. print(SqlEngine.query_page(DbKafka, [], [DbKafka.name.desc()], 0, 3))