root/campo-sirio
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Patch level : 12.0 1090

Browse Source 
Files correlati     : bs0.exe
Commento        :

aggiunto un meccanismo di trace nell'importazione bee store
Interno:
This commit is contained in:
Alessandro Bonazzi 2021-10-18 23:20:34 +02:00
parent 2d73b980f0
commit 754aeb32a3
1 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/include/transaction.cpp
View File

@ -370,9 +370,7 @@ bool TTransaction::set(
const char* rowkey = build_rowkey(table, row); const char* rowkey = build_rowkey(table, row);
TAssoc_array * row_data = (TAssoc_array *)_rows.objptr(rowkey); TAssoc_array * row_data = (TAssoc_array *)_rows.objptr(rowkey);
if (_executer.blank()) if (row_data == nullptr)
_executer = table;
if (row_data == nullptr)
_rows.add(rowkey, row_data = new TAssoc_array, true); _rows.add(rowkey, row_data = new TAssoc_array, true);
if (row_data != nullptr) if (row_data != nullptr)
{ {
@ -492,7 +490,10 @@ bool TTransaction::read_ini()
int index = get_varkey_index(key); int index = get_varkey_index(key);
TString name = get_varkey_name(key); TString name = get_varkey_name(key);
set(name, cnf.get(name, *para, index), index, table, row); if (name == "Executer")
_executer = cnf.get(name, *para);
else
set(name, cnf.get(name, *para, index), index, table, row);
} }
} }
return true; return true;
@ -537,6 +538,9 @@ bool TTransaction::read_xml()
int index = get_varkey_index(*str); int index = get_varkey_index(*str);
TString name = get_varkey_name(*str); TString name = get_varkey_name(*str);
if (name == "Executer")
_executer = child_row->GetAttr(*str);
else
set(name, child_row->GetAttr(*str), index, logicnum, row); set(name, child_row->GetAttr(*str), index, logicnum, row);
} }
} }
@ -575,6 +579,7 @@ bool TTransaction::write_ini()
_head.get_keys(arr); _head.get_keys(arr);
cnf.set("Version", "2.0"); cnf.set("Version", "2.0");
cnf.set("Executer", _executer);
FOR_EACH_ARRAY_ROW(arr, r, str) FOR_EACH_ARRAY_ROW(arr, r, str)
{ {
int index = get_varkey_index(*str); int index = get_varkey_index(*str);
@ -624,6 +629,7 @@ bool TTransaction::write_xml()
TXmlItem & child = xml.AddChild("Transaction"); TXmlItem & child = xml.AddChild("Transaction");
_head.get_keys(arr); _head.get_keys(arr);
child.AddEnclosedText("Version", "2.0"); child.AddEnclosedText("Version", "2.0");
child.AddEnclosedText("Executer", _executer);
FOR_EACH_ARRAY_ROW(arr, r, str) FOR_EACH_ARRAY_ROW(arr, r, str)
child.AddEnclosedText(*str, *((TString *)_head.objptr(*str))); child.AddEnclosedText(*str, *((TString *)_head.objptr(*str)));
_rows.get_keys(row_arr); _rows.get_keys(row_arr);
@ -740,9 +746,14 @@ void execute_transactions(TArray & transactions, TLog_report & log, bool interac
while (true) while (true)
{ {
int i = first; int i = first;
TTransaction t = (TTransaction &)transactions[i]; TString table = ((TTransaction &)transactions[i]).executer();
TString table = t.executer();
int logicnum = atoi(table); int logicnum = atoi(table);
TFilename pref = ((TTransaction &)transactions[i]).name();
TString ext = ((TTransaction &)transactions[i]).ext();
pref.ext("");
while (isdigit(pref[pref.len() - 1]))
pref.rtrim(1);
while (processed[i]) while (processed[i])
i++; i++;
@ -750,16 +761,12 @@ void execute_transactions(TArray & transactions, TLog_report & log, bool interac
break; break;
if (table.full()) if (table.full())
{ {
TFilename pref = t.name();
pref.ext("");
while (isdigit(pref[pref.len() - 1]))
pref.rtrim(1);
int totalTransaction = 0; int totalTransaction = 0;
while (i >= 0) while (i >= 0)
{ {
TTransaction &t = (TTransaction &)transactions[i];
TRACE("Salvataggio registrazione %d - %s = %s %s starts with %s", i , (const char*)t.executer(), (const char*)table, (const char*)t.name(), (const char*)pref); TRACE("Salvataggio registrazione %d - %s = %s %s starts with %s", i , (const char*)t.executer(), (const char*)table, (const char*)t.name(), (const char*)pref);
if (t.executer() == table && t.name().starts_with(pref)) if (t.executer() == table && t.name().starts_with(pref))
{ {
@ -773,7 +780,6 @@ void execute_transactions(TArray & transactions, TLog_report & log, bool interac
i++; i++;
if (i > last) if (i > last)
break; break;
t = (TTransaction &)transactions[i];
} }
TString app; TString app;
@ -784,7 +790,7 @@ void execute_transactions(TArray & transactions, TLog_report & log, bool interac
TFilename filemask(pref); TFilename filemask(pref);
TString_array files; TString_array files;
filemask << "*" << "." << t.ext(); filemask << "*" << "." << ext;
app << (interactive ? " -i" : " -b") << filemask; app << (interactive ? " -i" : " -b") << filemask;
if (prog_msg.full()) if (prog_msg.full())
app << " -m\"" << prog_msg << "\""; app << " -m\"" << prog_msg << "\"";
@ -821,7 +827,7 @@ void execute_transactions(TArray & transactions, TLog_report & log, bool interac
{ {
TString msg(TR("Esecutore sconosciuto per le transazioni sul file ")); TString msg(TR("Esecutore sconosciuto per le transazioni sul file "));
msg << (logicnum == 0) ? t.executer() : prefix().description(logicnum); msg << (logicnum == 0) ? table : prefix().description(logicnum);
log.log(2, msg); log.log(2, msg);
} }
} }