c#使用FreeSql生產(chǎn)環(huán)境時自動升級備份數(shù)據(jù)庫

第c#使用FreeSql生產(chǎn)環(huán)境時自動升級備份數(shù)據(jù)庫//數(shù)據(jù)庫是否存在，用于插入初始數(shù)據(jù)，必須在freesql實例化前判斷，因為實例化時會自動創(chuàng)建數(shù)據(jù)庫

varcustDbPathExists=File.Exists(CustDbPath);

//deebug自動同步實體結(jié)構(gòu)到數(shù)據(jù)庫，release手動同步

boolsyncDbStructure=false;

#ifDEBUG

syncDbStructure=true;

#endif

fsql=newFreeSql.FreeSqlBuilder()

.UseConnectionString(FreeSql.DataType.Sqlite,$@"DataSource={CustDbPath};Pooling=true;MinPoolSize=1")

.UseAutoSyncStructure(syncDbStructure)//deebug自動同步實體結(jié)構(gòu)到數(shù)據(jù)庫，release手動同步

.UseMonitorCommand(cmd=Console.WriteLine($"線程：{cmd.CommandText}\r\n"))

.Build();//請務(wù)必定義成Singleton單例模式

if(syncDbStructure)

//主要用于開發(fā)模式下，讓數(shù)據(jù)庫修改快速生效，不加此句時，只有在用到表時才會同步

fsql.CodeFirst.SyncStructure(GetTypesByTableAttribute());

if(custDbPathExists==false)

//數(shù)據(jù)庫文件不存在，表示是首次安裝

fsql.CodeFirst.SyncStructure(GetTypesByTableAttribute());

varsysConfig=newSysConfig();

sysConfig.DbVer=ServerDbVer;

vardbResult=fsql.Insert(sysConfig).ExecuteAffrows();

if(dbResult=0)

thrownewException("初始數(shù)據(jù)庫失敗。");

varrow=newDbLog();

row.DbVer=ServerDbVer;

fsql.Insert(row).ExecuteAffrows();

intlocalDbVer=fsql.SelectSysConfig().First().DbVer;

if(localDbVer!=ServerDbVer)

//數(shù)據(jù)庫版本不一樣，需要升級

//備份數(shù)據(jù)庫

File.Copy(CustDbPath,Application.StartupPath+$"\\數(shù)據(jù)庫\\cust{DateTime.Now:yyyyMMddHHmmss}.db");

//升級數(shù)據(jù)庫

fsql.CodeFirst.SyncStructure(GetTypesByTableAttribute());

varrow=newDbLog();

row.DbVer=ServerDbVer;

fsql.Insert(row).ExecuteAffrows();

Application.EnableVisualStyles();

Application.SetCompatibleTextRenderingDefault(false);

Application.Run(newFrmMain());

catch(Exceptione)

MessageBox.Show(e.ToString(),"出錯啦",MessageBoxButtons.OK,MessageBoxIcon.Error);

publicstaticType[]GetTypesByTableAttribute()

ListTypetableAssembies=newListType

foreach(TypetypeinAssembly.GetAssembly(typeof(IEntity)).GetExportedTypes())

foreach(Attributeattributeintype.GetCustomAttributes())

if(attributeisTableAttributetableAttribute)

if(tableAttribute.DisableSyncStructure==false)

tableAssembies.Add(type);

returntableAssembies.ToArray();

}

SysConfig.cs

usingFreeSql.DataAnnotations;

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceWindowsClient.Model

///summary

///

////summary

[Table(Name="sys_config")]

publicclassSysConfig:IEntity

///summary

///主鍵

////summary

[Column(Name="id",IsIdentity=true,IsPrimary=true)]

publicintId{get;set;}

///summary

///主鍵

////summary

[Column(Name="dbVer")]

publicintDbVer{get;set;}

///summary

///創(chuàng)建時間

////summary

[Column(ServerTime=DateTimeKind.Local,CanUpdate=false)]

publicDateTimeCreateTime{get;set;}

///summary

///修改時間

////summary

[Column(ServerTime=DateTimeKind.Local,CanUpdate=true)]

publicDateTimeUpdateTime{get;set;}

}

DbLog.cs

usingFreeSql.DataAnnotations;

usingSystem;

usingSystem.Collections.Generic;

usingSystem.Linq;

usingSystem.Text;

usingSystem.Threading.Tasks;

namespaceWindowsClient.Model

///summary

///

////summary

[Table(Name="db_log")]

publicclassDbLog:IEntity

///summary

///主鍵

////summary

[Column(Name="id",IsIdentity=true,IsPrimary=true)]

publicintId{get;set;}

///summary

///主鍵

////summary

[Column(Name="dbVer")]

publicintDbVer{get;set;}

///summary

///創(chuàng)建時間

////summary

[Column(ServerTime=DateTimeKind.Local,CanUpdate=false)]

publicDateTimeCreateTime{get;set;}

///summary

///修改時間

////summary

[Column(ServerTime=DateTimeKi