peewee无法在插入新列后插入数据

2024-04-16 13:03:57 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在使用peewee模块来管理Sqlite数据库中的数据。我的用例场景是,我将创建一个具有特定字段的数据库。我还需要在特定时间将列添加到现有数据库中。下面是我应该按预期工作的代码:

from peewee import *
import os
from playhouse.migrate import *

my_db = SqliteDatabase('my_database.db')
migrator = SqliteMigrator(my_db)

class FirstTable(Model):
    first_name = CharField(null=True)
    last_name = CharField(null=True)

    class Meta:
        database = my_db

class Checkit:

    def __init__(self):
        self.db = my_db
        self.migrator = migrator

    def makeDatabse(self):
        if os.path.exists("my_database.db"):
            print "File Exists remove it"
            os.remove("my_database.db")
        try:
            self.db.connect()
            self.db.create_tables([FirstTable,])
        except OperationalError:
            print "Table Exists"

    def insertDatas(self):
        with self.db.atomic():
            for i in range(10):
                first_name_ = "Hello " + str(i)
                last_name_ = "World " + str(i)
                db_ = FirstTable(first_name=first_name_, last_name = last_name_)
                db_.save()

    def alterDatabase(self, columns):
        with self.db.transaction():
            columnField = CharField(null=True)
            for column in columns:              
                migrate(migrator.add_column("firsttable", column, columnField))

    def insertAfterAlteringDatabase(self):
        with self.db.atomic():
            for i in range(20,30):
                first_name_ = "Hello " + str(i)
                last_name_ = "World " + str(i)
                address_ = "Address " + str(i)
                db_ = FirstTable(first_name=first_name_, last_name = last_name_, address=address_)
                db_.save()

ch = Checkit() 
ch.makeDatabse()
ch.insertDatas()
ch.alterDatabase(["address"])
ch.insertAfterAlteringDatabase()

在添加了一个新的列address之后,null=True我正在对修改后的数据库进行一些插入。我希望在address字段中看到地址数据,但我没有得到任何这些数据。而是NULL。我的代码应该可以正常工作,但它没有按预期工作。有什么问题吗?在


Tags: nameself数据库dbaddressmydefch
1条回答
网友
1楼 · 发布于 2024-04-16 13:03:57

在您的insertAfterAlteringDatabase中,您需要将新字段添加到模型中。迁移器将添加到数据库表中,但它没有将字段添加到model类中。为此,您可以:

def alterDatabase(self, columns):
    with self.db.transaction():
        columnField = CharField(null=True)
        for column in columns:              
            migrate(migrator.add_column("firsttable", column, columnField))
        columnField.add_to_class(FirstTable, column)  # Add the field to the model.

相关问题 更多 >