數據庫更改軟件更新

Question

我有一個程序，它有一個特定的模式的數據庫，v0.1.0。

在我的下一個版本（v0.1.1）中，我對數據庫模式進行了更改。

因此，當我更新到（0.1.1）時，我希望這些更改在不影響（0.1.0）及其後續版本中的原始數據的情況下生效。

如何在不影響（0.1.0）數據庫數據並跟蹤後續版本中的更改的情況下進行更改？

我正在使用python與sqlite3。

更新

沒有爲軟件的多個版本不支持。數據庫取決於您正在使用的版本。

沒有併發訪問數據庫，每個版本有1個數據庫。

因此，用戶可以使用舊版本，但是當他們升級到新版本時，.sqlite模式將被更改。

Answer 1

有幾種方法可以做到這一點，我只提一個。

看來你已經跟蹤數據庫中的版本。在您的應用程序開始時，您需要根據正在運行的應用程序的版本來檢查此版本，並運行將執行架構更改的任何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') 

每次升級腳本將採取的making your database changes照顧，然後更新數據庫內的版本到最新版本。請注意，我們不使用elif語句，因此您可以根據需要將數據庫升級到多個版本。

有一些注意事項要注意：

• 運行升級inside transactions，你會想回滾任何錯誤，避免讓數據庫處於不可用狀態。 - 更新這是不正確的，正如指出的，謝謝Martijn！
• 如果可以，請避免重命名和刪除列，並且如果必須，請確保使用它們的任何視圖也會更新。

Answer 2

長期來看，使用ORM（例如SQLAlchemy）和Alembic等遷移工具會更好。

Answer 3

與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)