27 |
|
{ IBX For Lazarus (Firebird Express) } |
28 |
|
{ Contributor: Tony Whyman, MWA Software http://www.mwasoftware.co.uk } |
29 |
|
{ Portions created by MWA Software are copyright McCallum Whyman } |
30 |
< |
{ Associates Ltd 2011 } |
30 |
> |
{ Associates Ltd 2011 - 2015 } |
31 |
|
{ } |
32 |
|
{************************************************************************} |
33 |
|
|
120 |
|
{ TIBStringField allows us to have strings longer than 8196 } |
121 |
|
|
122 |
|
TIBStringField = class(TStringField) |
123 |
+ |
private |
124 |
+ |
FInitialised: boolean; |
125 |
+ |
protected |
126 |
+ |
procedure SetSize(AValue: Integer); override; |
127 |
|
public |
128 |
|
constructor create(AOwner: TComponent); override; |
129 |
|
class procedure CheckTypeSize(Value: Integer); override; |
191 |
|
property ApplyOnEvent: TIBGeneratorApplyOnEvent read FApplyOnEvent write FApplyOnEvent; |
192 |
|
end; |
193 |
|
|
194 |
+ |
{TIBControlLink - Allows IB Aware controls to react to dataset state changes} |
195 |
+ |
|
196 |
+ |
TIBControlLink = class |
197 |
+ |
private |
198 |
+ |
FTIBDataSet: TIBCustomDataSet; |
199 |
+ |
procedure SetIBDataSet(AValue: TIBCustomDataSet); |
200 |
+ |
protected |
201 |
+ |
procedure UpdateSQL(Sender: TObject); virtual; |
202 |
+ |
procedure UpdateParams(Sender: TObject); virtual; |
203 |
+ |
public |
204 |
+ |
destructor Destroy; override; |
205 |
+ |
property IBDataSet: TIBCustomDataSet read FTIBDataSet write SetIBDataSet; |
206 |
+ |
end; |
207 |
+ |
|
208 |
+ |
TIBAutoCommit = (acDisabled, acCommitRetaining); |
209 |
+ |
|
210 |
|
{ TIBCustomDataSet } |
211 |
|
TIBUpdateAction = (uaFail, uaAbort, uaSkip, uaRetry, uaApply, uaApplied); |
212 |
|
|
213 |
|
TIBUpdateErrorEvent = procedure(DataSet: TDataSet; E: EDatabaseError; |
214 |
< |
UpdateKind: TUpdateKind; var UpdateAction: TIBUpdateAction) |
214 |
> |
UpdateKind: TUpdateKind; var TheUpdateAction: TIBUpdateAction) |
215 |
|
of object; |
216 |
|
TIBUpdateRecordEvent = procedure(DataSet: TDataSet; UpdateKind: TUpdateKind; |
217 |
|
var UpdateAction: TIBUpdateAction) of object; |
218 |
|
|
219 |
|
TIBUpdateRecordTypes = set of TCachedUpdateStatus; |
220 |
|
|
221 |
+ |
TDataSetCloseAction = (dcDiscardChanges, dcSaveChanges); |
222 |
+ |
|
223 |
+ |
TOnValidatePost = procedure (Sender: TObject; var CancelPost: boolean) of object; |
224 |
+ |
|
225 |
|
TIBCustomDataSet = class(TDataset) |
226 |
|
private |
227 |
+ |
FAutoCommit: TIBAutoCommit; |
228 |
|
FGenerateParamNames: Boolean; |
229 |
|
FGeneratorField: TIBGenerator; |
230 |
|
FNeedsRefresh: Boolean; |
251 |
|
FDeletedRecords: Long; |
252 |
|
FModelBuffer, |
253 |
|
FOldBuffer: PChar; |
254 |
+ |
FOnValidatePost: TOnValidatePost; |
255 |
|
FOpen: Boolean; |
256 |
|
FInternalPrepared: Boolean; |
257 |
|
FQDelete, |
262 |
|
FRecordBufferSize: Integer; |
263 |
|
FRecordCount: Integer; |
264 |
|
FRecordSize: Integer; |
265 |
+ |
FDataSetCloseAction: TDataSetCloseAction; |
266 |
|
FUniDirectional: Boolean; |
267 |
|
FUpdateMode: TUpdateMode; |
268 |
|
FUpdateObject: TIBDataSetUpdateObject; |
284 |
|
FAliasNameList: array of string; |
285 |
|
FBaseSQLSelect: TStrings; |
286 |
|
FParser: TSelectSQLParser; |
287 |
+ |
FCloseAction: TTransactionAction; |
288 |
+ |
FInTransactionEnd: boolean; |
289 |
+ |
FIBLinks: TList; |
290 |
|
function GetSelectStmtHandle: TISC_STMT_HANDLE; |
291 |
|
procedure SetUpdateMode(const Value: TUpdateMode); |
292 |
|
procedure SetUpdateObject(Value: TIBDataSetUpdateObject); |
299 |
|
function CanRefresh: Boolean; |
300 |
|
procedure CheckEditState; |
301 |
|
procedure ClearBlobCache; |
302 |
+ |
procedure ClearIBLinks; |
303 |
|
procedure CopyRecordBuffer(Source, Dest: Pointer); |
304 |
|
procedure DoBeforeDatabaseDisconnect(Sender: TObject); |
305 |
|
procedure DoAfterDatabaseDisconnect(Sender: TObject); |
306 |
|
procedure DoDatabaseFree(Sender: TObject); |
307 |
< |
procedure DoBeforeTransactionEnd(Sender: TObject); |
307 |
> |
procedure DoBeforeTransactionEnd(Sender: TObject; Action: TTransactionAction); |
308 |
|
procedure DoAfterTransactionEnd(Sender: TObject); |
309 |
|
procedure DoTransactionFree(Sender: TObject); |
310 |
|
procedure FetchCurrentRecordToBuffer(Qry: TIBSQL; RecordNumber: Integer; |
327 |
|
procedure InternalPostRecord(Qry: TIBSQL; Buff: Pointer); virtual; |
328 |
|
procedure InternalRevertRecord(RecordNumber: Integer); virtual; |
329 |
|
function IsVisible(Buffer: PChar): Boolean; |
330 |
+ |
procedure RegisterIBLink(Sender: TIBControlLink); |
331 |
+ |
procedure UnRegisterIBLink(Sender: TIBControlLink); |
332 |
|
procedure SaveOldBuffer(Buffer: PChar); |
333 |
|
procedure SetBufferChunks(Value: Integer); |
334 |
|
procedure SetDatabase(Value: TIBDatabase); |
395 |
|
procedure ClearCalcFields(Buffer: PChar); override; |
396 |
|
function AllocRecordBuffer: PChar; override; |
397 |
|
procedure DoBeforeDelete; override; |
398 |
+ |
procedure DoAfterDelete; override; |
399 |
|
procedure DoBeforeEdit; override; |
400 |
+ |
procedure DoAfterEdit; override; |
401 |
|
procedure DoBeforeInsert; override; |
402 |
|
procedure DoAfterInsert; override; |
403 |
+ |
procedure DoBeforeClose; override; |
404 |
|
procedure DoBeforeOpen; override; |
405 |
|
procedure DoBeforePost; override; |
406 |
+ |
procedure DoAfterPost; override; |
407 |
|
procedure FreeRecordBuffer(var Buffer: PChar); override; |
408 |
|
procedure GetBookmarkData(Buffer: PChar; Data: Pointer); override; |
409 |
|
function GetBookmarkFlag(Buffer: PChar): TBookmarkFlag; override; |
417 |
|
DoCheck: Boolean): TGetResult; override; |
418 |
|
function GetRecordCount: Integer; override; |
419 |
|
function GetRecordSize: Word; override; |
420 |
+ |
procedure InternalAutoCommit; |
421 |
|
procedure InternalAddRecord(Buffer: Pointer; Append: Boolean); override; |
422 |
|
procedure InternalCancel; override; |
423 |
|
procedure InternalClose; override; |
449 |
|
|
450 |
|
protected |
451 |
|
{Likely to be made public by descendant classes} |
452 |
+ |
property AutoCommit: TIBAutoCommit read FAutoCommit write FAutoCommit default acDisabled; |
453 |
|
property SQLParams: TIBXSQLDA read GetSQLParams; |
454 |
|
property Params: TIBXSQLDA read GetSQLParams; |
455 |
|
property InternalPrepared: Boolean read FInternalPrepared; |
488 |
|
write FAfterTransactionEnd; |
489 |
|
property TransactionFree: TNotifyEvent read FTransactionFree |
490 |
|
write FTransactionFree; |
491 |
+ |
property OnValidatePost: TOnValidatePost read FOnValidatePost write FOnValidatePost; |
492 |
|
|
493 |
|
public |
494 |
|
constructor Create(AOwner: TComponent); override; |
522 |
|
const ResultFields: string): Variant; override; |
523 |
|
function UpdateStatus: TUpdateStatus; override; |
524 |
|
function IsSequenced: Boolean; override; |
525 |
+ |
procedure Post; override; |
526 |
|
function ParamByName(ParamName: String): TIBXSQLVAR; |
527 |
|
property DBHandle: PISC_DB_HANDLE read GetDBHandle; |
528 |
|
property TRHandle: PISC_TR_HANDLE read GetTRHandle; |
530 |
|
property UpdatesPending: Boolean read FUpdatesPending; |
531 |
|
property UpdateRecordTypes: TIBUpdateRecordTypes read FUpdateRecordTypes |
532 |
|
write SetUpdateRecordTypes; |
533 |
+ |
property DataSetCloseAction: TDataSetCloseAction |
534 |
+ |
read FDataSetCloseAction write FDataSetCloseAction; |
535 |
|
|
536 |
|
published |
537 |
|
property Database: TIBDatabase read GetDatabase write SetDatabase; |
604 |
|
|
605 |
|
published |
606 |
|
{ TIBCustomDataSet } |
607 |
+ |
property AutoCommit; |
608 |
|
property BufferChunks; |
609 |
|
property CachedUpdates; |
610 |
|
property DeleteSQL; |
617 |
|
property ParamCheck; |
618 |
|
property UniDirectional; |
619 |
|
property Filtered; |
620 |
+ |
property DataSetCloseAction; |
621 |
|
|
622 |
|
property BeforeDatabaseDisconnect; |
623 |
|
property AfterDatabaseDisconnect; |
653 |
|
property OnFilterRecord; |
654 |
|
property OnNewRecord; |
655 |
|
property OnPostError; |
656 |
+ |
property OnValidatePost; |
657 |
|
end; |
658 |
|
|
659 |
|
{ TIBDSBlobStream } |
751 |
|
NextRelation : TRelationNode; |
752 |
|
end; |
753 |
|
|
754 |
+ |
{ TIBControlLink } |
755 |
+ |
|
756 |
+ |
destructor TIBControlLink.Destroy; |
757 |
+ |
begin |
758 |
+ |
IBDataSet := nil; |
759 |
+ |
inherited Destroy; |
760 |
+ |
end; |
761 |
+ |
|
762 |
+ |
procedure TIBControlLink.UpdateParams(Sender: TObject); |
763 |
+ |
begin |
764 |
+ |
|
765 |
+ |
end; |
766 |
+ |
|
767 |
+ |
procedure TIBControlLink.UpdateSQL(Sender: TObject); |
768 |
+ |
begin |
769 |
+ |
|
770 |
+ |
end; |
771 |
+ |
|
772 |
+ |
procedure TIBControlLink.SetIBDataSet(AValue: TIBCustomDataSet); |
773 |
+ |
begin |
774 |
+ |
if FTIBDataSet = AValue then Exit; |
775 |
+ |
if IBDataSet <> nil then |
776 |
+ |
IBDataSet.UnRegisterIBLink(self); |
777 |
+ |
FTIBDataSet := AValue; |
778 |
+ |
if IBDataSet <> nil then |
779 |
+ |
IBDataSet.RegisterIBLink(self); |
780 |
+ |
end; |
781 |
+ |
|
782 |
|
|
783 |
|
{ TIBStringField} |
784 |
|
|
785 |
< |
constructor TIBStringField.Create(AOwner: TComponent); |
785 |
> |
constructor TIBStringField.create(AOwner: TComponent); |
786 |
|
begin |
787 |
|
inherited Create(AOwner); |
788 |
|
end; |
839 |
|
end; |
840 |
|
end; |
841 |
|
|
842 |
+ |
procedure TIBStringField.SetSize(AValue: Integer); |
843 |
+ |
var FieldSize: integer; |
844 |
+ |
begin |
845 |
+ |
if csLoading in ComponentState then |
846 |
+ |
FInitialised := true; |
847 |
+ |
if FInitialised then |
848 |
+ |
inherited SetSize(AValue) |
849 |
+ |
else |
850 |
+ |
begin |
851 |
+ |
{IBCustomDataSet encodes the CharWidth size in the size} |
852 |
+ |
FieldSize := AValue div 4; |
853 |
+ |
inherited SetSize(FieldSize); |
854 |
+ |
DisplayWidth := FieldSize div ((AValue mod 4) + 1); |
855 |
+ |
FInitialised := true; |
856 |
+ |
end; |
857 |
+ |
end; |
858 |
+ |
|
859 |
|
{ TIBBCDField } |
860 |
|
|
861 |
|
constructor TIBBCDField.Create(AOwner: TComponent); |
953 |
|
CheckIBLoaded; |
954 |
|
FIBLoaded := True; |
955 |
|
FBase := TIBBase.Create(Self); |
956 |
+ |
FIBLinks := TList.Create; |
957 |
|
FCurrentRecord := -1; |
958 |
|
FDeletedRecords := 0; |
959 |
|
FUniDirectional := False; |
980 |
|
FParamCheck := True; |
981 |
|
FGenerateParamNames := False; |
982 |
|
FForcedRefresh := False; |
983 |
+ |
FAutoCommit:= acDisabled; |
984 |
+ |
FDataSetCloseAction := dcDiscardChanges; |
985 |
|
{Bookmark Size is Integer for IBX} |
986 |
|
BookmarkSize := SizeOf(Integer); |
987 |
|
FBase.BeforeDatabaseDisconnect := DoBeforeDatabaseDisconnect; |
1007 |
|
FDataLink.Free; |
1008 |
|
FBase.Free; |
1009 |
|
ClearBlobCache; |
1010 |
+ |
ClearIBLinks; |
1011 |
+ |
FIBLinks.Free; |
1012 |
|
FBlobStreamList.Free; |
1013 |
|
FreeMem(FBufferCache); |
1014 |
|
FBufferCache := nil; |
1453 |
|
FDatabaseFree(Sender); |
1454 |
|
end; |
1455 |
|
|
1456 |
< |
procedure TIBCustomDataSet.DoBeforeTransactionEnd(Sender: TObject); |
1456 |
> |
procedure TIBCustomDataSet.DoBeforeTransactionEnd(Sender: TObject; |
1457 |
> |
Action: TTransactionAction); |
1458 |
|
begin |
1459 |
< |
if Active then |
1460 |
< |
Active := False; |
1459 |
> |
FCloseAction := Action; |
1460 |
> |
FInTransactionEnd := true; |
1461 |
> |
try |
1462 |
> |
if Active then |
1463 |
> |
Active := False; |
1464 |
> |
finally |
1465 |
> |
FInTransactionEnd := false; |
1466 |
> |
end; |
1467 |
|
if FQSelect <> nil then |
1468 |
|
FQSelect.FreeHandle; |
1469 |
|
if FQDelete <> nil then |
1501 |
|
LocalData: Pointer; |
1502 |
|
LocalDate, LocalDouble: Double; |
1503 |
|
LocalInt: Integer; |
1504 |
+ |
LocalBool: wordBool; |
1505 |
|
LocalInt64: Int64; |
1506 |
|
LocalCurrency: Currency; |
1507 |
|
FieldsLoaded: Integer; |
1646 |
|
end; |
1647 |
|
end; |
1648 |
|
end; |
1649 |
+ |
SQL_BOOLEAN: |
1650 |
+ |
begin |
1651 |
+ |
LocalBool:= false; |
1652 |
+ |
rdFields[j].fdDataSize := SizeOf(wordBool); |
1653 |
+ |
if RecordNumber >= 0 then |
1654 |
+ |
LocalBool := Qry.Current[i].AsBoolean; |
1655 |
+ |
LocalData := PChar(@LocalBool); |
1656 |
+ |
end; |
1657 |
|
else { SQL_TEXT, SQL_BLOB, SQL_ARRAY, SQL_QUAD } |
1658 |
|
begin |
1659 |
|
rdFields[j].fdDataSize := Qry.Current[i].Data^.sqllen; |
1929 |
|
ofs: DWORD; |
1930 |
|
Qry: TIBSQL; |
1931 |
|
begin |
1932 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
1932 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
1933 |
> |
SetCursor := False |
1934 |
> |
else |
1935 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
1936 |
|
if SetCursor then |
1937 |
|
Screen.Cursor := crHourGlass; |
1938 |
|
try |
2056 |
|
if FInternalPrepared then |
2057 |
|
Exit; |
2058 |
|
DidActivate := False; |
2059 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
2059 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
2060 |
> |
SetCursor := False |
2061 |
> |
else |
2062 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
2063 |
|
if SetCursor then |
2064 |
|
Screen.Cursor := crHourGlass; |
2065 |
|
try |
2289 |
|
SQL_TIMESTAMP: |
2290 |
|
Qry.Params[i].AsDateTime := |
2291 |
|
TimeStampToDateTime(MSecsToTimeStamp(trunc(PDouble(data)^))); |
2292 |
+ |
SQL_BOOLEAN: |
2293 |
+ |
Qry.Params[i].AsBoolean := PWordBool(data)^; |
2294 |
|
end; |
2295 |
|
end; |
2296 |
|
end; |
2377 |
|
end; |
2378 |
|
end; |
2379 |
|
|
2380 |
+ |
procedure TIBCustomDataSet.RegisterIBLink(Sender: TIBControlLink); |
2381 |
+ |
begin |
2382 |
+ |
if FIBLinks.IndexOf(Sender) = -1 then |
2383 |
+ |
FIBLinks.Add(Sender); |
2384 |
+ |
end; |
2385 |
+ |
|
2386 |
|
|
2387 |
|
procedure TIBCustomDataSet.SQLChanging(Sender: TObject); |
2388 |
|
begin |
2421 |
|
end; |
2422 |
|
end; |
2423 |
|
|
2424 |
+ |
procedure TIBCustomDataSet.UnRegisterIBLink(Sender: TIBControlLink); |
2425 |
+ |
begin |
2426 |
+ |
FIBLinks.Remove(Sender); |
2427 |
+ |
end; |
2428 |
+ |
|
2429 |
|
function TIBCustomDataSet.UpdateStatus: TUpdateStatus; |
2430 |
|
begin |
2431 |
|
if Active then |
2655 |
|
inherited DoBeforeDelete; |
2656 |
|
end; |
2657 |
|
|
2658 |
+ |
procedure TIBCustomDataSet.DoAfterDelete; |
2659 |
+ |
begin |
2660 |
+ |
inherited DoAfterDelete; |
2661 |
+ |
FBase.DoAfterDelete(self); |
2662 |
+ |
InternalAutoCommit; |
2663 |
+ |
end; |
2664 |
+ |
|
2665 |
|
procedure TIBCustomDataSet.DoBeforeEdit; |
2666 |
|
var |
2667 |
|
Buff: PRecordData; |
2676 |
|
inherited DoBeforeEdit; |
2677 |
|
end; |
2678 |
|
|
2679 |
+ |
procedure TIBCustomDataSet.DoAfterEdit; |
2680 |
+ |
begin |
2681 |
+ |
inherited DoAfterEdit; |
2682 |
+ |
FBase.DoAfterEdit(self); |
2683 |
+ |
end; |
2684 |
+ |
|
2685 |
|
procedure TIBCustomDataSet.DoBeforeInsert; |
2686 |
|
begin |
2687 |
|
if not CanInsert then |
2694 |
|
if GeneratorField.ApplyOnEvent = gaeOnNewRecord then |
2695 |
|
GeneratorField.Apply; |
2696 |
|
inherited DoAfterInsert; |
2697 |
+ |
FBase.DoAfterInsert(self); |
2698 |
+ |
end; |
2699 |
+ |
|
2700 |
+ |
procedure TIBCustomDataSet.DoBeforeClose; |
2701 |
+ |
begin |
2702 |
+ |
inherited DoBeforeClose; |
2703 |
+ |
if State in [dsInsert,dsEdit] then |
2704 |
+ |
begin |
2705 |
+ |
if FInTransactionEnd and (FCloseAction = TARollback) then |
2706 |
+ |
Exit; |
2707 |
+ |
|
2708 |
+ |
if DataSetCloseAction = dcSaveChanges then |
2709 |
+ |
Post; |
2710 |
+ |
{Note this can fail with an exception e.g. due to |
2711 |
+ |
database validation error. In which case the dataset remains open } |
2712 |
+ |
end; |
2713 |
|
end; |
2714 |
|
|
2715 |
|
procedure TIBCustomDataSet.DoBeforeOpen; |
2716 |
+ |
var i: integer; |
2717 |
|
begin |
2718 |
|
if assigned(FParser) then |
2719 |
|
FParser.Reset; |
2720 |
< |
DataEvent(deCheckBrowseMode,1); {Conventional use to report getting ready to prepare} |
2720 |
> |
for i := 0 to FIBLinks.Count - 1 do |
2721 |
> |
TIBControlLink(FIBLinks[i]).UpdateSQL(self); |
2722 |
|
inherited DoBeforeOpen; |
2723 |
< |
DataEvent(deCheckBrowseMode,2); {Conventional use to report the right time to set parameters} |
2723 |
> |
for i := 0 to FIBLinks.Count - 1 do |
2724 |
> |
TIBControlLink(FIBLinks[i]).UpdateParams(self); |
2725 |
|
end; |
2726 |
|
|
2727 |
|
procedure TIBCustomDataSet.DoBeforePost; |
2732 |
|
GeneratorField.Apply |
2733 |
|
end; |
2734 |
|
|
2735 |
+ |
procedure TIBCustomDataSet.DoAfterPost; |
2736 |
+ |
begin |
2737 |
+ |
inherited DoAfterPost; |
2738 |
+ |
FBase.DoAfterPost(self); |
2739 |
+ |
InternalAutoCommit; |
2740 |
+ |
end; |
2741 |
+ |
|
2742 |
|
procedure TIBCustomDataSet.FetchAll; |
2743 |
|
var |
2744 |
|
SetCursor: Boolean; |
2748 |
|
CurBookmark: string; |
2749 |
|
{$ENDIF} |
2750 |
|
begin |
2751 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
2751 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
2752 |
> |
SetCursor := False |
2753 |
> |
else |
2754 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
2755 |
|
if SetCursor then |
2756 |
|
Screen.Cursor := crHourGlass; |
2757 |
|
try |
2873 |
|
Data := Buff + CurrentRecord^.rdFields[FMappedFieldPosition[Field.FieldNo - 1]].fdDataOfs; |
2874 |
|
if (fdDataType = SQL_VARYING) or (fdDataType = SQL_TEXT) then |
2875 |
|
begin |
2876 |
< |
if fdDataLength <= Field.Size then |
2876 |
> |
if fdDataLength < Field.DataSize then |
2877 |
|
begin |
2878 |
|
Move(Data^, Buffer^, fdDataLength); |
2879 |
|
PChar(Buffer)[fdDataLength] := #0; |
3016 |
|
result := FRecordBufferSize; |
3017 |
|
end; |
3018 |
|
|
3019 |
+ |
procedure TIBCustomDataSet.InternalAutoCommit; |
3020 |
+ |
begin |
3021 |
+ |
with Transaction do |
3022 |
+ |
if InTransaction and (FAutoCommit = acCommitRetaining) then |
3023 |
+ |
begin |
3024 |
+ |
if CachedUpdates then ApplyUpdates; |
3025 |
+ |
CommitRetaining; |
3026 |
+ |
end; |
3027 |
+ |
end; |
3028 |
+ |
|
3029 |
|
procedure TIBCustomDataSet.InternalAddRecord(Buffer: Pointer; Append: Boolean); |
3030 |
|
begin |
3031 |
|
CheckEditState; |
3105 |
|
Buff: PChar; |
3106 |
|
SetCursor: Boolean; |
3107 |
|
begin |
3108 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3108 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
3109 |
> |
SetCursor := False |
3110 |
> |
else |
3111 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3112 |
|
if SetCursor then |
3113 |
|
Screen.Cursor := crHourGlass; |
3114 |
|
try |
3177 |
|
var |
3178 |
|
FieldType: TFieldType; |
3179 |
|
FieldSize: Word; |
3180 |
+ |
CharSetSize: integer; |
3181 |
|
FieldNullable : Boolean; |
3182 |
|
i, FieldPosition, FieldPrecision: Integer; |
3183 |
|
FieldAliasName, DBAliasName: string; |
3313 |
|
their values } |
3314 |
|
SQL_VARYING, SQL_TEXT: |
3315 |
|
begin |
3316 |
< |
FieldSize := sqllen; |
3316 |
> |
CharSetSize := FBase.GetCharSetSize(sqlsubtype and $FF); |
3317 |
> |
{FieldSize is encoded for strings - see TIBStringField.SetSize for decode} |
3318 |
> |
FieldSize := sqllen * 4 + (CharSetSize - 1); |
3319 |
|
FieldType := ftString; |
3320 |
|
end; |
3321 |
|
{ All Doubles/Floats should be cast to doubles } |
3384 |
|
FieldSize := sizeof (TISC_QUAD); |
3385 |
|
FieldType := ftUnknown; |
3386 |
|
end; |
3387 |
+ |
SQL_BOOLEAN: |
3388 |
+ |
FieldType:= ftBoolean; |
3389 |
|
else |
3390 |
|
FieldType := ftUnknown; |
3391 |
|
end; |
3482 |
|
else case cur_field.DataType of |
3483 |
|
ftString: |
3484 |
|
cur_param.AsString := cur_field.AsString; |
3485 |
< |
ftBoolean, ftSmallint, ftWord: |
3485 |
> |
ftBoolean: |
3486 |
> |
cur_param.AsBoolean := cur_field.AsBoolean; |
3487 |
> |
ftSmallint, ftWord: |
3488 |
|
cur_param.AsShort := cur_field.AsInteger; |
3489 |
|
ftInteger: |
3490 |
|
cur_param.AsLong := cur_field.AsInteger; |
3546 |
|
end; |
3547 |
|
|
3548 |
|
begin |
3549 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3549 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
3550 |
> |
SetCursor := False |
3551 |
> |
else |
3552 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3553 |
|
if SetCursor then |
3554 |
|
Screen.Cursor := crHourGlass; |
3555 |
|
try |
3624 |
|
SetCursor: Boolean; |
3625 |
|
bInserting: Boolean; |
3626 |
|
begin |
3627 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3627 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
3628 |
> |
SetCursor := False |
3629 |
> |
else |
3630 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3631 |
|
if SetCursor then |
3632 |
|
Screen.Cursor := crHourGlass; |
3633 |
|
try |
3695 |
|
inherited Loaded; |
3696 |
|
end; |
3697 |
|
|
3698 |
+ |
procedure TIBCustomDataSet.Post; |
3699 |
+ |
var CancelPost: boolean; |
3700 |
+ |
begin |
3701 |
+ |
CancelPost := false; |
3702 |
+ |
if assigned(FOnValidatePost) then |
3703 |
+ |
OnValidatePost(self,CancelPost); |
3704 |
+ |
if CancelPost then |
3705 |
+ |
Cancel |
3706 |
+ |
else |
3707 |
+ |
inherited Post; |
3708 |
+ |
end; |
3709 |
+ |
|
3710 |
|
function TIBCustomDataSet.Locate(const KeyFields: string; const KeyValues: Variant; |
3711 |
|
Options: TLocateOptions): Boolean; |
3712 |
|
var |
3908 |
|
FillChar(Buffer[FRecordSize], CalcFieldsSize, 0); |
3909 |
|
end; |
3910 |
|
|
3911 |
+ |
procedure TIBCustomDataSet.ClearIBLinks; |
3912 |
+ |
var i: integer; |
3913 |
+ |
begin |
3914 |
+ |
for i := FIBLinks.Count - 1 downto 0 do |
3915 |
+ |
TIBControlLink(FIBLinks[i]).IBDataSet := nil; |
3916 |
+ |
end; |
3917 |
+ |
|
3918 |
|
|
3919 |
|
procedure TIBCustomDataSet.InternalUnPrepare; |
3920 |
|
begin |
3934 |
|
SetCursor: Boolean; |
3935 |
|
begin |
3936 |
|
DidActivate := False; |
3937 |
< |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3937 |
> |
if Assigned(Database) and not Database.SQLHourGlass then |
3938 |
> |
SetCursor := False |
3939 |
> |
else |
3940 |
> |
SetCursor := (GetCurrentThreadID = MainThreadID) and (Screen.Cursor = crDefault); |
3941 |
|
if SetCursor then |
3942 |
|
Screen.Cursor := crHourGlass; |
3943 |
|
try |
4402 |
|
Owner.FieldByName(FFieldName).AsInteger := GetNextValue(Owner.Database,Owner.Transaction); |
4403 |
|
end; |
4404 |
|
|
4405 |
< |
end. |
4405 |
> |
end. |