connectivity/source/drivers/mork/MQueryHelper.cxx | 154 +++++++++++++++++++++-
connectivity/source/drivers/mork/MQueryHelper.hxx | 2
2 files changed, 149 insertions(+), 7 deletions(-)
New commits:
commit 4ba4ca8d39485ecbb4cd02a684c17d6731d73ff6
Author: David Ostrovsky <da...@ostrovsky.org>
Date: Sun Sep 16 23:41:57 2012 +0200
mork driver: add query
Change-Id: I8f32f04d2c0e0b026bbe960c6bc8895906988419
diff --git a/connectivity/source/drivers/mork/MQueryHelper.cxx
b/connectivity/source/drivers/mork/MQueryHelper.cxx
index 74fd046..ffc2a5f 100644
--- a/connectivity/source/drivers/mork/MQueryHelper.cxx
+++ b/connectivity/source/drivers/mork/MQueryHelper.cxx
@@ -38,6 +38,9 @@ using namespace ::com::sun::star::sdbc;
using namespace connectivity;
+extern
+::std::vector< sal_Bool > entryMatchedByExpression(MQueryHelper* _aQuery,
MQueryExpression* _aExpr, MQueryHelperResultEntry* entry);
+
MQueryHelperResultEntry::MQueryHelperResultEntry()
{
}
@@ -83,7 +86,8 @@ MQueryHelper::MQueryHelper(const OColumnAlias& _ca)
MQueryHelper::~MQueryHelper()
{
- OSL_TRACE("IN MQueryHelper::~MQueryHelper()");
+ SAL_INFO("connectivity.mork", "MQueryHelper::~MQueryHelper()");
+
clear_results();
OSL_TRACE("OUT MQueryHelper::~MQueryHelper()");
}
@@ -91,7 +95,8 @@ MQueryHelper::~MQueryHelper()
// -------------------------------------------------------------------------
void MQueryHelper::setAddressbook(::rtl::OUString &ab)
{
- OSL_TRACE("IN MQueryHelper::setAddressbook()");
+ SAL_INFO("connectivity.mork", "MQueryHelper::setAddressbook()");
+
::osl::MutexGuard aGuard(m_aMutex);
m_aAddressbook = ab;
@@ -101,6 +106,7 @@ void MQueryHelper::setAddressbook(::rtl::OUString &ab)
// -------------------------------------------------------------------------
void MQueryHelper::setExpression( MQueryExpression &_expr )
{
+ SAL_INFO("connectivity.mork", "MQueryHelper::setExpression()");
OSL_TRACE("IN MQueryHelper::setExpression()");
::osl::MutexGuard aGuard(m_aMutex);
@@ -111,7 +117,7 @@ void MQueryHelper::setExpression( MQueryExpression &_expr )
void MQueryHelper::append(MQueryHelperResultEntry* resEnt)
{
-// SAL_INFO("connectivity.mork", "MQueryHelper::append()" );
+// SAL_INFO("connectivity.mork", "MQueryHelper::append()");
if ( resEnt != NULL ) {
m_aResults.push_back( resEnt );
@@ -170,9 +176,9 @@ MQueryHelper::getByIndex(sal_uInt32 nRow)
sal_Int32 MQueryHelper::getResultCount() const
{
- SAL_INFO("connectivity.mork", "MQueryHelper::getResultCount()" );
+// SAL_INFO("connectivity.mork", "MQueryHelper::getResultCount()" );
sal_Int32 result = static_cast<sal_Int32>(m_aResults.size());
- SAL_INFO("connectivity.mork", "result: " << result);
+// SAL_INFO("connectivity.mork", "result: " << result);
return result;
}
@@ -229,6 +235,7 @@ sal_Int32 MQueryHelper::executeQuery(OConnection*
xConnection)
SAL_INFO("connectivity.mork", "MQueryHelper::executeQuery()" );
reset();
+ //dumpExpression(this, &m_aExpr);
MorkTableMap::iterator tableIter;
MorkTableMap *Tables = xConnection->getMorkParser()->getTables( 0x80 );
MorkRowMap *Rows = 0;
@@ -260,7 +267,14 @@ sal_Int32 MQueryHelper::executeQuery(OConnection*
xConnection)
rtl::OUString valueOUString =
::rtl::OStringToOUString( valueOString, RTL_TEXTENCODING_UTF8 );
entry->setValue(key, valueOUString);
}
- append(entry);
+ ::std::vector< sal_Bool > vector =
entryMatchedByExpression(this, &m_aExpr, entry);
+ sal_Bool result = sal_True;
+ for (::std::vector<sal_Bool>::iterator iter =
vector.begin(); iter != vector.end(); ++iter) {
+ result = result && *iter;
+ }
+ if (result) {
+ append(entry);
+ }
}
}
}
@@ -269,4 +283,132 @@ sal_Int32 MQueryHelper::executeQuery(OConnection*
xConnection)
return 0;
}
+::std::vector< sal_Bool > entryMatchedByExpression(MQueryHelper* _aQuery,
MQueryExpression* _aExpr, MQueryHelperResultEntry* entry)
+{
+ ::std::vector< sal_Bool > resultVector;
+ MQueryExpression::ExprVector::iterator evIter;
+ for( evIter = _aExpr->getExpressions().begin();
+ evIter != _aExpr->getExpressions().end();
+ ++evIter )
+ {
+ if ( (*evIter)->isStringExpr() ) {
+ MQueryExpressionString* evStr =
static_cast<MQueryExpressionString*> (*evIter);
+
+ // Set the 'name' property of the boolString.
+ // Check if it's an alias first...
+ rtl::OString attrName =
_aQuery->getColumnAlias().getProgrammaticNameOrFallbackToUTF8Alias(
evStr->getName() );
+ //OSL_TRACE("Name = %s ;", attrName.getStr() );
+ SAL_INFO("connectivity.mork", "Name = " << attrName.getStr());
+ // Set the 'matchType' property of the boolString. Check for equal
length.
+ sal_Bool requiresValue = sal_True;
+ switch(evStr->getCond()) {
+ case MQueryOp::Exists:
+ SAL_INFO("connectivity.mork", "MQueryOp::Exists; done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::Exists);
+ requiresValue = sal_False;
+ break;
+ case MQueryOp::DoesNotExist:
+ SAL_INFO("connectivity.mork", "MQueryOp::DoesNotExist;
done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::DoesNotExist);
+ requiresValue = sal_False;
+ break;
+ case MQueryOp::Contains:
+ SAL_INFO("connectivity.mork", "MQueryOp::Contains; done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::Contains);
+ break;
+ case MQueryOp::DoesNotContain:
+ SAL_INFO("connectivity.mork", "MQueryOp::DoesNotContain;
done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::DoesNotContain);
+ break;
+ case MQueryOp::Is:
+ SAL_INFO("connectivity.mork", "MQueryOp::Is; done");
+ //boolString->SetCondition(nsIAbBooleanConditionTypes::Is);
+ break;
+ case MQueryOp::IsNot:
+ SAL_INFO("connectivity.mork", "MQueryOp::IsNot; done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::IsNot);
+ break;
+ case MQueryOp::BeginsWith:
+ SAL_INFO("connectivity.mork", "MQueryOp::BeginsWith;
done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::BeginsWith);
+ break;
+ case MQueryOp::EndsWith:
+ SAL_INFO("connectivity.mork", "MQueryOp::EndsWith; done");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::EndsWith);
+ break;
+ case MQueryOp::SoundsLike:
+ SAL_INFO("connectivity.mork", "MQueryOp::SoundsLike;
TODO");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::SoundsLike);
+ break;
+ case MQueryOp::RegExp:
+ SAL_INFO("connectivity.mork", "MQueryOp::RegExp; TODO");
+
//boolString->SetCondition(nsIAbBooleanConditionTypes::RegExp);
+ break;
+ default:
+ SAL_INFO("connectivity.mork", "(default) MQueryOp::Is; ");
+ //boolString->SetCondition(nsIAbBooleanConditionTypes::Is);
+ break;
+ }
+ rtl::OUString currentValue = entry->getValue(attrName);
+ // Set the 'matchValue' property of the boolString. Value returned
in unicode.
+ if ( requiresValue )
+ {
+ SAL_INFO("connectivity.mork", "Value = " << evStr->getValue()
);
+ rtl::OUString searchedValue = evStr->getValue();
+ if (evStr->getCond() == MQueryOp::Is) {
+ resultVector.push_back((currentValue == searchedValue) ?
sal_True : sal_False);
+ } else if (evStr->getCond() == MQueryOp::IsNot) {
+ resultVector.push_back((currentValue == searchedValue) ?
sal_False : sal_True);
+ } else if (evStr->getCond() == MQueryOp::EndsWith) {
+
resultVector.push_back((currentValue.endsWith(searchedValue)) ? sal_True :
sal_False);
+ } else if (evStr->getCond() == MQueryOp::BeginsWith) {
+
resultVector.push_back((currentValue.indexOf(searchedValue) == 0) ? sal_True :
sal_False);
+ } else if (evStr->getCond() == MQueryOp::Contains) {
+
resultVector.push_back((currentValue.indexOf(searchedValue) == -1) ? sal_False
: sal_True);
+ } else if (evStr->getCond() == MQueryOp::DoesNotContain) {
+
resultVector.push_back((currentValue.indexOf(searchedValue) == -1) ? sal_True :
sal_False);
+ } else {
+ OSL_FAIL("not yet implemented");
+ }
+ }
+
+ // Find it and change it ;-)
+ // class rtl::OUString "has no element named" isEmtpy
+ if (evStr->getCond() == MQueryOp::Exists) {
+ resultVector.push_back((currentValue.getLength() == 0) ?
sal_False : sal_True);
+ } else if (evStr->getCond() == MQueryOp::DoesNotExist) {
+ resultVector.push_back((currentValue.getLength() == 0) ?
sal_True : sal_False);
+ }
+ }
+ else if ( (*evIter)->isExpr() ) {
+ SAL_INFO("connectivity.mork", "Appending Subquery Expression");
+ MQueryExpression* queryExpression = static_cast<MQueryExpression*>
(*evIter);
+ ::std::vector<sal_Bool> subquery_result =
entryMatchedByExpression(_aQuery, queryExpression, entry);
+ MQueryExpression::bool_cond condition =
queryExpression->getExpressionCondition();
+ if (condition == MQueryExpression::OR) {
+ sal_Bool result = sal_False;
+ for (::std::vector<sal_Bool>::iterator iter =
subquery_result.begin(); iter != subquery_result.end(); ++iter) {
+ result = result || *iter;
+ }
+ resultVector.push_back(result);
+ } else if (condition == MQueryExpression::AND) {
+ sal_Bool result = sal_True;
+ for (::std::vector<sal_Bool>::iterator iter =
subquery_result.begin(); iter != subquery_result.end(); ++iter) {
+ result = result && *iter;
+ }
+ resultVector.push_back(result);
+ } else {
+ OSL_FAIL("Unknown Expression Type");
+ }
+ }
+ else {
+ // Should never see this...
+ // OSL_FAIL("Unknown Expression Type!");
+ SAL_WARN("connectivity.mork", "Unknown Expression Type!");
+ return resultVector;
+ }
+ }
+ return resultVector;
+}
+
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
diff --git a/connectivity/source/drivers/mork/MQueryHelper.hxx
b/connectivity/source/drivers/mork/MQueryHelper.hxx
index 5c5a6b8..4cc33f9 100644
--- a/connectivity/source/drivers/mork/MQueryHelper.hxx
+++ b/connectivity/source/drivers/mork/MQueryHelper.hxx
@@ -199,7 +199,7 @@ namespace connectivity
sal_Bool checkRowAvailable( sal_Int32 nDBRow );
sal_Bool getRowValue( ORowSetValue& rValue, sal_Int32 nDBRow,const
rtl::OUString& aDBColumnName, sal_Int32 nType );
sal_Int32 executeQuery(OConnection* xConnection);
-
+ const OColumnAlias& getColumnAlias() const { return
m_rColumnAlias; }
bool hadError() const { return
m_aError.is(); }
inline const ErrorDescriptor& getError() const { return
m_aError; }
_______________________________________________
Libreoffice-commits mailing list
libreoffice-comm...@lists.freedesktop.org
http://lists.freedesktop.org/mailman/listinfo/libreoffice-commits
