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

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

varcustDbPathExists=File.Exists(CustDbPath);

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

boolsyncDbStructure=false;

#ifDEBUG

syncDbStructure=true;

#endif

fsql=newFreeSql.FreeSqlBuilder()

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

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

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

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

if(syncDbStructure)

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

fsql.CodeFirst.SyncStructure(GetTypesByTableAttribute());

if(custDbPathExists==false)

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

fsql.CodeFirst.SyncStructure(GetTypesByTableAttribute());

varsysConfig=newSysConfig();

sysConfig.DbVer=ServerDbVer;

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

if(dbResult=0)

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

varrow=newDbLog();

row.DbVer=ServerDbVer;

fsql.Insert(row).ExecuteAffrows();

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

if(localDbVer!=ServerDbVer)

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

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

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

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

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(),"出錯(cuò)啦",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)建時(shí)間

////summary

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

publicDateTimeCreateTime{get;set;}

///summary

///修改時(shí)間

////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)建時(shí)間

////summary

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

publicDateTimeCreateTime{get;set;}

///summary

///修改時(shí)間

////summary

[Column(ServerTime=DateTimeKi