Дегтярев Евгений,
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
type
TobPack = class (Tobject)
m1: Variant;
m2: Variant;
m3: Variant;
m4: Variant;
m5: Variant;
m6:Variant;
m7: Variant;
m8: Variant;
cnt_pack: integer;
constructor Create(const dbSize: integer); overload;
destructor Destroy; override;
end;
constructor TobPack.create(const dbSize: integer);
begin
inherited Create;
try
m1 := VarArrayCreate([0, dbSize-1], varOleStr);
m2 := VarArrayCreate([0, dbSize-1], varOleStr);
m3:= VarArrayCreate([0, dbSize-1], varOleStr);
m4:= VarArrayCreate([0, dbSize-1], varInteger);
m5:= VarArrayCreate([0, dbSize-1], varInteger);
m6:= VarArrayCreate([0, dbSize-1], varInteger);
m7:= VarArrayCreate([0, dbSize-1], varDate);
m8:= VarArrayCreate([0, dbSize-1], varDate);
except
on e : Exception do
WriteLog(FormatDateTime('yyyy_mm_dd_hh:nn:ss', now)+' (!ОШИБКА) TobPack.create '+' Ошибка:'+e.Message);
end;
end;
destructor TobPack.Destroy;
begin
m1 := null;
m2 := null;
m3:= null;
m4:= null;
m5:= null;
m6:= null;
m7:= Null;
m8:= Null;
inherited;
end;
При инициализации
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
err:= False;
try
oraSession := TOracleSession.Create(nil);
oraSession.LogonUsername := AUser;
oraSession.LogonPassword := APasswd;
oraSession.LogonDatabase := AConnectionString;
oraSession.ThreadSafe := True;
oraSession.StatementCache:= True;
oraSession.Preferences.ConvertCRLF:= false;
oraSession.Preferences.TrimStringFields:= false;
except
on E: exception do
begin
err := True;
errMessage := E.Message;
WriteLog(FormatDateTime('yyyy_mm_dd_hh:nn:ss', now) +' - (!ОШИБКА) процедура создания oraSession. Поток записи в БД №' + inttostr(Fnum) + '. ' + E.Message);
end;
end;
if err = false then
begin
try
oraSession.LogOn;
except
on E: exception do
begin
err := True;
errMessage := E.Message;
WriteLog(FormatDateTime('yyyy_mm_dd_hh:nn:ss', now) +' - (!ОШИБКА) процедура oraSession.LogOn. Поток записи в БД №' + inttostr(Fnum) + '. ' + E.Message);
end;
end;
if err = false then
begin
try
ods:= TOracleQuery.create(nil);
ods.Tag:= Fnum;
with ods do
begin
Session:= oraSession;
DeleteVariables;
sql.Text:='begin' + #13#10 +
' proc(m1 => :m1,' + #13#10 +
' m2 => :m2,' + #13#10 +
' m3 => :m3,' + #13#10 +
' m4 => :m4,' + #13#10 +
' m5 => :m5,' + #13#10 +
' m6 => :m6,' + #13#10 +
' m7 => :m7,' + #13#10 +
' m8 => :m8,' + #13#10 +
' v_cnt => :v_cnt);' + #13#10 +
'end;';
DeclareVariable('m1', otDate);
DimPLSQLTable('m1', size_pack, 0);
DeclareVariable('m2', otDate);
DimPLSQLTable('m2', size_pack, 0);
DeclareVariable('m3', otString);
DimPLSQLTable('m3', size_pack, 10);
DeclareVariable('m4', otString);
DimPLSQLTable('m4', size_pack, 10);
DeclareVariable('m5', otString);
DimPLSQLTable('m5', size_pack, 10);
DeclareVariable('m6', otInteger);
DimPLSQLTable('m6', size_pack, 0);
DeclareVariable('m7', otInteger);
DimPLSQLTable('m7', size_pack, 0);
DeclareVariable('m8', otInteger);
DimPLSQLTable('m8', size_pack, 0);
DeclareVariable('v_cnt', otInteger);
Optimize:= True; //не будет пересобирать заново запрос
end;
except
on E: exception do
begin
errMessage:= e.Message;
WriteLog(FormatDateTime('yyyy_mm_dd_hh:nn:ss', now)+' - (!ОШИБКА) процедура создания Query. Поток записи в БД №'+inttostr(fnum)+'.'+#13#10+e.Message);
end;
end;
err_Execute:= False;
end;
end;
if err then //ошибка при инициализации
begin
WriteLog(FormatDateTime('yyyy_mm_dd_hh:nn:ss', now) + ' - (!ОШИБКА) Инициализация потока записи в БД №' + inttostr(fnum) + '. Служба будет перезапущена');
CSectionErrDB.Enter;
TRY
err_conn_db:= 1;
FINALLY
CSectionErrDB.Leave;
END;
end;
В Execute потока:
try
fStartNew:= GetTickCount;
ods.SetVariable(0, obPack.m1);
ods.SetVariable(1, obPack.m2);
ods.SetVariable(2, obPack.m3);
ods.SetVariable(3, obPack.m4);
ods.SetVariable(4, obPack.m5);
ods.SetVariable(5, obPack.m6);
ods.SetVariable(6, obPack.m7);
ods.SetVariable(7, obPack.m8);
ods.SetVariable(8, obPack.cnt_pack);
buf_set:= inttostr(GetTickCount - fStartNew);
fStartNew:= GetTickCount;
try
EOracle:= 0;
ods.Execute;
err_Execute:= False;
except
on E: EOracleError do
begin
EOracle:= E.ErrorCode;
end;
on E: Exception do
begin
WriteLog(FormatDateTime('yyyy_mm_dd_hh:nn:ss', now)+' (!ОШИБКА) Модуль записи в БД. Выполнение запроса. Поток №'+inttostr(fnum)+' '+e.Message);
err_Execute:= True;
end;
end;
