UpdateDataBase.pas 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206
  1. unit UpdateDataBase;
  2. interface
  3. uses ScAutoUpdateUnit, ADODB, SysUtils, DataBaseTables, Classes, Connections;
  4. type
  5. TUpdateDB = class
  6. private
  7. procedure UpdateAllTables(AConnection: TADOConnection); virtual;
  8. public
  9. constructor Create; virtual;
  10. destructor Destroy; virtual;
  11. procedure Update(AConnection: TEncryptConnection);
  12. end;
  13. TUpdateManagerDB = class(TUpdateDB)
  14. private
  15. Procedure UpdateAllTables(AConnection: TADOConnection); override;
  16. public
  17. procedure Update(AConnection: TConnection); overload;
  18. end;
  19. TUpdateProjectDB = class(TUpdateDB)
  20. private
  21. procedure UpdateAllTables(AConnection: TADOConnection); override;
  22. public
  23. procedure ForceUpdate(AConnection: TADOConnection);
  24. end;
  25. TUpdatePhaseDB = class(TUpdateDB)
  26. private
  27. FAuditList: TStringList;
  28. procedure UpdateAllTables(AConnection: TADOConnection); override;
  29. procedure GetAuditList(AConnection: TADOConnection);
  30. function GetNewAuditTableName(AIndex: Integer): String;
  31. public
  32. constructor Create; override;
  33. destructor Destroy; override;
  34. procedure AddAuditData(AConnection: TADOConnection; AIndex: Integer);
  35. end;
  36. implementation
  37. { TUpdateDB }
  38. constructor TUpdateDB.Create;
  39. begin
  40. end;
  41. destructor TUpdateDB.Destroy;
  42. begin
  43. end;
  44. procedure TUpdateDB.Update(AConnection: TEncryptConnection);
  45. begin
  46. if AConnection.NeedUpdate then
  47. begin
  48. UpdateAllTables(AConnection.Connection);
  49. AConnection.UpdateFileVersion;
  50. end;
  51. end;
  52. procedure TUpdateDB.UpdateAllTables(AConnection: TADOConnection);
  53. begin
  54. // Nothing
  55. end;
  56. { TUpdateProjectDB }
  57. procedure TUpdateProjectDB.ForceUpdate(AConnection: TADOConnection);
  58. begin
  59. UpdateAllTables(AConnection);
  60. end;
  61. procedure TUpdateProjectDB.UpdateAllTables(AConnection: TADOConnection);
  62. var
  63. Updater: TScUpdater;
  64. iIndex: Integer;
  65. begin
  66. Updater := TScUpdater.Create;
  67. try
  68. Updater.ForceUpdate := True;
  69. Updater.Open('', AConnection, '', '');
  70. Updater.AddTableDef(SBills, @tdBills, Length(tdBills), False, False);
  71. Updater.AddTableDef(SProjProperties, @tdProjProperties, Length(tdProjProperties), False, False);
  72. Updater.AddTableDef(SDealPayment, @tdDealPayment, Length(tdDealPayment), False, False);
  73. Updater.AddTableDef(SBGL, @tdBGL, length(tdBGL), False, False);
  74. Updater.AddTableDef(SBGBills, @tdBGBills, length(tdBGBills), False, False);
  75. Updater.AddTableDef(SStaff, @tdStaff, Length(tdStaff), False, False);
  76. Updater.AddTableDef(SDealBills, @tdDealBills, Length(tdDealBills), False, False);
  77. Updater.AddTableDef(SMainDataList, @tdMainDataList, Length(tdMainDataList), False, False);
  78. Updater.AddTableDef(SProjectGL, @tdProjectGL, Length(tdProjectGL), False, False);
  79. Updater.AddTableDef(SGLPrice, @tdGLPrice, Length(tdGLPrice), False, False);
  80. Updater.AddTableDef(SDetailGL, @tdDetailGL, Length(tdDetailGL), False, False);
  81. Updater.ExcuteUpdate;
  82. finally
  83. Updater.Free;
  84. end;
  85. end;
  86. { TUpdatePhaseDB }
  87. procedure TUpdatePhaseDB.AddAuditData(AConnection: TADOConnection;
  88. AIndex: Integer);
  89. var
  90. Updater: TScUpdater;
  91. begin
  92. Updater := TScUpdater.Create;
  93. try
  94. Updater.ForceUpdate := True;
  95. Updater.Open('', AConnection, '', '');
  96. Updater.AddTableDef(GetNewAuditTableName(AIndex), @tdRefer_Audit, Length(tdRefer_Audit), False, False);
  97. Updater.ExcuteUpdate;
  98. finally
  99. Updater.Free;
  100. end;
  101. end;
  102. constructor TUpdatePhaseDB.Create;
  103. begin
  104. inherited;
  105. FAuditList := TStringList.Create;
  106. end;
  107. destructor TUpdatePhaseDB.Destroy;
  108. begin
  109. FAuditList.Free;
  110. inherited;
  111. end;
  112. procedure TUpdatePhaseDB.GetAuditList(AConnection: TADOConnection);
  113. var
  114. iIndex: Integer;
  115. begin
  116. AConnection.GetTableNames(FAuditList);
  117. iIndex := 0;
  118. while iIndex < FAuditList.Count do
  119. begin
  120. if Pos(SAudit, FAuditList.Strings[iIndex]) = 1 then
  121. Inc(iIndex)
  122. else
  123. FAuditList.Delete(iIndex);
  124. end;
  125. end;
  126. function TUpdatePhaseDB.GetNewAuditTableName(AIndex: Integer): String;
  127. begin
  128. Result := SAudit + IntToStr(AIndex);
  129. end;
  130. procedure TUpdatePhaseDB.UpdateAllTables(AConnection: TADOConnection);
  131. var
  132. Updater: TScUpdater;
  133. iIndex: Integer;
  134. begin
  135. Updater := TScUpdater.Create;
  136. try
  137. GetAuditList(AConnection);
  138. Updater.ForceUpdate := True;
  139. Updater.Open('', AConnection, '', '');
  140. Updater.AddTableDef(SRefer, @tdRefer_Audit, Length(tdRefer_Audit), False, False);
  141. for iIndex := 0 to FAuditList.Count - 1 do
  142. Updater.AddTableDef(FAuditList.Strings[iIndex], @tdRefer_Audit, Length(tdRefer_Audit), False, False);
  143. Updater.AddTableDef(SPhaseProperty, @tdPhaseProperty, Length(tdPhaseProperty), False, False);
  144. Updater.AddTableDef(SPhasePay, @tdPhasePay, Length(tdPhasePay), False, False);
  145. Updater.AddTableDef(SZJJL, @tdZJJL, Length(tdZJJL), False, False);
  146. Updater.AddTableDef(SReportData, @tdReportData, Length(tdReportData), False, False);
  147. Updater.ExcuteUpdate;
  148. finally
  149. Updater.Free;
  150. end;
  151. end;
  152. { TUpdateManagerDB }
  153. procedure TUpdateManagerDB.Update(AConnection: TConnection);
  154. begin
  155. UpdateAllTables(AConnection.Connection);
  156. end;
  157. procedure TUpdateManagerDB.UpdateAllTables(AConnection: TADOConnection);
  158. var
  159. Updater: TScUpdater;
  160. iIndex: Integer;
  161. begin
  162. Updater := TScUpdater.Create;
  163. try
  164. Updater.ForceUpdate := True;
  165. Updater.Open('', AConnection, '', '');
  166. Updater.AddTableDef(SProjectsInfo, @tdProjectsInfo, Length(tdProjectsInfo), False, False);
  167. Updater.AddTableDef(STenderProperty, @tdTenderProperty, Length(tdTenderProperty), False, False);
  168. Updater.AddTableDef(STenderBackup, @tdTenderBackup, Length(tdTenderBackup), False, False);
  169. Updater.ExcuteUpdate;
  170. finally
  171. Updater.Free;
  172. end;
  173. end;
  174. end.