处理此类问题的一个好方法是在数据库中添加版本控制系统。在使用与数据库的连接之前,只需检查数据库中的应用程序版本,如果新版本高于以前的版本,则运行所有必要的命令来更新数据库。
前任:
public async Task<SQLite.SQLiteConnection> GetSqliteConnectionForUserAsync(string login)
{
using (await _mutex.LockAsync())
{
if (login == null)
{
login = "__anonymous__";
}
SQLite.SQLiteConnection conn;
if (!_userConnections.TryGetValue(login, out conn))
{
conn = new SQLite.SQLiteConnection(Path.Combine(ApplicationData.Current.LocalFolder.Path,
string.Format("{0}.db", Uri.EscapeDataString(login))));
await SqlSchemaHandler.EnsureSchemaReadyAsync(conn, s =>
{
_logger.Info("Schema handler message : {0}", s);
});
_userConnections[login] = conn;
}
return conn;
}
}
和(SqlSchemaHandler):
public static Task EnsureSchemaReadyAsync(SQLiteConnection connection, Action<string> actionReporter)
{
return Task.Run(() =>
{
connection.CreateTable<SchemaInfo>();
var schemaInfo = connection.Table<SchemaInfo>().FirstOrDefault();
if (schemaInfo == null)
{
ApplyV0ToV1(connection);
schemaInfo = new SchemaInfo { Id = 1, Version = 1 };
connection.Insert(schemaInfo);
}
});
}
private static void ApplyV0ToV1(SQLiteConnection connection)
{
connection.CreateTable<Test>();
}
谢谢,