7
peewee.OperationalError: no such table
source link: https://blog.51cto.com/mouday/5822710
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
peewee.OperationalError: no such table
精选 原创
初始化数据表的时候，依次执行了
peewee.OperationalError: no such table: tb_user
$ python --version
Python 3.7.0
$ pip show peewee
Name: peewee
Version: 3.15.3
定义Model
# -*- coding: utf-8 -*-
from peewee import TextField, AutoField, Model
from playhouse.sqliteq import SqliteQueueDatabase
db = SqliteQueueDatabase(database='database.db')
class UserModel(Model):
id = AutoField()
name = TextField()
class Meta:
database = db
table_name = 'tb_user'
1、执行建表和插入
执行正常，没有报错
# 建表
db.create_tables([UserModel])
# 插入数据
UserModel.create(id=1, name='Tom')
2、执行建表和查询
- 第一次执行的时候，都会报错，提示表不存在
- 第二次之后执行，就不会报错
# 建表
db.create_tables([UserModel])
# 查询数据
row = UserModel.select('id').where(
UserModel.id, '=', 1
).get_or_none()
print(row)
# peewee.OperationalError: no such table: tb_user
SqliteQueueDatabase is designed to simplify things by sending all write queries through a single, long-lived connection. The benefit is that you get the appearance of multiple threads writing to the database without conflicts or timeouts. The downside, however, is that you cannot issue write transactions that encompass multiple queries – all writes run in autocommit mode, essentially.
SqliteQueueDatabase 是单线程写入和多线程读取，写的线程和读的线程并不在一起。
所以，写入还没完成就执行了读取操作，触发了表不存在的报错
找到了问题所在，那我们等一等写入线程，再执行读操作
import time
time.sleep(0.01)
# -*- coding: utf-8 -*-
import time
from peewee import TextField, AutoField, Model
from playhouse.sqliteq import SqliteQueueDatabase
db = SqliteQueueDatabase(database='database.db')
class UserModel(Model):
id = AutoField()
name = TextField()
class Meta:
database = db
table_name = 'tb_user'
# 建表
db.create_tables([UserModel])
# 等一等，写入操作完成再读取
time.sleep(0.01)
# 查询数据
row = UserModel.select('id').where(
UserModel.id, '=', 1
).get_or_none()
print(row)
# None
- 打赏
- 赞
- 收藏
- 评论
- 分享
- 举报
上一篇：sql：递减/递减更新一列字段值
Recommend
About Joyk
Aggregate valuable and interesting links.
Joyk means Joy of geeK