current/DataAccess/ConnectionManager.pas

unit ConnectionManager;
interface

uses TypeDefs, DataAccess, Access_OniArchive, Access_OUP_ADB, Access_OniSplitArchive;

type
  TConnections = array of TDataAccess;

  TConnectionListChangedEvent = procedure of object;

  
  TConnectionManager = class
  private
    FConnections: TConnections;
    FLastID:      Integer;
    FConnectionListChanged: TConnectionListChangedEvent;
    function GetConnectionCount: Integer;
    function GetConnection(ConnectionID: Integer): TDataAccess;
    function GetConnectionByIndex(Index: Integer): TDataAccess;
    function GetConnectionIndex(ConnectionID: Integer): Integer;
    procedure RemoveConnection(ArrayIndex: Integer);
  protected
  public
    property Count: Integer read GetConnectionCount;
    property Connection[ConnectionID: Integer]: TDataAccess read GetConnection;
    property ConnectionByIndex[Index: Integer]: TDataAccess read GetConnectionByIndex;
    property ConnectionIndexByID[ConnectionID: Integer]: Integer read GetConnectionIndex;
    property OnCoonnectionListChanged: TConnectionListChangedEvent read FConnectionListChanged write FConnectionListChanged;

    constructor Create;
    function Close: Boolean;

    function OpenConnection(FileName: String; var Msg: TStatusMessages): Integer;
    function CloseConnectionByIndex(Index: Integer; var Msg: TStatusMessages): Boolean; overload;
    function CloseConnection(ID: Integer; var Msg: TStatusMessages): Boolean; overload;
    function CloseConnection(FileName: String; var Msg: TStatusMessages): Boolean; overload;
    function FileOpened(FileName: String): Integer;
  published
  end;


var
  ConManager: TConnectionManager;


implementation
uses
  SysUtils, Dialogs;

(*
 Implementation of TConnectionManager
*)


function TConnectionManager.GetConnectionCount: Integer;
begin
  Result := Length(FConnections);
end;

function TConnectionManager.GetConnectionIndex(ConnectionID: Integer): Integer;
var
  i: Integer;
begin
  Result := -1;
  if Count > 0 then
    for i := 0 to Count - 1 do
      if ConnectionByIndex[i].ConnectionID = ConnectionID then
      begin
        Result := i;
        Break;
      end;
end;

function TConnectionManager.GetConnection(ConnectionID: Integer): TDataAccess;
var
  i: Integer;
begin
  Result := nil;
  if Length(FConnections) > 0 then
  begin
    for i := 0 to High(FConnections) do
    begin
      if FConnections[i].ConnectionID = ConnectionID then
      begin
        Result := FConnections[i];
        Break;
      end;
    end;
    if i = Length(FConnections) then
      ShowMessage('Couldn''t find specified ConnectionID (' +
          IntToStr(ConnectionID) + '). Please contact developer!!!');
  end;
end;


function TConnectionManager.GetConnectionByIndex(Index: Integer): TDataAccess;
begin
  Result := nil;
  if index < Length(FConnections) then
  begin
    Result := FConnections[index];
  end;
end;

constructor TConnectionManager.Create;
begin
  inherited;
  FLastID := 0;
end;

function TConnectionManager.Close: Boolean;
begin
  Result := False;
  if Length(FConnections) > 0 then
    Exit;

  inherited;
end;


function TConnectionManager.OpenConnection(FileName: String; var Msg: TStatusMessages): Integer;
var
  i: Integer;
  ext: String;
  backend: TDataBackend;
  CreateMsg: TStatusMessages;
