+ added empty TSQLConnection.GetHandle

 + added empty TSQLConnection.CreateBlobStream
 + implemented TSQLConnection.StartTransaction and EndTransaction

git-svn-id: trunk@2631 -

fcl/db/dbconst.pp

@@ -74,6 +74,7 @@ Const
   SDuplicateName           = 'Duplicate name ''%s'' in %s';
   SNoParseSQL              = '%s is only possible if ParseSQL is True';
   SLookupInfoError         = 'Lookup information for field ''%s'' is incomplete';
+  SUnsupportedFieldType    = 'Fieldtype %s is not supported';
 
 Implementation
 

fcl/db/sqldb/sqldb.pp

@@ -77,7 +77,7 @@ type
     procedure DoInternalConnect; override;
     procedure DoInternalDisconnect; override;
     function GetAsSQLText(Field : TField) : string; virtual;
-    function GetHandle : pointer; virtual; abstract;
+    function GetHandle : pointer; virtual; virtual;
 
     Function AllocateCursorHandle : TSQLCursor; virtual; abstract;
     Procedure DeAllocateCursorHandle(var cursor : TSQLCursor); virtual; abstract;
@@ -99,10 +99,12 @@ type
     procedure RollBackRetaining(trans : TSQLHandle); virtual; abstract;
     procedure UpdateIndexDefs(var IndexDefs : TIndexDefs;TableName : string); virtual;
     function GetSchemaInfoSQL(SchemaType : TSchemaType; SchemaObjectName, SchemaPattern : string) : string; virtual;
-    function CreateBlobStream(Field: TField; Mode: TBlobStreamMode): TStream; virtual;abstract;
+    function CreateBlobStream(Field: TField; Mode: TBlobStreamMode): TStream; virtual;
   public
     property Handle: Pointer read GetHandle;
     destructor Destroy; override;
+    procedure StartTransaction; override;
+    procedure EndTransaction; override;
     property ConnOptions: TConnOptions read FConnOptions;
     procedure ExecuteDirect(SQL : String); overload; virtual;
     procedure ExecuteDirect(SQL : String; ATransaction : TSQLTransaction); overload; virtual;
@@ -311,6 +313,22 @@ begin
   inherited Destroy;
 end;
 
+procedure TSQLConnection.StartTransaction;
+begin
+  if not assigned(Transaction) then
+    DatabaseError(SErrConnTransactionnSet)
+  else
+    Transaction.StartTransaction;
+end;
+
+procedure TSQLConnection.EndTransaction;
+begin
+  if not assigned(Transaction) then
+    DatabaseError(SErrConnTransactionnSet)
+  else
+    Transaction.EndTransaction;
+end;
+
 Procedure TSQLConnection.ExecuteDirect(SQL: String);
 
 begin
@@ -402,6 +420,10 @@ begin
   end; {case}
 end;
 
+function TSQLConnection.GetHandle: pointer;
+begin
+  Result := nil;
+end;
 
 function TSQLConnection.GetSchemaInfoSQL( SchemaType : TSchemaType; SchemaObjectName, SchemaPattern : string) : string;
 
@@ -409,6 +431,11 @@ begin
   DatabaseError(SMetadataUnavailable);
 end;
 
+function TSQLConnection.CreateBlobStream(Field: TField; Mode: TBlobStreamMode): TStream;
+
+begin
+  DatabaseErrorFmt(SUnsupportedFieldType,['Blob']);
+end;
 
 { TSQLTransaction }
 procedure TSQLTransaction.EndTransaction;