Check expiration column exists before adding.

couchbase · Oct 24, 2024 · df4af06 · df4af06
1 parent 39444b2
commit df4af06
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/LiteCore/Storage/SQLiteDataFile.cc b/LiteCore/Storage/SQLiteDataFile.cc
@@ -334,6 +334,12 @@ namespace litecore {
                 // Add the 'expiration' column to every KeyStore:
                 for ( string& name : allKeyStoreNames() ) {
                     if ( name.find("::") == string::npos ) {
+                        string sql;
+                        // We need to check for existence of the expiration column first.
+                        // Do not add it if it already exists in the table.
+                        if ( getSchema("kv_" + name, "table", "kv_" + name, sql)
+                             && sql.find("expiration") != string::npos )
+                            continue;
                         // Only update data tables, not FTS index tables
                         _exec(format(
                                 "ALTER TABLE \"kv_%s\" ADD COLUMN expiration INTEGER; "