datasource.inc 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575
  1. { ---------------------------------------------------------------------
  2. TDatalink
  3. ---------------------------------------------------------------------}
  4. Constructor TDataLink.Create;
  5. begin
  6. Inherited Create;
  7. FBufferCount:=1;
  8. FDataSource := nil;
  9. FDatasourceFixed:=False;
  10. end;
  11. Destructor TDataLink.Destroy;
  12. begin
  13. Factive:=False;
  14. FEditing:=False;
  15. FDataSourceFixed:=False;
  16. DataSource:=Nil;
  17. Inherited Destroy;
  18. end;
  19. Procedure TDataLink.ActiveChanged;
  20. begin
  21. end;
  22. Procedure TDataLink.CheckActiveAndEditing;
  23. Var
  24. B : Boolean;
  25. begin
  26. B:=Assigned(DataSource) and (DataSource.State<>dsInactive);
  27. If B<>FActive then
  28. begin
  29. FActive:=B;
  30. ActiveChanged;
  31. end;
  32. B:=Assigned(DataSource) and (DataSource.State in dsEditModes) and Not FReadOnly;
  33. If B<>FEditing Then
  34. begin
  35. FEditing:=B;
  36. EditingChanged;
  37. end;
  38. end;
  39. Procedure TDataLink.CheckBrowseMode;
  40. begin
  41. end;
  42. Function TDataLink.CalcFirstRecord(Index : Integer) : Integer;
  43. { recalculates index of first record in buffer,
  44. and returns number of record scrolled.}
  45. Var
  46. A, // Index of active record in buffer
  47. F, // Index of current first record in buffer
  48. L : Integer; // index of Last (for us) record in buffer;
  49. begin
  50. Result:=0;
  51. A:=DataSource.DataSet.FActiveRecord;
  52. F:=FFirstRecord+Index;
  53. L:=F+FBufferCount-1;
  54. If A>L Then
  55. Result:=A-L
  56. else If A<F Then
  57. Result:=A-F;
  58. FFirstRecord:=F+Result;
  59. {$IfDef dsDebug}
  60. WriteLn('CalcFirstRecord: FFirstRecord=',FFirstRecord,' Scrolled=',Result);
  61. {$Endif}
  62. end;
  63. Procedure TDataLink.CalcRange;
  64. var
  65. aMax, aMin: integer;
  66. begin
  67. aMin:= DataSet.FActiveRecord - FBufferCount + 1;
  68. If aMin < 0 Then aMin:= 0;
  69. aMax:= Dataset.FBufferCount - FBufferCount;
  70. If aMax < 0 then aMax:= 0;
  71. If aMax>DataSet.FActiveRecord Then aMax:=DataSet.FActiveRecord;
  72. If FFirstRecord < aMin Then FFirstRecord:= aMin;
  73. If FFirstrecord > aMax Then FFirstRecord:= aMax;
  74. If (FfirstRecord<>0) And
  75. (DataSet.FActiveRecord - FFirstRecord < FBufferCount -1) Then
  76. Dec(FFirstRecord, 1);
  77. end;
  78. Procedure TDataLink.DataEvent(Event: TDataEvent; Info: Ptrint);
  79. begin
  80. Case Event of
  81. deFieldChange, deRecordChange:
  82. If Not FUpdatingRecord then
  83. RecordChanged(TField(Info));
  84. deDataSetChange: begin
  85. SetActive(DataSource.DataSet.Active);
  86. CalcFirstRecord(Info);
  87. DatasetChanged;
  88. end;
  89. deDataSetScroll: DatasetScrolled(CalcFirstRecord(Info));
  90. deLayoutChange: begin
  91. CalcFirstRecord(Info);
  92. LayoutChanged;
  93. end;
  94. deUpdateRecord: UpdateRecord;
  95. deUpdateState: CheckActiveAndEditing;
  96. deCheckBrowseMode: CheckBrowseMode;
  97. deFocusControl: FocusControl(TFieldRef(Info));
  98. end;
  99. end;
  100. Procedure TDataLink.DataSetChanged;
  101. begin
  102. RecordChanged(Nil);
  103. end;
  104. Procedure TDataLink.DataSetScrolled(Distance: Integer);
  105. begin
  106. DataSetChanged;
  107. end;
  108. Procedure TDataLink.EditingChanged;
  109. begin
  110. end;
  111. Procedure TDataLink.FocusControl(Field: TFieldRef);
  112. begin
  113. end;
  114. Function TDataLink.GetActiveRecord: Integer;
  115. begin
  116. Result:=Dataset.FActiveRecord - FFirstRecord;
  117. end;
  118. Function TDatalink.GetDataSet : TDataset;
  119. begin
  120. Result:=FDataSource.DataSet
  121. end;
  122. Function TDataLink.GetBOF: Boolean;
  123. begin
  124. Result:=DataSet.BOF
  125. end;
  126. Function TDataLink.GetBufferCount: Integer;
  127. begin
  128. Result:=FBufferCount;
  129. end;
  130. Function TDataLink.GetEOF: Boolean;
  131. begin
  132. Result:=DataSet.EOF
  133. end;
  134. Function TDataLink.GetRecordCount: Integer;
  135. begin
  136. Result:=Dataset.FRecordCount;
  137. If Result>BufferCount then
  138. Result:=BufferCount;
  139. end;
  140. Procedure TDataLink.LayoutChanged;
  141. begin
  142. DataSetChanged;
  143. end;
  144. Function TDataLink.MoveBy(Distance: Integer): Integer;
  145. begin
  146. Result:=DataSet.MoveBy(Distance);
  147. end;
  148. Procedure TDataLink.RecordChanged(Field: TField);
  149. begin
  150. end;
  151. Procedure TDataLink.SetActiveRecord(Value: Integer);
  152. begin
  153. {$ifdef dsdebug}
  154. Writeln('Datalink. Setting active record to ',Value,' with firstrecord ',ffirstrecord);
  155. {$endif}
  156. Dataset.FActiveRecord:=Value + FFirstRecord;
  157. end;
  158. Procedure TDataLink.SetBufferCount(Value: Integer);
  159. begin
  160. If FBufferCount<>Value then
  161. begin
  162. FBufferCount:=Value;
  163. if Active then begin
  164. DataSet.RecalcBufListSize;
  165. CalcRange;
  166. end;
  167. end;
  168. end;
  169. procedure TDataLink.SetActive(AActive: Boolean);
  170. begin
  171. if Active <> AActive then
  172. begin
  173. FActive := AActive;
  174. // !!!: Set internal state
  175. ActiveChanged;
  176. end;
  177. end;
  178. Procedure TDataLink.SetDataSource(Value : TDatasource);
  179. begin
  180. if not FDataSourceFixed then
  181. begin
  182. if Assigned(DataSource) then
  183. Begin
  184. DataSource.UnregisterDatalink(Self);
  185. FDataSource := nil;
  186. CheckActiveAndEditing;
  187. End;
  188. FDataSource := Value;
  189. if Assigned(DataSource) then
  190. begin
  191. DataSource.RegisterDatalink(Self);
  192. CheckActiveAndEditing;
  193. End;
  194. end;
  195. end;
  196. Procedure TDatalink.SetReadOnly(Value : Boolean);
  197. begin
  198. If FReadOnly<>Value then
  199. begin
  200. FReadOnly:=Value;
  201. CheckActiveAndEditing;
  202. end;
  203. end;
  204. Procedure TDataLink.UpdateData;
  205. begin
  206. end;
  207. Function TDataLink.Edit: Boolean;
  208. begin
  209. If Not FReadOnly then
  210. DataSource.Edit;
  211. // Triggered event will set FEditing
  212. Result:=FEditing;
  213. end;
  214. Procedure TDataLink.UpdateRecord;
  215. begin
  216. FUpdatingRecord:=True;
  217. Try
  218. UpdateData;
  219. finally
  220. FUpdatingRecord:=False;
  221. end;
  222. end;
  223. { ---------------------------------------------------------------------
  224. TDetailDataLink
  225. ---------------------------------------------------------------------}
  226. Function TDetailDataLink.GetDetailDataSet: TDataSet;
  227. begin
  228. Result := nil;
  229. end;
  230. { ---------------------------------------------------------------------
  231. TMasterDataLink
  232. ---------------------------------------------------------------------}
  233. constructor TMasterDataLink.Create(ADataSet: TDataSet);
  234. begin
  235. inherited Create;
  236. FDataSet := ADataSet;
  237. FFields := TList.Create;
  238. end;
  239. destructor TMasterDataLink.Destroy;
  240. begin
  241. FFields.Free;
  242. inherited Destroy;
  243. end;
  244. Procedure TMasterDataLink.ActiveChanged;
  245. begin
  246. FFields.Clear;
  247. if Active then
  248. try
  249. DataSet.GetFieldList(FFields, FFieldNames);
  250. except
  251. FFields.Clear;
  252. raise;
  253. end;
  254. if FDataSet.Active and not (csDestroying in FDataSet.ComponentState) then
  255. if Active and (FFields.Count > 0) then
  256. begin
  257. if Assigned(FOnMasterChange) then FOnMasterChange(Self);
  258. end else
  259. if Assigned(FOnMasterDisable) then FOnMasterDisable(Self);
  260. end;
  261. Procedure TMasterDataLink.CheckBrowseMode;
  262. begin
  263. if FDataSet.Active then FDataSet.CheckBrowseMode;
  264. end;
  265. Function TMasterDataLink.GetDetailDataSet: TDataSet;
  266. begin
  267. Result := FDataSet;
  268. end;
  269. Procedure TMasterDataLink.LayoutChanged;
  270. begin
  271. ActiveChanged;
  272. end;
  273. Procedure TMasterDataLink.RecordChanged(Field: TField);
  274. begin
  275. if (DataSource.State <> dsSetKey) and FDataSet.Active and
  276. (FFields.Count > 0) and ((Field = nil) or
  277. (FFields.IndexOf(Field) >= 0)) and
  278. Assigned(FOnMasterChange) then
  279. FOnMasterChange(Self);
  280. end;
  281. procedure TMasterDatalink.SetFieldNames(const Value: string);
  282. begin
  283. if FFieldNames <> Value then
  284. begin
  285. FFieldNames := Value;
  286. ActiveChanged;
  287. end;
  288. end;
  289. { ---------------------------------------------------------------------
  290. TDatasource
  291. ---------------------------------------------------------------------}
  292. Constructor TDataSource.Create(AOwner: TComponent);
  293. begin
  294. Inherited Create(AOwner);
  295. FDatalinks := TList.Create;
  296. FEnabled := True;
  297. FAutoEdit := True;
  298. end;
  299. Destructor TDataSource.Destroy;
  300. begin
  301. FOnStateCHange:=Nil;
  302. Dataset:=Nil;
  303. With FDataLinks do
  304. While Count>0 do
  305. TDatalink(Items[Count - 1]).DataSource:=Nil;
  306. FDatalinks.Free;
  307. inherited Destroy;
  308. end;
  309. Procedure TDatasource.Edit;
  310. begin
  311. If (State=dsBrowse) and AutoEdit Then
  312. Dataset.Edit;
  313. end;
  314. Function TDataSource.IsLinkedTo(ADataSet: TDataSet): Boolean;
  315. begin
  316. Result:=False;
  317. end;
  318. procedure TDatasource.DistributeEvent(Event: TDataEvent; Info: Ptrint);
  319. Var
  320. i : Longint;
  321. begin
  322. With FDatalinks do
  323. begin
  324. For I:=0 to Count-1 do
  325. With TDatalink(Items[i]) do
  326. If Not VisualControl Then
  327. DataEvent(Event,Info);
  328. For I:=0 to Count-1 do
  329. With TDatalink(Items[i]) do
  330. If VisualControl Then
  331. DataEvent(Event,Info);
  332. end;
  333. end;
  334. procedure TDatasource.RegisterDataLink(DataLink: TDataLink);
  335. begin
  336. FDatalinks.Add(DataLink);
  337. if Assigned(DataSet) then
  338. DataSet.RecalcBufListSize;
  339. end;
  340. procedure TDatasource.SetDataSet(ADataSet: TDataSet);
  341. begin
  342. If FDataset<>Nil Then
  343. Begin
  344. FDataset.UnRegisterDataSource(Self);
  345. FDataSet:=nil;
  346. ProcessEvent(deUpdateState,0);
  347. End;
  348. If ADataset<>Nil Then
  349. begin
  350. ADataset.RegisterDatasource(Self);
  351. FDataSet:=ADataset;
  352. ProcessEvent(deUpdateState,0);
  353. End;
  354. end;
  355. procedure TDatasource.SetEnabled(Value: Boolean);
  356. begin
  357. FEnabled:=Value;
  358. end;
  359. Procedure TDatasource.DoDataChange (Info : Pointer);
  360. begin
  361. If Assigned(OnDataChange) Then
  362. OnDataChange(Self,TField(Info));
  363. end;
  364. Procedure TDatasource.DoStateChange;
  365. begin
  366. If Assigned(OnStateChange) Then
  367. OnStateChange(Self);
  368. end;
  369. Procedure TDatasource.DoUpdateData;
  370. begin
  371. If Assigned(OnUpdateData) Then
  372. OnUpdateData(Self);
  373. end;
  374. procedure TDatasource.UnregisterDataLink(DataLink: TDataLink);
  375. begin
  376. FDatalinks.Remove(Datalink);
  377. If Dataset<>Nil then
  378. DataSet.RecalcBufListSize;
  379. //Dataset.SetBufListSize(DataLink.BufferCount);
  380. end;
  381. procedure TDataSource.ProcessEvent(Event : TDataEvent; Info : Ptrint);
  382. Const
  383. OnDataChangeEvents = [deRecordChange, deDataSetChange, deDataSetScroll,
  384. deLayoutChange,deUpdateState];
  385. Var
  386. NeedDataChange : Boolean;
  387. FLastState : TdataSetState;
  388. begin
  389. // Special UpdateState handling.
  390. If Event=deUpdateState then
  391. begin
  392. NeedDataChange:=(FState=dsInactive);
  393. FLastState:=FState;
  394. If Assigned(Dataset) then
  395. FState:=Dataset.State
  396. else
  397. FState:=dsInactive;
  398. // Don't do events if nothing changed.
  399. If FState=FlastState then
  400. exit;
  401. end
  402. else
  403. NeedDataChange:=True;
  404. DistributeEvent(Event,Info);
  405. // Extra handlers
  406. If Not (csDestroying in ComponentState) then
  407. begin
  408. If (Event=deUpdateState) then
  409. DoStateChange;
  410. If (Event in OnDataChangeEvents) and
  411. NeedDataChange Then
  412. DoDataChange(Nil);
  413. If (Event = deFieldChange) Then
  414. DoDataCHange(Pointer(Info));
  415. If (Event=deUpdateRecord) then
  416. DoUpdateData;
  417. end;
  418. end;