Menu
▾
▴
[Instantobjects-cvscommit] SF.net SVN: instantobjects:[800] branches/BrokerDev
|
From: <Dav...@us...> - 2009-03-21 23:32:35
|
Revision: 800
http://instantobjects.svn.sourceforge.net/instantobjects/revision/?rev=800&view=rev
Author: DavidVTaylor
Date: 2009-03-21 23:32:31 +0000 (Sat, 21 Mar 2009)
Log Message:
-----------
Initial import of AnyDAC broker development (Delphi 2007 only)
Added Paths:
-----------
branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dpk
branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dproj
branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.res
branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dpk
branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dproj
branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.res
branches/BrokerDev/AnyDAC/InstantAnyDAC.dcr
branches/BrokerDev/AnyDAC/InstantAnyDAC.pas
branches/BrokerDev/AnyDAC/InstantAnyDAC.res
branches/BrokerDev/AnyDAC/InstantAnyDACCatalog.pas
branches/BrokerDev/AnyDAC/InstantAnyDACConnectionDefEdit.dfm
branches/BrokerDev/AnyDAC/InstantAnyDACConnectionDefEdit.pas
branches/BrokerDev/AnyDAC/InstantAnyDACReg.pas
Removed Paths:
-------------
branches/BrokerDev/InstantAnyDAC.dcr
Added: branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dpk
===================================================================
--- branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dpk (rev 0)
+++ branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dpk 2009-03-21 23:32:31 UTC (rev 800)
@@ -0,0 +1,39 @@
+package DclIOAnyDAC;
+
+{$R *.res}
+{$R '..\InstantAnyDAC.dcr'}
+
+{$ALIGN 8}
+{$ASSERTIONS ON}
+{$BOOLEVAL OFF}
+{$DEBUGINFO ON}
+{$EXTENDEDSYNTAX ON}
+{$IMPORTEDDATA ON}
+{$IOCHECKS ON}
+{$LOCALSYMBOLS ON}
+{$LONGSTRINGS ON}
+{$OPENSTRINGS ON}
+{$OPTIMIZATION ON}
+{$OVERFLOWCHECKS OFF}
+{$RANGECHECKS OFF}
+{$REFERENCEINFO ON}
+{$SAFEDIVIDE OFF}
+{$STACKFRAMES OFF}
+{$TYPEDADDRESS ON}
+{$VARSTRINGCHECKS ON}
+{$WRITEABLECONST OFF}
+{$MINENUMSIZE 1}
+{$IMAGEBASE $400000}
+{$DESCRIPTION 'InstantObjects AnyDAC Design-Time Support (Delphi 2007)'}
+{$LIBSUFFIX '_D11'}
+{$DESIGNONLY}
+{$IMPLICITBUILD OFF}
+
+requires
+ IOAnyDAC;
+
+contains
+ InstantAnyDACReg in '..\InstantAnyDACReg.pas';
+
+end.
+
Property changes on: branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dpk
___________________________________________________________________
Added: svn:mime-type
+ text/plain
Added: svn:keywords
+ Id
Added: svn:eol-style
+ native
Added: branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dproj
===================================================================
--- branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dproj (rev 0)
+++ branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dproj 2009-03-21 23:32:31 UTC (rev 800)
@@ -0,0 +1,131 @@
+<Project xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+ <PropertyGroup>
+ <ProjectGuid>{bd7f8385-a35b-4433-9704-0c5a664a70de}</ProjectGuid>
+ <MainSource>DclIOAnyDAC.dpk</MainSource>
+ <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
+ <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
+ <DCC_DCCCompiler>DCC32</DCC_DCCCompiler>
+ <DCC_DependencyCheckOutputName>C:\Documents and Settings\All Users\Documents\RAD Studio\5.0\Bpl\DclIOAnyDAC_D11.bpl</DCC_DependencyCheckOutputName>
+ </PropertyGroup>
+ <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
+ <Version>7.0</Version>
+ <DCC_DebugInformation>False</DCC_DebugInformation>
+ <DCC_LocalDebugSymbols>False</DCC_LocalDebugSymbols>
+ <DCC_TypedAtParameter>True</DCC_TypedAtParameter>
+ <DCC_SymbolReferenceInfo>0</DCC_SymbolReferenceInfo>
+ <DCC_Define>RELEASE</DCC_Define>
+ </PropertyGroup>
+ <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
+ <Version>7.0</Version>
+ <DCC_TypedAtParameter>True</DCC_TypedAtParameter>
+ </PropertyGroup>
+ <ProjectExtensions>
+ <Borland.Personality>Delphi.Personality</Borland.Personality>
+ <Borland.ProjectType>Package</Borland.ProjectType>
+ <BorlandProject>
+<BorlandProject xmlns=""> <Delphi.Personality> <Parameters>
+ <Parameters Name="UseLauncher">False</Parameters>
+ <Parameters Name="LoadAllSymbols">True</Parameters>
+ <Parameters Name="LoadUnspecifiedSymbols">False</Parameters>
+ </Parameters>
+ <Package_Options>
+ <Package_Options Name="PackageDescription">InstantObjects AnyDAC Design-Time Support (Delphi 2007)</Package_Options>
+ <Package_Options Name="ImplicitBuild">False</Package_Options>
+ <Package_Options Name="DesigntimeOnly">True</Package_Options>
+ <Package_Options Name="RuntimeOnly">False</Package_Options>
+ <Package_Options Name="LibSuffix">_D11</Package_Options>
+ </Package_Options>
+ <VersionInfo>
+ <VersionInfo Name="IncludeVerInfo">True</VersionInfo>
+ <VersionInfo Name="AutoIncBuild">False</VersionInfo>
+ <VersionInfo Name="MajorVer">1</VersionInfo>
+ <VersionInfo Name="MinorVer">0</VersionInfo>
+ <VersionInfo Name="Release">0</VersionInfo>
+ <VersionInfo Name="Build">0</VersionInfo>
+ <VersionInfo Name="Debug">False</VersionInfo>
+ <VersionInfo Name="PreRelease">False</VersionInfo>
+ <VersionInfo Name="Special">False</VersionInfo>
+ <VersionInfo Name="Private">False</VersionInfo>
+ <VersionInfo Name="DLL">False</VersionInfo>
+ <VersionInfo Name="Locale">1033</VersionInfo>
+ <VersionInfo Name="CodePage">1252</VersionInfo>
+ </VersionInfo>
+ <VersionInfoKeys>
+ <VersionInfoKeys Name="CompanyName"></VersionInfoKeys>
+ <VersionInfoKeys Name="FileDescription"></VersionInfoKeys>
+ <VersionInfoKeys Name="FileVersion">1.0.0.0</VersionInfoKeys>
+ <VersionInfoKeys Name="InternalName"></VersionInfoKeys>
+ <VersionInfoKeys Name="LegalCopyright"></VersionInfoKeys>
+ <VersionInfoKeys Name="LegalTrademarks"></VersionInfoKeys>
+ <VersionInfoKeys Name="OriginalFilename"></VersionInfoKeys>
+ <VersionInfoKeys Name="ProductName"></VersionInfoKeys>
+ <VersionInfoKeys Name="ProductVersion">1.0.0.0</VersionInfoKeys>
+ <VersionInfoKeys Name="Comments"></VersionInfoKeys>
+ </VersionInfoKeys>
+ <Excluded_Packages>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ <Excluded_Packages Name="$(BDS)\bin\bcboffice2k100.bpl">CodeGear C++Builder Office 2000 Servers Package</Excluded_Packages>
+ <Excluded_Packages Name="$(BDS)\bin\bcbofficexp100.bpl">CodeGear C++Builder Office XP Servers Package</Excluded_Packages>
+ <Excluded_Packages Name="$(BDS)\bin\dcloffice2k100.bpl">Microsoft Office 2000 Sample Automation Server Wrapper Components</Excluded_Packages>
+ <Excluded_Packages Name="$(BDS)\bin\dclofficexp100.bpl">Microsoft Office XP Sample Automation Server Wrapper Components</Excluded_Packages>
+ </Excluded_Packages>
+ <Source>
+ <Source Name="MainSource">DclIOAnyDAC.dpk</Source>
+ </Source>
+ </Delphi.Personality> </BorlandProject></BorlandProject>
+ </ProjectExtensions>
+ <ItemGroup />
+ <ItemGroup>
+ <DelphiCompile Include="DclIOAnyDAC.dpk">
+ <MainSource>MainSource</MainSource>
+ </DelphiCompile>
+ <DCCReference Include="..\InstantAnyDAC.dcr" />
+ <DCCReference Include="..\InstantAnyDAC.dcr" />
+ <DCCReference Include="..\InstantAnyDACReg.pas" />
+ <DCCReference Include="IOAnyDAC.dcp" />
+ </ItemGroup>
+ <Import Project="$(MSBuildBinPath)\Borland.Delphi.Targets" />
+</Project>
\ No newline at end of file
Property changes on: branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.dproj
___________________________________________________________________
Added: svn:mime-type
+ text/plain
Added: svn:keywords
+ Id
Added: svn:eol-style
+ native
Added: branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.res
===================================================================
(Binary files differ)
Property changes on: branches/BrokerDev/AnyDAC/D2007/DclIOAnyDAC.res
___________________________________________________________________
Added: svn:mime-type
+ application/octet-stream
Added: branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dpk
===================================================================
--- branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dpk (rev 0)
+++ branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dpk 2009-03-21 23:32:31 UTC (rev 800)
@@ -0,0 +1,42 @@
+package IOAnyDAC;
+
+{$R *.res}
+{$ALIGN 8}
+{$ASSERTIONS ON}
+{$BOOLEVAL OFF}
+{$DEBUGINFO ON}
+{$EXTENDEDSYNTAX ON}
+{$IMPORTEDDATA ON}
+{$IOCHECKS ON}
+{$LOCALSYMBOLS ON}
+{$LONGSTRINGS ON}
+{$OPENSTRINGS ON}
+{$OPTIMIZATION ON}
+{$OVERFLOWCHECKS OFF}
+{$RANGECHECKS OFF}
+{$REFERENCEINFO ON}
+{$SAFEDIVIDE OFF}
+{$STACKFRAMES OFF}
+{$TYPEDADDRESS ON}
+{$VARSTRINGCHECKS ON}
+{$WRITEABLECONST OFF}
+{$MINENUMSIZE 1}
+{$IMAGEBASE $400000}
+{$DESCRIPTION 'InstantObjects AnyDAC Run-Time Support (Delphi 2007)'}
+{$LIBSUFFIX '_D11'}
+{$RUNONLY}
+{$IMPLICITBUILD OFF}
+
+requires
+ IOCore,
+ xmlrtl,
+ AnyDAC_Phys_D11,
+ AnyDAC_ComI_D11,
+ AnyDAC_Comp_D11;
+
+contains
+ InstantAnyDAC in '..\InstantAnyDAC.pas',
+ InstantAnyDACCatalog in '..\InstantAnyDACCatalog.pas',
+ InstantAnyDACConnectionDefEdit in '..\InstantAnyDACConnectionDefEdit.pas' {InstantAnyDACConnectionDefEditForm};
+
+end.
Property changes on: branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dpk
___________________________________________________________________
Added: svn:mime-type
+ text/plain
Added: svn:keywords
+ Id
Added: svn:eol-style
+ native
Added: branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dproj
===================================================================
--- branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dproj (rev 0)
+++ branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dproj 2009-03-21 23:32:31 UTC (rev 800)
@@ -0,0 +1,102 @@
+<Project xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+ <PropertyGroup>
+ <ProjectGuid>{97b73472-7b2c-4fb3-bff7-971ec36c17ad}</ProjectGuid>
+ <MainSource>IOAnyDAC.dpk</MainSource>
+ <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
+ <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
+ <DCC_DCCCompiler>DCC32</DCC_DCCCompiler>
+ <DCC_DependencyCheckOutputName>C:\Documents and Settings\All Users\Documents\RAD Studio\5.0\Bpl\IOAnyDAC_D11.bpl</DCC_DependencyCheckOutputName>
+ </PropertyGroup>
+ <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
+ <Version>7.0</Version>
+ <DCC_DebugInformation>False</DCC_DebugInformation>
+ <DCC_LocalDebugSymbols>False</DCC_LocalDebugSymbols>
+ <DCC_TypedAtParameter>True</DCC_TypedAtParameter>
+ <DCC_SymbolReferenceInfo>0</DCC_SymbolReferenceInfo>
+ <DCC_Define>RELEASE</DCC_Define>
+ </PropertyGroup>
+ <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
+ <Version>7.0</Version>
+ <DCC_TypedAtParameter>True</DCC_TypedAtParameter>
+ <DCC_Define>DEBUG</DCC_Define>
+ </PropertyGroup>
+ <ProjectExtensions>
+ <Borland.Personality>Delphi.Personality</Borland.Personality>
+ <Borland.ProjectType>Package</Borland.ProjectType>
+ <BorlandProject>
+<BorlandProject xmlns=""> <Delphi.Personality> <Parameters>
+ <Parameters Name="UseLauncher">False</Parameters>
+ <Parameters Name="LoadAllSymbols">True</Parameters>
+ <Parameters Name="LoadUnspecifiedSymbols">False</Parameters>
+ </Parameters>
+ <Package_Options>
+ <Package_Options Name="PackageDescription">InstantObjects AnyDAC Run-Time Support (Delphi 2007)</Package_Options>
+ <Package_Options Name="ImplicitBuild">False</Package_Options>
+ <Package_Options Name="DesigntimeOnly">False</Package_Options>
+ <Package_Options Name="RuntimeOnly">True</Package_Options>
+ <Package_Options Name="LibSuffix">_D11</Package_Options>
+ </Package_Options>
+ <VersionInfo>
+ <VersionInfo Name="IncludeVerInfo">True</VersionInfo>
+ <VersionInfo Name="AutoIncBuild">False</VersionInfo>
+ <VersionInfo Name="MajorVer">1</VersionInfo>
+ <VersionInfo Name="MinorVer">0</VersionInfo>
+ <VersionInfo Name="Release">0</VersionInfo>
+ <VersionInfo Name="Build">0</VersionInfo>
+ <VersionInfo Name="Debug">False</VersionInfo>
+ <VersionInfo Name="PreRelease">False</VersionInfo>
+ <VersionInfo Name="Special">False</VersionInfo>
+ <VersionInfo Name="Private">False</VersionInfo>
+ <VersionInfo Name="DLL">False</VersionInfo>
+ <VersionInfo Name="Locale">1033</VersionInfo>
+ <VersionInfo Name="CodePage">1252</VersionInfo>
+ </VersionInfo>
+ <VersionInfoKeys>
+ <VersionInfoKeys Name="CompanyName"></VersionInfoKeys>
+ <VersionInfoKeys Name="FileDescription"></VersionInfoKeys>
+ <VersionInfoKeys Name="FileVersion">1.0.0.0</VersionInfoKeys>
+ <VersionInfoKeys Name="InternalName"></VersionInfoKeys>
+ <VersionInfoKeys Name="LegalCopyright"></VersionInfoKeys>
+ <VersionInfoKeys Name="LegalTrademarks"></VersionInfoKeys>
+ <VersionInfoKeys Name="OriginalFilename"></VersionInfoKeys>
+ <VersionInfoKeys Name="ProductName"></VersionInfoKeys>
+ <VersionInfoKeys Name="ProductVersion">1.0.0.0</VersionInfoKeys>
+ <VersionInfoKeys Name="Comments"></VersionInfoKeys>
+ </VersionInfoKeys>
+ <Excluded_Packages>
+
+
+
+
+
+
+
+
+ <Excluded_Packages Name="$(BDS)\bin\bcboffice2k100.bpl">CodeGear C++Builder Office 2000 Servers Package</Excluded_Packages>
+ <Excluded_Packages Name="$(BDS)\bin\bcbofficexp100.bpl">CodeGear C++Builder Office XP Servers Package</Excluded_Packages>
+ <Excluded_Packages Name="$(BDS)\bin\dcloffice2k100.bpl">Microsoft Office 2000 Sample Automation Server Wrapper Components</Excluded_Packages>
+ <Excluded_Packages Name="$(BDS)\bin\dclofficexp100.bpl">Microsoft Office XP Sample Automation Server Wrapper Components</Excluded_Packages>
+ </Excluded_Packages>
+ <Source>
+ <Source Name="MainSource">IOAnyDAC.dpk</Source>
+ </Source>
+ </Delphi.Personality> </BorlandProject></BorlandProject>
+ </ProjectExtensions>
+ <ItemGroup />
+ <ItemGroup>
+ <DelphiCompile Include="IOAnyDAC.dpk">
+ <MainSource>MainSource</MainSource>
+ </DelphiCompile>
+ <DCCReference Include="..\InstantAnyDAC.pas" />
+ <DCCReference Include="..\InstantAnyDACCatalog.pas" />
+ <DCCReference Include="..\InstantAnyDACConnectionDefEdit.pas">
+ <Form>InstantAnyDACConnectionDefEditForm</Form>
+ </DCCReference>
+ <DCCReference Include="AnyDAC_ComI_D11.dcp" />
+ <DCCReference Include="AnyDAC_Comp_D11.dcp" />
+ <DCCReference Include="AnyDAC_Phys_D11.dcp" />
+ <DCCReference Include="IOCore.dcp" />
+ <DCCReference Include="xmlrtl.dcp" />
+ </ItemGroup>
+ <Import Project="$(MSBuildBinPath)\Borland.Delphi.Targets" />
+</Project>
\ No newline at end of file
Property changes on: branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.dproj
___________________________________________________________________
Added: svn:mime-type
+ text/plain
Added: svn:keywords
+ Id
Added: svn:eol-style
+ native
Added: branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.res
===================================================================
(Binary files differ)
Property changes on: branches/BrokerDev/AnyDAC/D2007/IOAnyDAC.res
___________________________________________________________________
Added: svn:mime-type
+ application/octet-stream
Added: branches/BrokerDev/AnyDAC/InstantAnyDAC.dcr
===================================================================
(Binary files differ)
Property changes on: branches/BrokerDev/AnyDAC/InstantAnyDAC.dcr
___________________________________________________________________
Added: svn:mime-type
+ application/octet-stream
Added: branches/BrokerDev/AnyDAC/InstantAnyDAC.pas
===================================================================
--- branches/BrokerDev/AnyDAC/InstantAnyDAC.pas (rev 0)
+++ branches/BrokerDev/AnyDAC/InstantAnyDAC.pas 2009-03-21 23:32:31 UTC (rev 800)
@@ -0,0 +1,1356 @@
+(*
+ * InstantObjects
+ * RemObjects AnyDAC 2.0 Support
+ *)
+
+(* ***** BEGIN LICENSE BLOCK *****
+ * Version: MPL 1.1
+ *
+ * The contents of this file are subject to the Mozilla Public License Version
+ * 1.1 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * http://www.mozilla.org/MPL/
+ *
+ * Software distributed under the License is distributed on an "AS IS" basis,
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+ * for the specific language governing rights and limitations under the
+ * License.
+ *
+ * The Original Code is: InstantObjects AnyDAC Support
+ *
+ * The Initial Developer of the Original Code is: David Taylor
+ *
+ * Portions created by the Initial Developer are Copyright (C) 2009
+ * the Initial Developer. All Rights Reserved.
+ *
+ * Contributor(s):
+ *
+ * ***** END LICENSE BLOCK ***** *)
+
+unit InstantAnyDAC;
+
+{$IFDEF LINUX}
+{$I '../../InstantDefines.inc'}
+{$ELSE}
+{$I '..\..\InstantDefines.inc'}
+{$ENDIF}
+
+// Supported databases (only MSSQL has been tested as of 3/21/2009)
+
+{$DEFINE SYBASE_SUPPORT}
+{$DEFINE MSSQL_SUPPORT}
+{$DEFINE IBFB_SUPPORT}
+{$DEFINE ORACLE_SUPPORT}
+{$DEFINE PGSQL_SUPPORT}
+{-- Broken: Not converted to AnyDAC -- $DEFINE MYSQL_SUPPORT}
+{$DEFINE SQLITE_SUPPORT}
+
+interface
+
+uses
+ Classes, Db, InstantPersistence, InstantCommand, InstantDBBuild,
+ InstantBrokers, InstantMetadata, InstantTypes, uADCompClient,
+ uADStanOption, uADStanParam, uADStanIntf, uADStanConst
+ {$IFDEF D10+}, DBCommonTypes{$ENDIF};
+
+type
+ TInstantAnyDACConnectionDef = class(TInstantRelationalConnectionDef)
+ private
+ FCatalog : string;
+ FDatabase : string;
+ FHostName : string;
+ FLoginPrompt : boolean;
+ FPassword : string;
+ FPort : integer;
+ FProperties : string;
+ FProtocol : string;
+ FUseDelimitedIdents : boolean;
+ FUserName : string;
+ protected
+ procedure InitConnector(Connector: TInstantConnector); override;
+ public
+ function Edit: Boolean; override;
+ class function ConnectionTypeName: string; override;
+ class function ConnectorClass: TInstantConnectorClass; override;
+ published
+ property Catalog: string read FCatalog write FCatalog;
+ property Database: string read FDatabase write FDatabase;
+ property HostName: string read FHostName write FHostName;
+ property LoginPrompt: boolean read FLoginPrompt write FLoginPrompt;
+ property Password: string read FPassword write FPassword;
+ property Port: Integer read FPort write FPort;
+ property Properties: string read FProperties write FProperties;
+ property Protocol: string read FProtocol write FProtocol;
+ property UseDelimitedIdents: boolean read FUseDelimitedIdents write FUseDelimitedIdents;
+ property UserName: string read FUserName write FUserName;
+ end;
+
+ TInstantAnyDACBroker = class;
+
+ TInstantAnyDACConnector = class(TInstantRelationalConnector)
+ private
+ FConnection : TADConnection;
+ FLoginPrompt : Boolean;
+ FOnLogin : TLoginEvent;
+ FUseDelimitedIdents : Boolean;
+ procedure DoAfterConnectionChange;
+ procedure DoBeforeConnectionChange;
+ function GetBroker: TInstantAnyDACBroker;
+ function GetConnection: TADConnection;
+ function GetLoginPrompt: Boolean;
+ procedure SetConnection(Value: TADConnection);
+ procedure SetLoginPrompt(const Value: Boolean);
+ procedure SetUseDelimitedIdents(const Value: Boolean);
+ protected
+ procedure AfterConnectionChange; virtual;
+ procedure BeforeConnectionChange; virtual;
+ procedure AssignLoginOptions; virtual;
+ procedure CheckConnection;
+ function CreateBroker: TInstantBroker; override;
+ procedure DoLogin(AConnection: TADCustomConnection;
+ const AConnectionDef: IADStanConnectionDef); virtual;
+ function GetConnected: Boolean; override;
+ function GetDatabaseExists: Boolean; override;
+ procedure InternalBuildDatabase(Scheme: TInstantScheme); override;
+ procedure InternalCommitTransaction; override;
+ procedure InternalConnect; override;
+ procedure InternalCreateDatabase; override;
+ procedure InternalDisconnect; override;
+ procedure InternalRollbackTransaction; override;
+ procedure InternalStartTransaction; override;
+ procedure Notification(AComponent: TComponent; Operation: TOperation); override;
+ function ParamByName(const AName: string): string;
+ public
+ constructor Create(AOwner: TComponent); override;
+ class function ConnectionDefClass: TInstantConnectionDefClass; override;
+ function HasConnection: Boolean;
+ property Broker: TInstantAnyDACBroker read GetBroker;
+ published
+ property Connection: TADConnection read GetConnection write SetConnection;
+ property LoginPrompt: Boolean read GetLoginPrompt write SetLoginPrompt default False;
+ property OnLogin: TLoginEvent read FOnLogin write FOnLogin;
+ property UseDelimitedIdents: Boolean read FUseDelimitedIdents write SetUseDelimitedIdents default False;
+ end;
+
+ TInstantAnyDACBroker = class(TInstantSQLBroker)
+ private
+ function GetConnector: TInstantAnyDACConnector;
+ protected
+ procedure AssignDataSetParams(DataSet: TDataSet; AParams: TParams); override;
+ procedure AssignParam(SourceParam: TParam; TargetParam: TADParam); virtual;
+ function CreateCatalog(const AScheme: TInstantScheme): TInstantCatalog; override;
+ function CreateResolver(Map: TInstantAttributeMap): TInstantSQLResolver; override;
+ function GetDatabaseName: string; override;
+ function GetDBMSName: string; override;
+ function GetSQLDelimiters: string; override;
+ function GetSQLQuote: Char; override;
+ procedure InternalCreateDatabase; virtual;
+ function InternalCreateQuery: TInstantQuery; override;
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; virtual; abstract;
+ function InternalDBNotExistsErrorCode: Integer; virtual;
+ function UseBooleanFields: Boolean; virtual; abstract;
+ public
+ procedure CreateDatabase;
+ function CreateDataSet(const AStatement: string; AParams: TParams = nil): TDataSet; override;
+ function CreateDBBuildCommand(const CommandType: TInstantDBBuildCommandType): TInstantDBBuildCommand; override;
+ function DataTypeToColumnType(DataType: TInstantDataType; Size: Integer): string; override;
+ function Execute(const AStatement: string; AParams: TParams = nil): Integer; override;
+ function DBNotExistsErrorCode: Integer;
+ property Connector: TInstantAnyDACConnector read GetConnector;
+ end;
+
+ //
+ // Resolver that interprets an integer column value as a boolean
+ //
+ TInstantAnyDACResolver = class(TInstantSQLResolver)
+ protected
+ function ReadBooleanField(DataSet: TDataSet; const FieldName: string): Boolean; override;
+ end;
+
+ //
+ // Translator that translates a boolean value to a '0' or '1'
+ //
+ TInstantAnyDACTranslator = class(TInstantRelationalTranslator)
+ protected
+ function TranslateConstant(Constant: TInstantIQLConstant; Writer: TInstantIQLWriter): Boolean; override;
+ end;
+
+ TInstantAnyDACQuery = class(TInstantSQLQuery)
+ protected
+ class function TranslatorClass: TInstantRelationalTranslatorClass; override;
+ end;
+
+ { Sybase broker }
+
+ {$IFDEF SYBASE_SUPPORT}
+ TInstantAnyDACSybaseBroker = class(TInstantAnyDACBroker)
+ protected
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; override;
+ function UseBooleanFields: Boolean; override;
+ end;
+ {$ENDIF}
+
+ { MS SQL Server broker }
+
+ {$IFDEF MSSQL_SUPPORT}
+ TInstantAnyDACMSSQLBroker = class(TInstantAnyDACBroker)
+ protected
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; override;
+ function UseBooleanFields: Boolean; override;
+ end;
+ {$ENDIF}
+
+ { Interbase and Firebird brokers }
+
+ {$IFDEF IBFB_SUPPORT}
+ TInstantAnyDACIbFbBroker = class(TInstantAnyDACBroker)
+ protected
+ procedure InternalCreateDatabase; override;
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; override;
+ function InternalDBNotExistsErrorCode: Integer; override;
+ function UseBooleanFields: Boolean; override;
+ end;
+ {$ENDIF}
+
+ { Oracle broker }
+
+ {$IFDEF ORACLE_SUPPORT}
+ TInstantAnyDACOracleBroker = class(TInstantAnyDACBroker)
+ protected
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; override;
+ function UseBooleanFields: Boolean; override;
+ end;
+ {$ENDIF}
+
+ { PostgreSQL broker }
+
+ {$IFDEF PGSQL_SUPPORT}
+ TInstantAnyDACPgSQLBroker = class(TInstantAnyDACBroker)
+ protected
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; override;
+ function UseBooleanFields: Boolean; override;
+ end;
+ {$ENDIF}
+
+ { MySQL broker }
+
+ {$IFDEF MYSQL_SUPPORT}
+ TInstantMySQLGenerator = class(TInstantSQLGenerator)
+ protected
+ function InternalGenerateDropIndexSQL(Metadata: TInstantIndexMetadata): string; override;
+ end;
+
+ TInstantAnyDACMySQLBroker = class(TInstantAnyDACBroker)
+ protected
+ procedure InternalCreateDatabase; override;
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string;
+ override;
+ function InternalDBNotExistsErrorCode: Integer; override;
+ function UseBooleanFields: Boolean; override;
+ public
+ class function GeneratorClass: TInstantSQLGeneratorClass; override;
+ end;
+ {$ENDIF}
+
+ { SQLite broker }
+
+ {$IFDEF SQLITE_SUPPORT}
+
+ //SQLite doesn\xB4t support ALTER TABLE. Spport for ADD COLUMN, ALTER COLUMN and
+ //DROP COLUMN, is emulated with a couple of CREATE TEMP TABLE, INSERT INTO,
+ //DROP TABLE, CREATE TABLE, INSERT INTO and finally DROP TABLE
+ TInstantDBBuildSQLiteAlterTableSQLCommand = class(TInstantDBBuildSQLCommand)
+ private
+ FTmpTableMD : TInstantTableMetadata;
+ FOldTableMetadata : TInstantTableMetadata;
+ FNewTableMetadata : TInstantTableMetadata;
+ FScheme : TInstantScheme;
+ protected
+ procedure Rollback; virtual;
+ function GetDescription: string; override;
+ function GetSQLStatement(const Index: Integer): string; override;
+ function GetSQLStatementCount: Integer; override;
+ function GetNewTableMetadata: TInstantTableMetadata;
+ function GetOldTableMetadata: TInstantTableMetadata;
+ procedure InternalExecute; override;
+ public
+ destructor Destroy; override;
+ property OldTableMetadata: TInstantTableMetadata read GetOldTableMetadata;
+ property NewTableMetadata: TInstantTableMetadata read GetNewTableMetadata;
+ end;
+
+ TInstantSQLiteGenerator = class(TInstantSQLGenerator)
+ protected
+ function InternalGenerateInsertFromSelectSQL(const SourceMetadata, TargetMetadata: TInstantTableMetadata): string; virtual;
+ function InternalGenerateCreateTempTableSQL(Metadata: TInstantTableMetadata): string; virtual;
+ public
+ function GenerateCreateTempTableSQL(Metadata: TInstantTableMetadata): string;
+ function GenerateInsertFromSelectSQL(const SourceMetadata, TargetMetadata: TInstantTableMetadata): string;
+ end;
+
+ TInstantAnyDACSQLiteBroker = class(TInstantAnyDACBroker)
+ protected
+ function InternalDataTypeToColumnType(DataType: TInstantDataType): string; override;
+ function UseBooleanFields: Boolean; override;
+ public
+ class function GeneratorClass: TInstantSQLGeneratorClass; override;
+ function CreateDBBuildCommand(const CommandType: TInstantDBBuildCommandType): TInstantDBBuildCommand; override;
+ end;
+ {$ENDIF}
+
+procedure AssignAnyDACProtocols(Strings: TStrings);
+
+implementation
+
+uses
+ SysUtils, {$IFDEF D7+}Types,{$ENDIF} Controls, {$IFDEF D5}DBLogDlg,{$ENDIF}
+ InstantConsts, InstantClasses, InstantAnyDACConnectionDefEdit,
+ InstantAnyDACCatalog, InstantUtils;
+
+{$IFDEF SQLITE_SUPPORT}
+const
+ STmpTableSuffix = '_IOTmp_';
+{$ENDIF}
+
+
+procedure AssignAnyDACProtocols(Strings: TStrings);
+begin
+ if assigned(Strings) then
+ begin
+ Strings.Clear;
+
+ {$IFDEF SYBASE_SUPPORT}
+ Strings.Add(S_AD_ASAId);
+ {$ENDIF}
+
+ {$IFDEF MSSQL_SUPPORT}
+ Strings.Add(S_AD_MSSQLId);
+ {$ENDIF}
+
+ {$IFDEF IBFB_SUPPORT}
+ Strings.Add(S_AD_IBId);
+ {$ENDIF}
+
+ {$IFDEF ORACLE_SUPPORT}
+ Strings.Add(S_AD_OraId);
+ {$ENDIF}
+
+ {$IFDEF PGSQL_SUPPORT}
+ Strings.Add(S_AD_PGId);
+ {$ENDIF}
+
+ {$IFDEF MYSQL_SUPPORT}
+ Strings.Add(S_AD_MySQLId);
+ {$ENDIF}
+
+ {$IFDEF SQLITE_SUPPORT}
+ Strings.Add(S_AD_SQLiteId);
+ {$ENDIF}
+ end;
+end;
+
+
+{ Local routines }
+
+{$IFDEF D5}
+function LoginDialogProcCompatibility(const ADatabaseName: string;
+ var AUserName, APassword: string): Boolean;
+begin
+ Result := LoginDialogEx(ADatabaseName, AUserName, APassword, False);
+end;
+{$ENDIF}
+
+{ TInstantAnyDACConnectionDef }
+
+class function TInstantAnyDACConnectionDef.ConnectionTypeName: string;
+begin
+ Result := 'AnyDAC 2';
+end;
+
+class function TInstantAnyDACConnectionDef.ConnectorClass: TInstantConnectorClass;
+begin
+ Result := TInstantAnyDACConnector;
+end;
+
+function TInstantAnyDACConnectionDef.Edit: Boolean;
+var
+ EditForm : TInstantAnyDACConnectionDefEditForm;
+begin
+ EditForm := TInstantAnyDACConnectionDefEditForm.Create(nil);
+ try
+ EditForm.LoadData(Self);
+ Result := (EditForm.ShowModal = mrOk);
+ if (Result) then
+ EditForm.SaveData(Self);
+ finally
+ EditForm.Free;
+ end;
+end;
+
+procedure TInstantAnyDACConnectionDef.InitConnector(Connector: TInstantConnector);
+var
+ Connection : TADConnection;
+ ADConnector : TInstantAnyDACConnector;
+begin
+ inherited;
+ Connection := TADConnection.Create(Connector);
+ try
+ ADConnector := (Connector as TInstantAnyDACConnector);
+ ADConnector.Connection := Connection;
+ ADConnector.LoginPrompt := LoginPrompt;
+ ADConnector.UseDelimitedIdents := UseDelimitedIdents;
+ Connection.DriverName := Protocol;
+ Connection.TxOptions.AutoCommit := false;
+ Connection.TxOptions.Isolation := xiReadCommitted;
+ Connection.Params.Values['User_Name'] := UserName;
+ Connection.Params.Values['Password'] := Password;
+ Connection.Params.Values['Database'] := Database;
+ Connection.Params.Values['MetaDefCatalog'] := Catalog;
+
+ if (trim(HostName) = '') then
+ HostName := '127.0.0.1';
+
+ if (Port <= 0) then
+ Connection.Params.Values['Server'] := HostName else
+ Connection.Params.Values['Server'] := HostName + ', ' + IntToStr(Port)
+
+ // Connection.Properties.Text := Properties;
+ except
+ Connection.Free;
+ raise;
+ end;
+end;
+
+{ TInstantAnyDACConnector }
+
+procedure TInstantAnyDACConnector.AfterConnectionChange;
+begin
+ if (HasConnection) then
+ begin
+ FConnection.Connected := False;
+ FConnection.TxOptions.AutoCommit := true;
+ FConnection.TxOptions.Isolation := xiReadCommitted;
+ FConnection.OnLogin := DoLogin;
+ end;
+end;
+
+procedure TInstantAnyDACConnector.AssignLoginOptions;
+begin
+ if (HasConnection) then
+ FConnection.LoginPrompt := FLoginPrompt;
+end;
+
+procedure TInstantAnyDACConnector.BeforeConnectionChange;
+begin
+end;
+
+procedure TInstantAnyDACConnector.CheckConnection;
+begin
+ if not assigned(FConnection) then
+ raise EInstantError.Create(SUnassignedConnection);
+end;
+
+class function TInstantAnyDACConnector.ConnectionDefClass: TInstantConnectionDefClass;
+begin
+ Result := TInstantAnyDACConnectionDef;
+end;
+
+constructor TInstantAnyDACConnector.Create(AOwner: TComponent);
+begin
+ inherited Create(AOwner);
+ FLoginPrompt := False;
+ FUseDelimitedIdents := False;
+end;
+
+function TInstantAnyDACConnector.CreateBroker: TInstantBroker;
+begin
+ CheckConnection;
+ Result := nil;
+
+ {$IFDEF SYBASE_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_ASAId) then
+ Result := TInstantAnyDACSybaseBroker.Create(Self);
+ {$ENDIF}
+
+ {$IFDEF MSSQL_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_MSSQLId) then
+ Result := TInstantAnyDACMSSQLBroker.Create(Self);
+ {$ENDIF}
+
+ {$IFDEF IBFB_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_IBId) then
+ Result := TInstantAnyDACIbFbBroker.Create(Self);
+ {$ENDIF}
+
+ {$IFDEF ORACLE_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_OraId) then
+ Result := TInstantAnyDACOracleBroker.Create(Self);
+ {$ENDIF}
+
+ {$IFDEF PGSQL_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_PGId) then
+ Result := TInstantAnyDACPgSQLBroker.Create(Self);
+ {$ENDIF}
+
+ {$IFDEF MYSQL_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_MySQLId) then
+ Result := TInstantAnyDACMySQLBroker.Create(Self);
+ {$ENDIF}
+
+ {$IFDEF SQLITE_SUPPORT}
+ if SameText(FConnection.DriverName, S_AD_SQLiteId) then
+ Result := TInstantAnyDACSQLiteBroker.Create(Self);
+ {$ENDIF}
+
+ if (Result = nil) then
+ raise EInstantError.CreateFmt(SProtocolNotSupported,
+ [FConnection.DriverName]);
+end;
+
+procedure TInstantAnyDACConnector.DoLogin(AConnection: TADCustomConnection;
+ const AConnectionDef: IADStanConnectionDef);
+begin
+ if (assigned(FOnLogin)) then
+ FOnLogin(AConnection, AConnection.Params.Values['User_Name'],
+ AConnection.Params.Values['Password']);
+end;
+
+procedure TInstantAnyDACConnector.DoAfterConnectionChange;
+begin
+ if (HasConnection) then
+ FConnection.FreeNotification(Self);
+ AfterConnectionChange;
+end;
+
+procedure TInstantAnyDACConnector.DoBeforeConnectionChange;
+begin
+ try
+ BeforeConnectionChange;
+ finally
+ if HasConnection then
+ FConnection.RemoveFreeNotification(Self);
+ end;
+end;
+
+function TInstantAnyDACConnector.GetBroker: TInstantAnyDACBroker;
+begin
+ Result := inherited Broker as TInstantAnyDACBroker;
+end;
+
+function TInstantAnyDACConnector.GetConnected: Boolean;
+begin
+ if (HasConnection) then
+ Result := Connection.Connected else
+ Result := inherited GetConnected;
+end;
+
+function TInstantAnyDACConnector.GetConnection: TADConnection;
+begin
+ if not (csDesigning in ComponentState) then
+ CheckConnection;
+ Result := FConnection;
+end;
+
+function TInstantAnyDACConnector.GetDatabaseExists: Boolean;
+begin
+ AssignLoginOptions;
+ try
+ Connection.Connected := True;
+ Result := True;
+ Connection.Connected := False;
+ except
+// TODO Fixup database detection logic for AnyDAC - Exception approach may not work well
+// on E : EZSQLException do
+// if (E.ErrorCode = Broker.DBNotExistsErrorCode) then
+// Result := False
+// else
+// raise;
+ Result := False
+ end;
+end;
+
+function TInstantAnyDACConnector.GetLoginPrompt: Boolean;
+begin
+ if (HasConnection) then
+ FLoginPrompt := FConnection.LoginPrompt;
+ Result := FLoginPrompt;
+end;
+
+function TInstantAnyDACConnector.HasConnection: Boolean;
+begin
+ Result := assigned(FConnection);
+end;
+
+procedure TInstantAnyDACConnector.InternalBuildDatabase(
+ Scheme: TInstantScheme);
+begin
+ StartTransaction;
+ try
+ inherited InternalBuildDatabase(Scheme);
+ CommitTransaction;
+ except
+ RollbackTransaction;
+ raise;
+ end;
+end;
+
+procedure TInstantAnyDACConnector.InternalCommitTransaction;
+begin
+ CheckConnection;
+ if (FConnection.InTransaction) then
+ FConnection.Commit;
+end;
+
+procedure TInstantAnyDACConnector.InternalConnect;
+begin
+ CheckConnection;
+ FConnection.Connected := true;
+end;
+
+procedure TInstantAnyDACConnector.InternalCreateDatabase;
+begin
+ if (Connection.Connected) then
+ raise EInstantError.Create(SDatabaseOpen);
+ Broker.CreateDatabase;
+end;
+
+procedure TInstantAnyDACConnector.InternalDisconnect;
+begin
+ if (HasConnection) then
+ FConnection.Connected := false;
+end;
+
+procedure TInstantAnyDACConnector.InternalRollbackTransaction;
+begin
+ CheckConnection;
+ if (FConnection.InTransaction) then
+ FConnection.Rollback;
+end;
+
+procedure TInstantAnyDACConnector.InternalStartTransaction;
+begin
+ CheckConnection;
+ if (not FConnection.InTransaction) then
+ FConnection.StartTransaction;
+end;
+
+procedure TInstantAnyDACConnector.Notification(AComponent: TComponent;
+ Operation: TOperation);
+begin
+ inherited;
+ if (AComponent = FConnection) and (Operation = opRemove) then
+ FConnection := nil;
+end;
+
+function TInstantAnyDACConnector.ParamByName(const AName: string): string;
+begin
+ Result := Connection.Params.Values[AName];
+end;
+
+procedure TInstantAnyDACConnector.SetConnection(Value: TADConnection);
+begin
+ if (Value <> FConnection) then
+ begin
+ Disconnect;
+ DoBeforeConnectionChange;
+ FConnection := Value;
+ AssignLoginOptions;
+ DoAfterConnectionChange;
+ end;
+end;
+
+procedure TInstantAnyDACConnector.SetLoginPrompt(const Value: Boolean);
+begin
+ FLoginPrompt := Value;
+ AssignLoginOptions;
+end;
+
+procedure TInstantAnyDACConnector.SetUseDelimitedIdents(const Value: Boolean);
+begin
+ FUseDelimitedIdents := Value;
+end;
+
+{ TInstantAnyDACBroker }
+
+procedure TInstantAnyDACBroker.AssignDataSetParams(DataSet: TDataSet; AParams: TParams);
+var
+ SourceParam : TParam;
+ TargetParam : TADParam;
+ i : Integer;
+begin
+ // Don't call inherited
+ for i := 0 to Pred(AParams.Count) do
+ begin
+ SourceParam := AParams[i];
+ TargetParam := (DataSet as TADQuery).Params.FindParam(SourceParam.Name);
+ if assigned(TargetParam) then
+ AssignParam(SourceParam, TargetParam);
+ end;
+end;
+
+procedure TInstantAnyDACBroker.AssignParam(SourceParam: TParam; TargetParam: TADParam);
+begin
+ case SourceParam.DataType of
+ ftBoolean:
+ if UseBooleanFields then
+ TargetParam.Assign(SourceParam) else
+ TargetParam.AsInteger := ord(SourceParam.AsBoolean);
+ else
+ TargetParam.Assign(SourceParam);
+ end;
+end;
+
+function TInstantAnyDACBroker.CreateCatalog(const AScheme: TInstantScheme): TInstantCatalog;
+begin
+ Result := TInstantAnyDACCatalog.Create(AScheme,Self);
+end;
+
+procedure TInstantAnyDACBroker.CreateDatabase;
+begin
+ InternalCreateDatabase;
+end;
+
+function TInstantAnyDACBroker.CreateDataSet(const AStatement: string;
+ AParams: TParams): TDataSet;
+var
+ Query: TADQuery;
+begin
+ Query := TADQuery.Create(nil);
+ try
+ Query.Connection := Connector.Connection;
+ Query.SQL.Text := AStatement;
+ if assigned(AParams) then
+ AssignDatasetParams(Query, AParams);
+ Result := Query;
+ except
+ Query.Free;
+ raise;
+ end;
+end;
+
+function TInstantAnyDACBroker.CreateDBBuildCommand(
+ const CommandType: TInstantDBBuildCommandType): TInstantDBBuildCommand;
+begin
+ if CommandType = ctAddTable then
+ Result := TInstantDBBuildAddTableSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctDropTable then
+ Result := TInstantDBBuildDropTableSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctAddField then
+ Result := TInstantDBBuildAddFieldSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctAlterField then
+ Result := TInstantDBBuildAlterFieldSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctDropField then
+ Result := TInstantDBBuildDropFieldSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctAddIndex then
+ Result := TInstantDBBuildAddIndexSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctAlterIndex then
+ Result := TInstantDBBuildAlterIndexSQLCommand.Create(CommandType, Connector)
+ else if CommandType = ctDropIndex then
+ Result := TInstantDBBuildDropIndexSQLCommand.Create(CommandType, Connector)
+ else
+ Result := inherited CreateDBBuildCommand(CommandType);
+end;
+
+function TInstantAnyDACBroker.CreateResolver(Map: TInstantAttributeMap): TInstantSQLResolver;
+begin
+ if UseBooleanFields then
+ Result := TInstantSQLResolver.Create(Self, Map) else
+ Result := TInstantAnyDACResolver.Create(Self, Map);
+end;
+
+function TInstantAnyDACBroker.DataTypeToColumnType(DataType: TInstantDataType;
+ Size: Integer): string;
+begin
+ Result := InternalDataTypeToColumnType(DataType);
+ if (DataType = dtString) and (Size > 0) then
+ Result := Result + InstantEmbrace(IntToStr(Size), '()');
+end;
+
+function TInstantAnyDACBroker.DBNotExistsErrorCode: Integer;
+begin
+ Result := InternalDBNotExistsErrorCode;
+end;
+
+function TInstantAnyDACBroker.Execute(const AStatement: string;
+ AParams: TParams): Integer;
+var
+ DataSet: TADQuery;
+begin
+ DataSet := AcquireDataSet(AStatement,AParams) as TADQuery;
+ try
+ DataSet.ExecSQL;
+ Result := DataSet.RowsAffected;
+ finally
+ ReleaseDataSet(DataSet);
+ end;
+end;
+
+function TInstantAnyDACBroker.GetConnector: TInstantAnyDACConnector;
+begin
+ Result := inherited Connector as TInstantAnyDACConnector;
+end;
+
+function TInstantAnyDACBroker.GetDatabaseName: string;
+begin
+ Result := Connector.ParamByName('Database');
+end;
+
+function TInstantAnyDACBroker.GetDBMSName: string;
+begin
+ Result := Connector.Connection.DriverName;
+end;
+
+function TInstantAnyDACBroker.GetSQLDelimiters: string;
+begin
+ if not Connector.UseDelimitedIdents then
+ Result := ''
+ else
+ begin
+ with Connector.Connection do
+ begin
+ if (ConnectionMetaDataIntf.NameQuotaChar1 <> #0) and
+ (ConnectionMetaDataIntf.NameQuotaChar1 <> ' ') then
+ Result := ConnectionMetaDataIntf.NameQuotaChar1 else
+ Result := '';
+ if (ConnectionMetaDataIntf.NameQuotaChar2 <> #0) and
+ (ConnectionMetaDataIntf.NameQuotaChar2 <> ' ') then
+ Result := Result + ConnectionMetaDataIntf.NameQuotaChar2;
+ end;
+ end;
+end;
+
+function TInstantAnyDACBroker.GetSQLQuote: Char;
+begin
+ Result := '''';
+end;
+
+procedure TInstantAnyDACBroker.InternalCreateDatabase;
+begin
+ raise EInstantError.CreateFmt(SDatabaseCreationNotSupported, [GetDBMSName]);
+end;
+
+function TInstantAnyDACBroker.InternalCreateQuery: TInstantQuery;
+begin
+ if UseBooleanFields then
+ Result := TInstantSQLQuery.Create(Connector) else
+ Result := TInstantAnyDACQuery.Create(Connector);
+end;
+
+function TInstantAnyDACBroker.InternalDBNotExistsErrorCode: Integer;
+begin
+ Result := 0;
+end;
+
+{ TInstantAnyDACResolver }
+
+function TInstantAnyDACResolver.ReadBooleanField(DataSet: TDataSet;
+ const FieldName: string): Boolean;
+begin
+ Result := (DataSet.FieldByName(FieldName).AsInteger <> 0);
+end;
+
+{ TInstantAnyDACTranslator }
+
+function TInstantAnyDACTranslator.TranslateConstant(
+ Constant: TInstantIQLConstant; Writer: TInstantIQLWriter): Boolean;
+begin
+ if SameText(Constant.Value, InstantTrueString) then
+ begin
+ Writer.WriteChar('1');
+ Result := True;
+ end
+ else if SameText(Constant.Value, InstantFalseString) then
+ begin
+ Writer.WriteChar('0');
+ Result := True;
+ end
+ else
+ Result := inherited TranslateConstant(Constant, Writer);
+end;
+
+{ TInstantAnyDACQuery }
+
+class function TInstantAnyDACQuery.TranslatorClass: TInstantRelationalTranslatorClass;
+begin
+ Result := TInstantAnyDACTranslator;
+end;
+
+{ TInstantAnyDACSybaseBroker }
+
+{$IFDEF SYBASE_SUPPORT}
+function TInstantAnyDACSybaseBroker.InternalDataTypeToColumnType(
+ DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'INTEGER',
+ 'DOUBLE PRECISION',
+ 'MONEY',
+ 'TINYINT',
+ 'VARCHAR',
+ 'TEXT',
+ 'DATETIME',
+ 'IMAGE',
+ 'DATETIME',
+ 'DATETIME');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACSybaseBroker.UseBooleanFields: Boolean;
+begin
+ Result := False;
+end;
+{$ENDIF}
+
+{ TInstantAnyDACMSSQLBroker }
+
+{$IFDEF MSSQL_SUPPORT}
+function TInstantAnyDACMSSQLBroker.InternalDataTypeToColumnType(
+ DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'INTEGER',
+ 'FLOAT',
+ 'MONEY',
+ 'BIT',
+ 'VARCHAR',
+ 'TEXT',
+ 'DATETIME',
+ 'IMAGE',
+ 'DATETIME',
+ 'DATETIME');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACMSSQLBroker.UseBooleanFields: Boolean;
+begin
+ Result := True;
+end;
+{$ENDIF}
+
+{ TInstantAnyDACIbFbBroker }
+
+{$IFDEF IBFB_SUPPORT}
+procedure TInstantAnyDACIbFbBroker.InternalCreateDatabase;
+var
+ OldProperties : string;
+ CharacterSet : string;
+begin
+ // TODO Quick first pass at using built-in AnyDAC database creation logic (not tested)
+ // do not call inherited
+ with Connector do
+ begin
+ OldProperties := Connection.Params.Text;
+
+ try
+ CharacterSet := trim(Connection.Params.Values['CharacterSet']);
+
+ if (CharacterSet = '') then
+ CharacterSet := 'ISO8859_1';
+
+ Connection.Params.Values['CharacterSet'] := CharacterSet;
+ Connection.Params.Values['CreateDatabase'] := 'Yes';
+ Connection.Params.Values['PageSize'] := '4096';
+ Connect;
+ Disconnect;
+ finally
+ Connection.Params.Text := OldProperties;
+ end;
+ end;
+end;
+
+function TInstantAnyDACIbFbBroker.InternalDataTypeToColumnType(DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'INTEGER',
+ 'DOUBLE PRECISION',
+ 'DECIMAL(14,4)',
+ 'SMALLINT',
+ 'VARCHAR',
+ 'BLOB SUB_TYPE 1',
+ 'TIMESTAMP',
+ 'BLOB',
+ 'TIMESTAMP',
+ 'TIMESTAMP');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACIbFbBroker.InternalDBNotExistsErrorCode: Integer;
+begin
+ Result := -902;
+end;
+
+function TInstantAnyDACIbFbBroker.UseBooleanFields: Boolean;
+begin
+ Result := False;
+end;
+{$ENDIF}
+
+{ TInstantAnyDACOracleBroker }
+
+{$IFDEF ORACLE_SUPPORT}
+function TInstantAnyDACOracleBroker.InternalDataTypeToColumnType(
+ DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'NUMBER(10)',
+ 'FLOAT',
+ 'NUMBER(14,4)',
+ 'NUMBER(1)',
+ 'VARCHAR2',
+ 'CLOB',
+ 'DATE',
+ 'BLOB',
+ 'DATE',
+ 'DATE');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACOracleBroker.UseBooleanFields: Boolean;
+begin
+ Result := False;
+end;
+{$ENDIF}
+
+{ TInstantAnyDACPgSQLBroker }
+
+{$IFDEF PGSQL_SUPPORT}
+function TInstantAnyDACPgSQLBroker.InternalDataTypeToColumnType(DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'INTEGER',
+ 'FLOAT8',
+ 'DECIMAL(14,4)',
+ 'BOOLEAN',
+ 'VARCHAR',
+ 'TEXT',
+ 'TIMESTAMP',
+ 'BYTEA',
+ 'TIMESTAMP',
+ 'TIMESTAMP');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACPgSQLBroker.UseBooleanFields: Boolean;
+begin
+ Result := True;
+end;
+{$ENDIF}
+
+{$IFDEF MYSQL_SUPPORT}
+
+{ TInstantMySQLGenerator }
+
+function TInstantMySQLGenerator.InternalGenerateDropIndexSQL(Metadata: TInstantIndexMetadata): string;
+begin
+ Result := Format('ALTER TABLE %s DROP INDEX %s',
+ [Metadata.TableMetadata.Name, Metadata.Name]);
+end;
+
+{ TInstantAnyDACMySQLBroker }
+
+class function TInstantAnyDACMySQLBroker.GeneratorClass: TInstantSQLGeneratorClass;
+begin
+ Result := TInstantMySQLGenerator;
+end;
+
+procedure TInstantAnyDACMySQLBroker.InternalCreateDatabase;
+var
+ MySqlConnection: IZMySqlConnection;
+ OldProperties: string;
+begin
+ // do not call inherited
+ with Connector.Connection do
+ begin
+ OldProperties := Properties.Text;
+ Properties.Values['dbless'] := 'TRUE';
+ try
+ try
+ Connect;
+ DbcConnection.QueryInterface(IZMySqlConnection, MySqlConnection);
+ if Assigned(MySqlConnection) then
+ MySqlConnection.GetPlainDriver.
+ CreateDatabase(MySqlConnection.GetConnectionHandle, PChar(Database))
+ else
+ inherited;
+ finally
+ Disconnect;
+ end;
+ finally
+ Properties.Text := OldProperties;
+ end;
+ end;
+end;
+
+function TInstantAnyDACMySQLBroker.InternalDataTypeToColumnType(DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'INTEGER',
+ 'FLOAT',
+ 'DECIMAL(14,4)',
+ 'BOOL',
+ 'VARCHAR',
+ 'TEXT',
+ 'DATETIME',
+ 'BLOB',
+ 'DATE',
+ 'TIME');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACMySQLBroker.InternalDBNotExistsErrorCode: Integer;
+begin
+ Result := 1049;
+end;
+
+function TInstantAnyDACMySQLBroker.UseBooleanFields: Boolean;
+begin
+ Result := False;
+end;
+{$ENDIF}
+
+{$IFDEF SQLITE_SUPPORT}
+
+{ TInstantDBBuildAlterTableSQLCommand }
+
+destructor TInstantDBBuildSQLiteAlterTableSQLCommand.Destroy;
+begin
+ FNewTableMetadata.Free;
+ FTmpTableMD.Free;
+ FScheme.Free;
+ inherited;
+end;
+
+function TInstantDBBuildSQLiteAlterTableSQLCommand.GetDescription: string;
+begin
+ with Broker.Generator do
+ case CommandType of
+ ctAddField:
+ Result := GenerateAddFieldSQL(NewMetadata as TInstantFieldMetadata);
+ ctAlterField:
+ Result := GenerateAlterFieldSQL(OldMetadata as TInstantFieldMetadata,
+ NewMetadata as TInstantFieldMetadata);
+ ctDropField:
+ Result := GenerateDropFieldSQL(OldMetadata as TInstantFieldMetadata);
+ end;
+ Result := Result + ' - emulated with multi-statement SQL.';
+end;
+
+function TInstantDBBuildSQLiteAlterTableSQLCommand.GetNewTableMetadata: TInstantTableMetadata;
+begin
+ if not Assigned(FNewTableMetadata) then
+ begin
+ FNewTableMetadata := TInstantTableMetadata.Create(OldTableMetadata.Collection);
+ FNewTableMetadata.Assign(OldTableMetadata);
+ case CommandType of
+ ctAddField:
+ FNewTableMetadata.FieldMetadatas.Add.Assign(NewMetadata);
+ ctAlterField:
+ begin
+ with FNewTableMetadata.FieldMetadatas do
+ Remove(Find(OldMetadata.Name));
+ FNewTableMetadata.FieldMetadatas.Add.Assign(NewMetadata);
+ end;
+ ctDropField:
+ with FNewTableMetadata.FieldMetadatas do
+ Remove(Find(OldMetadata.Name));
+ end;
+ end;
+ Result := FNewTableMetadata;
+end;
+
+function TInstantDBBuildSQLiteAlterTableSQLCommand.GetOldTableMetadata: TInstantTableMetadata;
+var
+ FieldMetadata : TInstantFieldMetadata;
+begin
+ if not Assigned(FOldTableMetadata) then
+ begin
+ //Force to read the table from database
+ FScheme := Broker.ReadDatabaseScheme(nil);
+
+ FieldMetadata := nil;
+ case CommandType of
+ ctDropField, ctAlterField:
+ FieldMetadata := TInstantFieldMetadata(OldMetadata);
+ ctAddField:
+ FieldMetadata := TInstantFieldMetadata(NewMetadata);
+ end;
+
+ { TODO : This only works for case-insensitive object names! }
+ FOldTableMetadata :=
+ FScheme.FindTableMetadata(AnsiUpperCase(FieldMetadata.TableMetadata.Name));
+ end;
+ Result := FOldTableMetadata;
+end;
+
+function TInstantDBBuildSQLiteAlterTableSQLCommand.GetSQLStatement(const Index: Integer): string;
+
+ function CreateTmpTableMetadata(TableMetadata: TInstantTableMetadata):
+ TInstantTableMetadata;
+ begin
+ Result := TInstantTableMetadata.Create(TableMetadata.Collection);
+ Result.Assign(TableMetadata);
+ Result.Name := TableMetadata.Name + STmpTableSuffix;
+ end;
+
+begin
+ Result := inherited GetSQLStatement(Index);
+
+ if not Assigned(FTmpTableMD) then
+ FTmpTableMD := CreateTmpTableMetadata(OldTableMetadata);
+
+ with TInstantSQLiteGenerator(Broker.Generator) do
+ case Index of
+ 0: Result := GenerateCreateTempTableSQL(FTmpTableMD);
+ 1: Result := GenerateInsertFromSelectSQL(OldTableMetadata, FTmpTableMD);
+ 2: Result := GenerateDropTableSQL(OldTableMetadata);
+ 3: Result := GenerateCreateTableSQL(NewTableMetadata);
+ 4: Result := GenerateInsertFromSelectSQL(FTmpTableMD, NewTableMetadata);
+ 5: Result := GenerateDropTableSQL(FTmpTableMD);
+ end;
+end;
+
+function TInstantDBBuildSQLiteAlterTableSQLCommand.GetSQLStatementCount: Integer;
+begin
+ Result := 6;
+end;
+
+procedure TInstantDBBuildSQLiteAlterTableSQLCommand.InternalExecute;
+var
+ iStatement: Integer;
+ InTransaction: Boolean;
+begin
+ InTransaction := false;
+ try
+ for iStatement := 0 to Pred(GetSQLStatementCount) do
+ begin
+ Broker.Execute(GetSQLStatement(iStatement));
+ InTransaction := (iStatement > 2) and (iStatement < 5);
+ end;
+ except
+ if InTransaction then Rollback;
+ raise;
+ end;
+end;
+
+procedure TInstantDBBuildSQLiteAlterTableSQLCommand.Rollback;
+begin
+ { TODO : Some DBMS supports data definition within transactions,
+ If AnyDAC knows that then the follow code is unnecessary! }
+ with Broker, TInstantSQLiteGenerator(Broker.Generator) do
+ begin
+ try
+ Execute(GenerateDropTableSQL(NewTableMetadata));
+ except
+ //Safe if NewTable doesn\xB4t exist
+ end;
+ Execute(GenerateCreateTableSQL(OldTableMetadata));
+ Execute(GenerateInsertFromSelectSQL(FTmpTableMD, OldTableMetadata));
+ Execute(GenerateDropTableSQL(FTmpTableMD));
+ end;
+end;
+
+{ TInstantSQLiteGenerator }
+
+function TInstantSQLiteGenerator.GenerateCreateTempTableSQL(
+ Metadata: TInstantTableMetadata): string;
+begin
+ Result := InternalGenerateCreateTempTableSQL(Metadata);
+end;
+
+function TInstantSQLiteGenerator.GenerateInsertFromSelectSQL(
+ const SourceMetadata, TargetMetadata: TInstantTableMetadata): string;
+begin
+ Result := InternalGenerateInsertFromSelectSQL(SourceMetadata, TargetMetadata);
+end;
+
+function TInstantSQLiteGenerator.InternalGenerateCreateTempTableSQL(
+ Metadata: TInstantTableMetadata): string;
+begin
+ Result := InternalGenerateCreateTableSQL(Metadata);
+ Insert('TEMP ', Result, Pos('TABLE', Result));
+end;
+
+function TInstantSQLiteGenerator.InternalGenerateInsertFromSelectSQL(
+ const SourceMetadata, TargetMetadata: TInstantTableMetadata): string;
+var
+ i: Integer;
+ TargetField : TInstantFieldMetadata;
+ FieldList : string;
+begin
+ for i := 0 to Pred(TargetMetadata.FieldMetadatas.Count) do
+ begin
+ TargetField := TargetMetadata.FieldMetadatas[i];
+ { TODO : This only works for case-insensitive object names! }
+ if SourceMetadata.FieldMetadatas.IndexOf(AnsiUpperCase(TargetField.Name)) > -1 then
+ FieldList := FieldList + EmbraceField(TargetField.Name) + ', ';
+ end;
+ Delete(FieldList, Length(FieldList) - 1, 2);
+ Result := Format('INSERT INTO %s(%s) SELECT %s FROM %s',
+ [TargetMetadata.Name, FieldList, FieldList, SourceMetadata.Name]);
+end;
+
+{ TInstantAnyDACSQLiteBroker }
+
+function TInstantAnyDACSQLiteBroker.CreateDBBuildCommand(
+ const CommandType: TInstantDBBuildCommandType): TInstantDBBuildCommand;
+begin
+ case CommandType of
+ ctAddField, ctAlterField, ctDropField:
+ Result := TInstantDBBuildSQLiteAlterTableSQLCommand.Create(CommandType, Connector)
+ else
+ Result := inherited CreateDBBuildCommand(CommandType);
+ end;
+end;
+
+class function TInstantAnyDACSQLiteBroker.GeneratorClass:
+ TInstantSQLGeneratorClass;
+begin
+ Result := TInstantSQLiteGenerator;
+end;
+
+function TInstantAnyDACSQLiteBroker.InternalDataTypeToColumnType(
+ DataType: TInstantDataType): string;
+const
+ Types: array[TInstantDataType] of string = (
+ 'INTEGER',
+ 'FLOAT',
+ 'NUMERIC(14,4)',
+ 'BOOLEAN',
+ 'VARCHAR',
+ 'TEXT',
+ 'TIMESTAMP',
+ 'BLOB',
+ 'TIMESTAMP',
+ 'TIMESTAMP');
+begin
+ Result := Types[DataType];
+end;
+
+function TInstantAnyDACSQLiteBroker.UseBooleanFields: Boolean;
+begin
+ Result := True;
+end;
+{$ENDIF}
+
+initialization
+ RegisterClass(TInstantAnyDACConnectionDef);
+ TInstantAnyDACConnector.RegisterClass;
+ {$IFDEF D5}
+ if (not assigned(LoginDialogProc)) then
+ LoginDialogProc := LoginDialogProcCompatibility;
+ {$ENDIF}
+
+finalization
+ TInstantAnyDACConnector.UnregisterClass;
+ {$IFDEF D5}
+ if @LoginDialogProc = @LoginDialogProcCompatibility then
+ LoginDialogProc := nil;
+ {$ENDIF}
+
+end.
Property changes on: branches/BrokerDev/AnyDAC/InstantAnyDAC.pas
___________________________________________________________________
Added: svn:mime-type
+ text/plain
Added: svn:keywords
+ Id
Added: svn:eol-style
+ native
Added: branches/BrokerDev/AnyDAC/InstantAnyDAC.res
===================================================================
(Binary files differ)
Property changes on: branches/BrokerDev/AnyDAC/InstantAnyDAC.res
___________________________________________________________________
Added: svn:mime-type
+ application/octet-stream
Added: branches/BrokerDev/AnyDAC/InstantAnyDACCatalog.pas
===================================================================
--- branches/BrokerDev/AnyDAC/InstantAnyDACCatalog.pas (rev 0)
+++ branches/BrokerDev/AnyDAC/InstantAnyDACCatalog.pas 2009-03-21 23:32:31 UTC (rev 800)
@@ -0,0 +1,313 @@
+(*
+ * InstantObjects DBEvolver Support
+ * RemObjects AnyDAC 2.0 Catalog
+ *)
+
+(* ***** BEGIN LICENSE BLOCK *****
+ * Version: MPL 1.1
+ *
+ * The contents of this file are subject to the Mozilla Public License Version
+ * 1.1 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * http://www.mozilla.org/MPL/
+ *
+ * Software distributed under the License is distributed on an "AS IS" basis,
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+ * for the specific language governing rights and limitations under the
+ * License.
+ *
+ * The Original Code is: InstantObjects DBEvolver Support/AnyDAC Catalog
+ *
+ * The Initial Developer of the Original Code is: David Taylor
+ *
+ * Portions created by the Initial Developer are Copyright (C) 2009
+ * the Initial Developer. All Rights Reserved.
+ *
+ * Contributor(s):
+ *
+ * ***** END LICENSE BLOCK ***** *)
+
+unit InstantAnyDACCatalog;
+
+{$IFDEF LINUX}
+{$I '../../InstantDefines.inc'}
+{$ELSE}
+{$I '..\..\InstantDefines.inc'}
+{$ENDIF}
+
+interface
+
+uses
+ DB, InstantPersistence, InstantAnyDAC, InstantBrokers,
+ InstantMetadata, InstantTypes, uADPhysIntf, uADStanIntf;
+
+type
+ //
+ // A TInstantCatalog that reads catalog information from a
+ // RemObjects AnyDAC 2 connection
+ //
+ TInstantAnyDACCatalog = class(TInstantBrokerCatalog)
+ protected
+ procedure AddFieldMetadatas(TableMetadata: TInstantTableMetadata;
+ const Catalog : string; Schema : string);
+ procedure AddIndexMetadatas(TableMetadata: TInstantTableMetadata;
+ const Catalog : string; Schema : string);
+ procedure AddTableMetadatas(TableMetadatas: TInstantTableMetadatas);
+ function ColumnTypeToDataType(const ColumnType: TADDataType;
+ out DataType: TInstantDataType; out AlternateDataTypes: TInstantDataTypes): Boolean;
+ function GetBroker: TInstantAnyDACBroker;
+ function GetConnector: TInstantAnyDACConnector;
+ public
+ procedure InitTableMetadatas(ATableMetadatas: TInstantTableMetadatas); override;
+ property Broker: TInstantAnyDACBroker read GetBroker;
+ property Connector: TInstantAnyDACConnector read GetConnector;
+ end;
+
+implementation
+
+uses
+ {$IFDEF D7+}Types,{$ENDIF} TypInfo, SysUtils, Classes, Variants,
+ InstantClasses, InstantConsts, uADDatSManager;
+
+
+procedure TInstantAnyDACCatalog.AddFieldMetadatas(TableMetadata: TInstantTableMetadata;
+ const Catalog: string; Schema: string);
+var
+ Fields : TADDatSView;
+ FieldMetadata : TInstantFieldMetadata;
+ FieldDataType : TInstantDataType;
+ FieldAltDataTypes : TInstantDataTypes;
+ ConnMetadata : IADPhysConnectionMetadata;
+ ADFieldName : string;
+ ADFieldType : TADDataType;
+ ADFieldAttrib : TADDataAttributes;
+ IntValue : integer;
+ FieldRow : TADDatSRow;
+ I : integer;
+begin
+ ConnMetadata := Connector.Connection.ConnectionMetaDataIntf;
+ Fields := ConnMetadata.GetTableFields(Catalog,Schema,TableMetadata.Name,'');
+
+ for I := 0 to Fields.Rows.Count - 1 do
+ begin
+ FieldRow := Fields.Rows[I];
+ ADFieldName := VarToStr(FieldRow.GetData('COLUMN_NAME'));
+ ADFieldType := TADDataType(FieldRow.GetData('COLUMN_DATATYPE'));
+ IntValue := FieldRow.GetData('COLUMN_ATTRIBUTES');
+ ADFieldAttrib := TA...
[truncated message content] |
