1

我有一个程序，它有一个具有特定模式的数据库，v0.1.0.

在我的下一个版本 ( v0.1.1) 中，我对数据库架构进行了更改。

因此，当我更新到 ( 0.1.1) 时，我希望这些更改在不影响 ( 0.1.0) 和后续版本中的原始数据的情况下生效。

如何在不影响 ( 0.1.0) 数据库数据的情况下进行更改并在后续版本中跟踪这些更改？

我正在使用带有sqlite3.

更新

不支持该软件的多个版本。数据库取决于您使用的版本。

是没有并发访问数据库，每个版本1个数据库。

所以用户可以使用旧版本，但是当他们升级到新版本时，.sqlite 架构将被更改。

4

3 回答 3

4

user_version使用PRAGMA跟踪数据库中的模式版本，并保持一系列升级步骤：

def get_schema_version(conn):
    cursor = conn.execute('PRAGMA user_version')
    return cursor.fetchone()[0]

def set_schema_version(conn, version):
    conn.execute('PRAGMA user_version={:d}'.format(version))

def initial_schema(conn):
    # install initial schema
    # ...

def ugrade_1_2(conn):
    # modify schema, alter data, etc.

# map target schema version to upgrade step from previous version
upgrade_steps = {
    1: initial_schema,
    2: ugrade_1_2,
}

def check_upgrade(conn):
    current = get_schema_version(conn)
    target = max(upgrade_steps)
    for step in range(current + 1, target + 1):
        if step in upgrade_steps:
            upgrade_steps[step](conn)
            set_schema_version(conn, step)
于 2013-10-12T08:48:21.887 回答
0

有几种方法可以做到这一点，我只提一种。

似乎您已经在数据库中跟踪了版本。在您的应用程序启动时，您需要对照正在运行的应用程序的版本检查此版本，并运行任何将执行架构更改的 sql 脚本。

更新

这方面的一个例子：

import os
import sqlite3 as sqlite

def make_movie_table(cursor):
    cursor.execute('CREATE TABLE movies(id INTEGER PRIMARY KEY, title VARCHAR(20), link VARCHAR(20))')

def make_series_table(cursor):
     cursor.execute('CREATE TABLE series(title VARCHAR(30) PRIMARY KEY,series_link VARCHAR(60),number_of_episodes INTEGER,number_of_seasons INTEGER)')

def make_episode_table(cursor):
    cursor.execute('CREATE TABLE episodes(id INTEGER PRIMARY KEY,title VARCHAR(30),episode_name VARCHAR(15), episode_link VARCHAR(40), Date TIMESTAMP, FOREIGN KEY (title) REFERENCES series(title) ON DELETE CASCADE)')

def make_version_table(cursor):
    cursor.execute('CREATE TABLE schema_versions(version VARCHAR(6))')
    cursor.execute('insert into schema_versions(version) values ("0.1.0")')

def create_database(sqlite_file):
    if not os.path.exists(sqlite_file):
        connection = sqlite.connect(sqlite_file)
        cursor = connection.cursor()
        cursor.execute("PRAGMA foreign_keys = ON")
        make_movie_table(cursor)
        make_series_table(cursor)
        make_episode_table(cursor)
        make_version_table(cursor)
        connection.commit()
        connection.close()

def upgrade_database(sqlite_file):
    if os.path.exists(sqlite_file):
        connection = sqlite.connect(sqlite_file)
        cursor = connection.cursor()

        cursor.execute("select max(version) from schema_versions")
        row = cursor.fetchone()
        database_version = row[0]
        print('current version is %s' % database_version)

        if database_version == '0.1.0':
            print('upgrading version to 0.1.1')
            cursor.execute('alter table series ADD COLUMN new_column1 VARCHAR(10)')
            cursor.execute('alter table series ADD COLUMN new_column2 INTEGER')
            cursor.execute('insert into schema_versions(version) values ("0.1.1")')

        #if database_version == '0.1.1':
            #print('upgrading version to 0.1.2')
            #etc cetera

        connection.commit()
        connection.close()

#I need to add 2 columns to the series table, when the user upgrade the software.

if __name__ == '__main__':
    create_database('/tmp/db.sqlite')
    upgrade_database('/tmp/db.sqlite')

每个升级脚本都会处理您的数据库更改，然后将数据库中的版本更新到最新版本。请注意，我们不使用elif语句，这样您可以在需要时将数据库升级到多个版本。

有一些注意事项需要注意：

  • 在 transactions中运行升级，您将希望回滚任何错误以避免使数据库处于不可用状态。-正如指出的那样更新这是不正确的，感谢Martijn！
  • 如果可以，请避免重命名和删除列，如果必须，请确保使用它们的任何视图也得到更新。
于 2013-10-12T08:17:43.470 回答
-2

从长远来看，使用诸如SQLAlchemy之类的 ORM 和诸如Alembic之类的迁移工具会更好。

于 2013-10-12T07:17:07.000 回答