| 22 |
|
{ Corporation. All Rights Reserved. } |
| 23 |
|
{ Contributor(s): Jeff Overcash } |
| 24 |
|
{ } |
| 25 |
+ |
{ IBX For Lazarus (Firebird Express) } |
| 26 |
+ |
{ Contributor: Tony Whyman, MWA Software http://www.mwasoftware.co.uk } |
| 27 |
+ |
{ Portions created by MWA Software are copyright McCallum Whyman } |
| 28 |
+ |
{ Associates Ltd 2011 } |
| 29 |
+ |
{ } |
| 30 |
|
{************************************************************************} |
| 31 |
|
|
| 32 |
|
unit IBDatabaseInfo; |
| 36 |
|
interface |
| 37 |
|
|
| 38 |
|
uses |
| 39 |
< |
SysUtils, Classes, IBHeader, IBExternals, IB, IBDatabase; |
| 39 |
> |
SysUtils, Classes, IB, IBExternals, IBDatabase; |
| 40 |
|
|
| 41 |
|
type |
| 42 |
|
|
| 89 |
|
public |
| 90 |
|
constructor Create(AOwner: TComponent); override; |
| 91 |
|
destructor Destroy; override; |
| 87 |
– |
function Call(ErrCode: ISC_STATUS; RaiseError: Boolean): ISC_STATUS; |
| 92 |
|
function GetLongDatabaseInfo(DatabaseInfoCommand: Integer): Long; |
| 93 |
|
property Allocation: Long read GetAllocation; |
| 94 |
|
property BaseLevel: Long read GetBaseLevel; |
| 128 |
|
implementation |
| 129 |
|
|
| 130 |
|
uses |
| 131 |
< |
IBIntf; |
| 131 |
> |
FBMessages; |
| 132 |
|
|
| 133 |
|
{ TIBDatabaseInfo } |
| 134 |
|
|
| 167 |
|
end; |
| 168 |
|
|
| 169 |
|
|
| 166 |
– |
function TIBDatabaseInfo.Call(ErrCode: ISC_STATUS; |
| 167 |
– |
RaiseError: Boolean): ISC_STATUS; |
| 168 |
– |
begin |
| 169 |
– |
result := ErrCode; |
| 170 |
– |
if RaiseError and (ErrCode > 0) then |
| 171 |
– |
IBDataBaseError; |
| 172 |
– |
end; |
| 170 |
|
function TIBDatabaseInfo.GetAllocation: Long; |
| 171 |
|
begin |
| 172 |
|
result := GetLongDatabaseInfo(isc_info_allocation); |
| 173 |
|
end; |
| 174 |
|
|
| 175 |
|
function TIBDatabaseInfo.GetBaseLevel: Long; |
| 176 |
< |
var |
| 180 |
< |
local_buffer: array[0..IBLocalBufferLength - 1] of Char; |
| 181 |
< |
DatabaseInfoCommand: Char; |
| 176 |
> |
var Response: TByteArray; |
| 177 |
|
begin |
| 178 |
< |
DatabaseInfoCommand := Char(isc_info_base_level); |
| 179 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 180 |
< |
IBLocalBufferLength, local_buffer), True); |
| 181 |
< |
result := isc_vax_integer(@local_buffer[4], 1); |
| 178 |
> |
with Database.Attachment.GetDBInformation([isc_info_base_level]) do |
| 179 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_base_level) then |
| 180 |
> |
begin |
| 181 |
> |
Response := Items[0].GetAsBytes; |
| 182 |
> |
Result := Response[1]; |
| 183 |
> |
end |
| 184 |
> |
else |
| 185 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 186 |
|
end; |
| 187 |
|
|
| 188 |
|
function TIBDatabaseInfo.GetDBFileName: String; |
| 189 |
|
var |
| 190 |
< |
local_buffer: array[0..IBLocalBufferLength - 1] of Char; |
| 191 |
< |
DatabaseInfoCommand: Char; |
| 190 |
> |
ConnectionType: integer; |
| 191 |
> |
SiteName: string; |
| 192 |
|
begin |
| 193 |
< |
DatabaseInfoCommand := Char(isc_info_db_id); |
| 194 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 195 |
< |
IBLocalBufferLength, local_buffer), True); |
| 196 |
< |
local_buffer[5 + Int(local_buffer[4])] := #0; |
| 197 |
< |
result := String(PChar(@local_buffer[5])); |
| 193 |
> |
with Database.Attachment.GetDBInformation([isc_info_db_id]) do |
| 194 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_db_id) then |
| 195 |
> |
Items[0].DecodeIDCluster(ConnectionType,Result,SiteName) |
| 196 |
> |
else |
| 197 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 198 |
|
end; |
| 199 |
|
|
| 200 |
|
function TIBDatabaseInfo.GetDBSiteName: String; |
| 201 |
|
var |
| 202 |
< |
local_buffer: array[0..IBBigLocalBufferLength - 1] of Char; |
| 203 |
< |
p: PChar; |
| 204 |
< |
DatabaseInfoCommand: Char; |
| 205 |
< |
begin |
| 206 |
< |
DatabaseInfoCommand := Char(isc_info_db_id); |
| 207 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 208 |
< |
IBLocalBufferLength, local_buffer), True); |
| 209 |
< |
p := @local_buffer[5 + Int(local_buffer[4])]; { DBSiteName Length } |
| 211 |
< |
p := p + Int(p^) + 1; { End of DBSiteName } |
| 212 |
< |
p^ := #0; { Null it } |
| 213 |
< |
result := String(PChar(@local_buffer[6 + Int(local_buffer[4])])); |
| 202 |
> |
ConnectionType: integer; |
| 203 |
> |
FileName: string; |
| 204 |
> |
begin |
| 205 |
> |
with Database.Attachment.GetDBInformation([isc_info_db_id]) do |
| 206 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_db_id) then |
| 207 |
> |
Items[0].DecodeIDCluster(ConnectionType,FileName,Result) |
| 208 |
> |
else |
| 209 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 210 |
|
end; |
| 211 |
|
|
| 212 |
|
function TIBDatabaseInfo.GetDBImplementationNo: Long; |
| 213 |
< |
var |
| 218 |
< |
local_buffer: array[0..IBLocalBufferLength - 1] of Char; |
| 219 |
< |
DatabaseInfoCommand: Char; |
| 213 |
> |
var Response: TByteArray; |
| 214 |
|
begin |
| 215 |
< |
DatabaseInfoCommand := Char(isc_info_implementation); |
| 216 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 217 |
< |
IBLocalBufferLength, local_buffer), True); |
| 218 |
< |
result := isc_vax_integer(@local_buffer[3], 1); |
| 215 |
> |
with Database.Attachment.GetDBInformation([isc_info_implementation]) do |
| 216 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_implementation) then |
| 217 |
> |
begin |
| 218 |
> |
Response := Items[0].GetAsBytes; |
| 219 |
> |
Result := Response[1]; |
| 220 |
> |
end |
| 221 |
> |
else |
| 222 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 223 |
|
end; |
| 224 |
|
|
| 225 |
|
function TIBDatabaseInfo.GetDBImplementationClass: Long; |
| 226 |
< |
var |
| 229 |
< |
local_buffer: array[0..IBLocalBufferLength - 1] of Char; |
| 230 |
< |
DatabaseInfoCommand: Char; |
| 226 |
> |
var Response: TByteArray; |
| 227 |
|
begin |
| 228 |
< |
DatabaseInfoCommand := Char(isc_info_implementation); |
| 229 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 230 |
< |
IBLocalBufferLength, local_buffer), True); |
| 231 |
< |
result := isc_vax_integer(@local_buffer[4], 1); |
| 228 |
> |
with Database.Attachment.GetDBInformation([isc_info_implementation]) do |
| 229 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_implementation) then |
| 230 |
> |
begin |
| 231 |
> |
Response := Items[0].GetAsBytes; |
| 232 |
> |
Result := Response[2]; |
| 233 |
> |
end |
| 234 |
> |
else |
| 235 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 236 |
|
end; |
| 237 |
|
|
| 238 |
|
function TIBDatabaseInfo.GetNoReserve: Long; |
| 256 |
|
end; |
| 257 |
|
|
| 258 |
|
function TIBDatabaseInfo.GetVersion: String; |
| 259 |
< |
var |
| 260 |
< |
local_buffer: array[0..IBBigLocalBufferLength - 1] of Char; |
| 261 |
< |
DatabaseInfoCommand: Char; |
| 259 |
> |
var Version: byte; |
| 260 |
|
begin |
| 261 |
< |
DatabaseInfoCommand := Char(isc_info_version); |
| 262 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 263 |
< |
IBBigLocalBufferLength, local_buffer), True); |
| 264 |
< |
local_buffer[5 + Int(local_buffer[4])] := #0; |
| 265 |
< |
result := String(PChar(@local_buffer[5])); |
| 261 |
> |
with Database.Attachment.GetDBInformation([isc_info_version]) do |
| 262 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_version) then |
| 263 |
> |
Items[0].DecodeVersionString(Version,Result) |
| 264 |
> |
else |
| 265 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 266 |
|
end; |
| 267 |
|
|
| 268 |
|
function TIBDatabaseInfo.GetCurrentMemory: Long; |
| 291 |
|
end; |
| 292 |
|
|
| 293 |
|
function TIBDatabaseInfo.GetUserNames: TStringList; |
| 294 |
< |
var |
| 295 |
< |
local_buffer: array[0..IBHugeLocalBufferLength - 1] of Char; |
| 298 |
< |
temp_buffer: array[0..IBLocalBufferLength - 2] of Char; |
| 299 |
< |
DatabaseInfoCommand: Char; |
| 300 |
< |
i, user_length: Integer; |
| 301 |
< |
begin |
| 302 |
< |
result := FUserNames; |
| 303 |
< |
DatabaseInfoCommand := Char(isc_info_user_names); |
| 304 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 305 |
< |
IBHugeLocalBufferLength, local_buffer), True); |
| 294 |
> |
begin |
| 295 |
> |
Result := FUserNames; |
| 296 |
|
FUserNames.Clear; |
| 297 |
< |
i := 0; |
| 298 |
< |
while local_buffer[i] = Char(isc_info_user_names) do |
| 299 |
< |
begin |
| 300 |
< |
Inc(i, 3); { skip "isc_info_user_names byte" & two unknown bytes of structure (see below) } |
| 301 |
< |
user_length := Long(local_buffer[i]); |
| 312 |
< |
Inc(i,1); |
| 313 |
< |
Move(local_buffer[i], temp_buffer[0], user_length); |
| 314 |
< |
Inc(i, user_length); |
| 315 |
< |
temp_buffer[user_length] := #0; |
| 316 |
< |
FUserNames.Add(String(temp_buffer)); |
| 317 |
< |
end; |
| 297 |
> |
with Database.Attachment.GetDBInformation([isc_info_user_names]) do |
| 298 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_user_names) then |
| 299 |
> |
Items[0].DecodeUserNames(Result) |
| 300 |
> |
else |
| 301 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 302 |
|
end; |
| 303 |
|
|
| 304 |
|
function TIBDatabaseInfo.GetFetches: Long; |
| 322 |
|
end; |
| 323 |
|
|
| 324 |
|
function TIBDatabaseInfo.GetOperationCounts(DBInfoCommand: Integer; FOperation: TStringList): TStringList; |
| 325 |
< |
var |
| 326 |
< |
local_buffer: array[0..IBHugeLocalBufferLength - 1] of Char; |
| 343 |
< |
DatabaseInfoCommand: Char; |
| 344 |
< |
i, qtd_tables, id_table, qtd_operations: Integer; |
| 325 |
> |
var opCounts: TDBOperationCounts; |
| 326 |
> |
i: integer; |
| 327 |
|
begin |
| 328 |
|
if FOperation = nil then FOperation := TStringList.Create; |
| 329 |
|
result := FOperation; |
| 330 |
< |
DatabaseInfoCommand := Char(DBInfoCommand); |
| 331 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 332 |
< |
IBHugeLocalBufferLength, local_buffer), True); |
| 333 |
< |
FOperation.Clear; |
| 334 |
< |
{ 1. 1 byte specifying the item type requested (e.g., isc_info_insert_count). |
| 335 |
< |
2. 2 bytes telling how many bytes compose the subsequent value pairs. |
| 336 |
< |
3. A pair of values for each table in the database on wich the requested |
| 355 |
< |
type of operation has occurred since the database was last attached. |
| 356 |
< |
Each pair consists of: |
| 357 |
< |
1. 2 bytes specifying the table ID. |
| 358 |
< |
2. 4 bytes listing the number of operations (e.g., inserts) done on that table. |
| 359 |
< |
} |
| 360 |
< |
qtd_tables := trunc(isc_vax_integer(@local_buffer[1],2)/6); |
| 361 |
< |
for i := 0 to qtd_tables - 1 do |
| 362 |
< |
begin |
| 363 |
< |
id_table := isc_vax_integer(@local_buffer[3+(i*6)],2); |
| 364 |
< |
qtd_operations := isc_vax_integer(@local_buffer[5+(i*6)],4); |
| 365 |
< |
FOperation.Add(IntToStr(id_table)+'='+IntToStr(qtd_operations)); |
| 366 |
< |
end; |
| 330 |
> |
with Database.Attachment.GetDBInformation([DBInfoCommand]) do |
| 331 |
> |
if (Count > 0) and (Items[0].GetItemType = DBInfoCommand) then |
| 332 |
> |
opCounts := Items[0].getOperationCounts |
| 333 |
> |
else |
| 334 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 335 |
> |
for i := 0 to Length(opCounts) - 1 do |
| 336 |
> |
FOperation.Add(IntToStr(opCounts[i].TableID) +'='+IntToStr(opCounts[i].Count)); |
| 337 |
|
end; |
| 338 |
|
|
| 339 |
|
function TIBDatabaseInfo.GetBackoutCount: TStringList; |
| 382 |
|
end; |
| 383 |
|
|
| 384 |
|
function TIBDatabaseInfo.GetLongDatabaseInfo(DatabaseInfoCommand: Integer): Long; |
| 385 |
< |
var |
| 386 |
< |
local_buffer: array[0..IBLocalBufferLength - 1] of Char; |
| 387 |
< |
length: Integer; |
| 388 |
< |
_DatabaseInfoCommand: Char; |
| 389 |
< |
begin |
| 390 |
< |
_DatabaseInfoCommand := Char(DatabaseInfoCommand); |
| 421 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @_DatabaseInfoCommand, |
| 422 |
< |
IBLocalBufferLength, local_buffer), True); |
| 423 |
< |
length := isc_vax_integer(@local_buffer[1], 2); |
| 424 |
< |
result := isc_vax_integer(@local_buffer[3], length); |
| 385 |
> |
begin |
| 386 |
> |
with Database.Attachment.GetDBInformation([DatabaseInfoCommand]) do |
| 387 |
> |
if (Count > 0) and (Items[0].GetItemType = DatabaseInfoCommand) then |
| 388 |
> |
Result := Items[0].AsInteger |
| 389 |
> |
else |
| 390 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 391 |
|
end; |
| 392 |
|
|
| 393 |
|
function TIBDatabaseInfo.GetStringDatabaseInfo(DatabaseInfoCommand: Integer): String; |
| 428 |
– |
var |
| 429 |
– |
local_buffer: array[0..IBBigLocalBufferLength - 1] of Char; |
| 430 |
– |
_DatabaseInfoCommand: Char; |
| 394 |
|
begin |
| 395 |
< |
_DatabaseInfoCommand := Char(DatabaseInfoCommand); |
| 396 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @_DatabaseInfoCommand, |
| 397 |
< |
IBBigLocalBufferLength, local_buffer), True); |
| 398 |
< |
local_buffer[4 + Int(local_buffer[3])] := #0; |
| 399 |
< |
result := String(PChar(@local_buffer[4])); |
| 395 |
> |
with Database.Attachment.GetDBInformation([DatabaseInfoCommand]) do |
| 396 |
> |
if (Count > 0) and (Items[0].GetItemType = DatabaseInfoCommand) then |
| 397 |
> |
Result := Items[0].AsString |
| 398 |
> |
else |
| 399 |
> |
IBError(ibxeUnexpectedDatabaseInfoResp,[nil]); |
| 400 |
|
end; |
| 401 |
|
|
| 402 |
|
|
| 403 |
|
function TIBDatabaseInfo.GetDBSQLDialect: Integer; |
| 404 |
< |
var |
| 405 |
< |
local_buffer: array[0..IBLocalBufferLength - 1] of Char; |
| 406 |
< |
length: Integer; |
| 407 |
< |
DatabaseInfoCommand: Char; |
| 408 |
< |
begin |
| 409 |
< |
DatabaseInfoCommand := Char(isc_info_db_SQL_Dialect); |
| 447 |
< |
Call(isc_database_info(StatusVector, @FDatabase.Handle, 1, @DatabaseInfoCommand, |
| 448 |
< |
IBLocalBufferLength, local_buffer), True); |
| 449 |
< |
if (local_buffer[0] <> Char(isc_info_db_SQL_dialect)) then |
| 450 |
< |
result := 1 |
| 451 |
< |
else begin |
| 452 |
< |
length := isc_vax_integer(@local_buffer[1], 2); |
| 453 |
< |
result := isc_vax_integer(@local_buffer[3], length); |
| 454 |
< |
end; |
| 404 |
> |
begin |
| 405 |
> |
with Database.Attachment.GetDBInformation([isc_info_db_SQL_Dialect]) do |
| 406 |
> |
if (Count > 0) and (Items[0].GetItemType = isc_info_db_SQL_Dialect) then |
| 407 |
> |
Result := Items[0].AsInteger |
| 408 |
> |
else |
| 409 |
> |
Result := 1; |
| 410 |
|
end; |
| 411 |
|
|
| 412 |
|
|