begin
  Msg := SM_UnknownError;
  Result := -1;

  if Length(FConnections) > 0 then
  begin
    for i := 0 to High(FConnections) do
    begin
      if FConnections[i].FileName = FileName then
      begin
        Result := FConnections[i].ConnectionID;
        Msg := SM_AlreadyOpened;
        Exit;
      end;
    end;
  end;

  if not FileExists(FileName) then
  begin
    Msg := SM_FileNotFound;
    Exit;
  end;

  ext := UpperCase(ExtractFileExt(FileName));

  if ext = '.OLDB' then
    backend := DB_ADB
  else if ext = '.DAT' then
    backend := DB_ONI
  else if ext = '.ONI' then
    backend := DB_ONISPLIT
  else
  begin
    Msg := SM_UnknownExtension;
    Exit;
  end;

  SetLength(FConnections, Length(FConnections) + 1);
  i := High(FConnections);
  case backend of
    DB_ONI:
      FConnections[i] := TAccess_OniArchive.Create(FileName, FLastID + 1, CreateMsg);
    DB_ADB:
      FConnections[i] := TAccess_OUP_ADB.Create(FileName, FLastID + 1, CreateMsg);
    DB_ONISPLIT:
      FConnections[i] := TAccess_OniSplitArchive.Create(FileName, FLastID + 1, CreateMsg);
  end;

  if CreateMsg = SM_OK then
  begin
    FLastID := FConnections[i].ConnectionID;
    Result := FLastID;
    Msg := SM_OK;
  end
  else
  begin
    FConnections[i].Close;
    FConnections[i] := nil;
    SetLength(FConnections, Length(FConnections) - 1);
    Msg := CreateMsg;
  end;
end;


procedure TConnectionManager.RemoveConnection(ArrayIndex: Integer);
var
  i: Integer;
begin
  if Length(FConnections) > 1 then
  begin
    for i := ArrayIndex to High(FConnections) - 1 do
    begin
      FConnections[i] := FConnections[i + 1];
    end;
  end;
  SetLength(FConnections, Length(FConnections) - 1);
end;

function TConnectionManager.CloseConnectionByIndex(Index: Integer; var Msg: TStatusMessages): Boolean;
begin
  Msg := SM_UnknownError;
  Result := False;

  if Index < Length(FConnections) then
  begin
    FConnections[Index].Close;
    RemoveConnection(Index);
    Msg := SM_OK;
    Result := True;
  end;
end;

function TConnectionManager.CloseConnection(ID: Integer; var Msg: TStatusMessages): Boolean;
var
  i: Integer;
begin
  Msg := SM_UnknownError;
  Result := False;

  if Length(FConnections) > 0 then
  begin
    for i := 0 to High(FConnections) do
    begin
      if FConnections[i].ConnectionID = ID then
      begin
        FConnections[i].Close;
        RemoveConnection(i);
        Msg := SM_OK;
        Result := True;
        Exit;
      end;
    end;
  end;
end;

function TConnectionManager.CloseConnection(FileName: String; var Msg: TStatusMessages): Boolean;
var
  i: Integer;
begin
  Msg := SM_UnknownError;
  Result := False;

  if Length(FConnections) > 0 then
  begin
    for i := 0 to High(FConnections) do
    begin
      if FConnections[i].FileName = FileName then
      begin
        FConnections[i].Close;
        RemoveConnection(i);
        Msg := SM_OK;
        Result := True;
        Exit;
      end;
    end;
  end;
end;


function TConnectionManager.FileOpened(FileName: String): Integer;
var
  i: Integer;
begin
  Result := -1;
  if Length(FConnections) > 0 then
    for i := 0 to High(FConnections) do
      if FConnections[i].FileName = FileName then
      begin
        Result := FConnections[i].ConnectionID;
        Exit;
      end;
end;


initialization
  ConManager := TConnectionManager.Create;
finalization
  ConManager.Free;
