github-starred/ultimatepp
2
0
Fork 0
mirror of https://github.com/ultimatepp/ultimatepp.git synced 2026-05-25 22:03:45 -06:00
Code Issues 33 Projects Packages Wiki Activity Actions

SqlCtrl: SqlArray has new WhenFilter Gate (able to filter records being fetched)

Browse source 
git-svn-id: svn://ultimatepp.org/upp/trunk@2313 f0d560ea-af0d-0410-9eb7-867de7ffcac7
This commit is contained in:
cxl 2010-04-07 21:44:38 +00:00
parent 83cc3ef6e5
commit a9d7aed5bd
2 changed files with 17 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

22
uppsrc/SqlCtrl/SqlArray.cpp
View file

@ -171,27 +171,32 @@ void SqlArray::AppendQuery(SqlBool where)
WhenPreQuery();
if(fk.IsNull() || !IsNull(fkv)) {
SqlSet cols;
for(int i = 0; i < GetIndexCount(); i++)
if(!GetId(i).IsNull())
cols.Cat(SqlId(GetId(i)));
VectorMap<Id, Value> fm;
for(int i = 0; i < GetIndexCount(); i++) {
if(!GetId(i).IsNull()) {
Id id(GetId(i));
cols.Cat(SqlId(id));
fm.Add(id);
}
}
SqlBool wh = where;
if(!fk.IsNull())
wh = wh && fk == fkv;
Sql sql(Session());
Session().ClearError();
// AutoWaitCursor awc(querytime); // todo: Fidler -> WaitCursor
if(IsNull(count))
sql * UPP::Select(cols).From(table).Where(wh).OrderBy(orderby);
else
sql * UPP::Select(cols).From(table).Where(wh).OrderBy(orderby).Limit(count).Offset(offset);
if(ShowError(sql)) {
// awc.Cancel(); // todo: Fidler -> WaitCursor
if(ShowError(sql))
return;
}
for(;;) {
Vector<Value> row;
if(!sql.Fetch(row)) break;
Add(row);
for(int i = 0; i < min(row.GetCount(), fm.GetCount()); i++)
fm[i] = row[i];
if(WhenFilter(fm))
Add(row);
}
if(GetCount())
if(goendpostquery)
@ -229,6 +234,7 @@ SqlArray::SqlArray() {
RowName(t_("record"));
offset = 0;
count = Null;
WhenFilter = true;
}
END_UPP_NAMESPACE