end.
Revision:	247
Committed:	Sun Nov 25 14:24:53 2007 UTC (17 years, 10 months ago) by alloc
Content type:	text/x-pascal
File size:	6934 byte(s)
Log Message:
#	Content
1	unit ConnectionManager;
2	interface
3
4	uses TypeDefs, DataAccess, Access_OniArchive, Access_OUP_ADB, Access_OniSplitArchive;
5
6	type
7	TConnections = array of TDataAccess;
8
9	TConnectionListChangedEvent = procedure of object;
10
11
12	TConnectionManager = class
13	private
14	FConnections: TConnections;
15	FLastID: Integer;
16	FConnectionListChanged: TConnectionListChangedEvent;
17	function GetConnectionCount: Integer;
18	function GetConnection(ConnectionID: Integer): TDataAccess;
19	function GetConnectionByIndex(Index: Integer): TDataAccess;
20	function GetConnectionIndex(ConnectionID: Integer): Integer;
21	procedure RemoveConnection(ArrayIndex: Integer);
22	protected
23	public
24	property Count: Integer read GetConnectionCount;
25	property Connection[ConnectionID: Integer]: TDataAccess read GetConnection;
26	property ConnectionByIndex[Index: Integer]: TDataAccess read GetConnectionByIndex;
27	property ConnectionIndexByID[ConnectionID: Integer]: Integer read GetConnectionIndex;
28	property OnCoonnectionListChanged: TConnectionListChangedEvent read FConnectionListChanged write FConnectionListChanged;
29
30	constructor Create;
31	function Close: Boolean;
32
33	function OpenConnection(FileName: String; var Msg: TStatusMessages): Integer;
34	function CloseConnectionByIndex(Index: Integer; var Msg: TStatusMessages): Boolean; overload;
35	function CloseConnection(ID: Integer; var Msg: TStatusMessages): Boolean; overload;
36	function CloseConnection(FileName: String; var Msg: TStatusMessages): Boolean; overload;
37	function FileOpened(FileName: String): Integer;
38	published
39	end;
40
41
42	var
43	ConManager: TConnectionManager;
44
45
46	implementation
47	uses
48	SysUtils, Dialogs;
49
50	(*
51	Implementation of TConnectionManager
52	*)
53
54
55	function TConnectionManager.GetConnectionCount: Integer;
56	begin
57	Result := Length(FConnections);
58	end;
59
60	function TConnectionManager.GetConnectionIndex(ConnectionID: Integer): Integer;
61	var
62	i: Integer;
63	begin
64	Result := -1;
65	if Count > 0 then
66	for i := 0 to Count - 1 do
67	if ConnectionByIndex[i].ConnectionID = ConnectionID then
68	begin
69	Result := i;
70	Break;
71	end;
72	end;
73
74	function TConnectionManager.GetConnection(ConnectionID: Integer): TDataAccess;
75	var
76	i: Integer;
77	begin
78	Result := nil;
79	if Length(FConnections) > 0 then
80	begin
81	for i := 0 to High(FConnections) do
82	begin
83	if FConnections[i].ConnectionID = ConnectionID then
84	begin
85	Result := FConnections[i];
86	Break;
87	end;
88	end;
89	if i = Length(FConnections) then
90	ShowMessage('Couldn''t find specified ConnectionID (' +
91	IntToStr(ConnectionID) + '). Please contact developer!!!');
92	end;
93	end;
94
95
96	function TConnectionManager.GetConnectionByIndex(Index: Integer): TDataAccess;
97	begin
98	Result := nil;
99	if index < Length(FConnections) then
100	begin
101	Result := FConnections[index];
102	end;
103	end;
104
105	constructor TConnectionManager.Create;
106	begin
107	inherited;
108	FLastID := 0;
109	end;
110
111	function TConnectionManager.Close: Boolean;
112	begin
113	Result := False;
114	if Length(FConnections) > 0 then
115	Exit;
116
117	inherited;
118	end;
119
120
121
122	function TConnectionManager.OpenConnection(FileName: String; var Msg: TStatusMessages): Integer;
123	var
124	i: Integer;
125	ext: String;
126	backend: TDataBackend;
127	CreateMsg: TStatusMessages;
128	begin
129	Msg := SM_UnknownError;
130	Result := -1;
131
132	if Length(FConnections) > 0 then
133	begin
134	for i := 0 to High(FConnections) do
135	begin
136	if FConnections[i].FileName = FileName then
137	begin
138	Result := FConnections[i].ConnectionID;
139	Msg := SM_AlreadyOpened;
140	Exit;
141	end;
142	end;
143	end;
144
145	if not FileExists(FileName) then
146	begin
147	Msg := SM_FileNotFound;
148	Exit;
149	end;
150
151	ext := UpperCase(ExtractFileExt(FileName));
152
153	if ext = '.OLDB' then
154	backend := DB_ADB
155	else if ext = '.DAT' then
156	backend := DB_ONI
157	else if ext = '.ONI' then
158	backend := DB_ONISPLIT
159	else
160	begin
161	Msg := SM_UnknownExtension;
162	Exit;
163	end;
164
165	SetLength(FConnections, Length(FConnections) + 1);
166	i := High(FConnections);
167	case backend of
168	DB_ONI:
169	FConnections[i] := TAccess_OniArchive.Create(FileName, FLastID + 1, CreateMsg);
170	DB_ADB:
171	FConnections[i] := TAccess_OUP_ADB.Create(FileName, FLastID + 1, CreateMsg);
172	DB_ONISPLIT:
173	FConnections[i] := TAccess_OniSplitArchive.Create(FileName, FLastID + 1, CreateMsg);
174	end;
175
176	if CreateMsg = SM_OK then
177	begin
178	FLastID := FConnections[i].ConnectionID;
179	Result := FLastID;
180	Msg := SM_OK;
181	end
182	else
183	begin
184	FConnections[i].Close;
185	FConnections[i] := nil;
186	SetLength(FConnections, Length(FConnections) - 1);
187	Msg := CreateMsg;
188	end;
189	end;
190
191
192	procedure TConnectionManager.RemoveConnection(ArrayIndex: Integer);
193	var
194	i: Integer;
195	begin
196	if Length(FConnections) > 1 then
197	begin
198	for i := ArrayIndex to High(FConnections) - 1 do
199	begin
200	FConnections[i] := FConnections[i + 1];
201	end;
202	end;
203	SetLength(FConnections, Length(FConnections) - 1);
204	end;
205
206	function TConnectionManager.CloseConnectionByIndex(Index: Integer; var Msg: TStatusMessages): Boolean;
207	begin
208	Msg := SM_UnknownError;
209	Result := False;
210
211	if Index < Length(FConnections) then
212	begin
213	FConnections[Index].Close;
214	RemoveConnection(Index);
215	Msg := SM_OK;
216	Result := True;
217	end;
218	end;
219
220	function TConnectionManager.CloseConnection(ID: Integer; var Msg: TStatusMessages): Boolean;
221	var
222	i: Integer;
223	begin
224	Msg := SM_UnknownError;
225	Result := False;
226
227	if Length(FConnections) > 0 then
228	begin
229	for i := 0 to High(FConnections) do
230	begin
231	if FConnections[i].ConnectionID = ID then
232	begin
233	FConnections[i].Close;
234	RemoveConnection(i);
235	Msg := SM_OK;
236	Result := True;
237	Exit;
238	end;
239	end;
240	end;
241	end;
242
243	function TConnectionManager.CloseConnection(FileName: String; var Msg: TStatusMessages): Boolean;
244	var
245	i: Integer;
246	begin
247	Msg := SM_UnknownError;
248	Result := False;
249
250	if Length(FConnections) > 0 then
251	begin
252	for i := 0 to High(FConnections) do
253	begin
254	if FConnections[i].FileName = FileName then
255	begin
256	FConnections[i].Close;
257	RemoveConnection(i);
258	Msg := SM_OK;
259	Result := True;
260	Exit;
261	end;
262	end;
263	end;
264	end;
265
266
267	function TConnectionManager.FileOpened(FileName: String): Integer;
268	var
269	i: Integer;
270	begin
271	Result := -1;
272	if Length(FConnections) > 0 then
273	for i := 0 to High(FConnections) do
274	if FConnections[i].FileName = FileName then
275	begin
276	Result := FConnections[i].ConnectionID;
277	Exit;
278	end;
279	end;
280
281
282	initialization
283	ConManager := TConnectionManager.Create;
284	finalization
285	ConManager.Free;
286	end.