Changeset 8185 for trunk/MagicSoft/Mars/msql/MSQLServer.cc

Timestamp:

11/01/06 08:29:46 (18 years ago)

Author:

tbretz

Message:

*** empty log message ***

File:

• trunk/MagicSoft/Mars/msql/MSQLServer.cc (modified) (6 diffs)

trunk/MagicSoft/Mars/msql/MSQLServer.cc

@@ -1 +1 @@
 /* ======================================================================== *\
+! $Name: not supported by cvs2svn $:$Id: MSQLServer.cc,v 1.13 2006-11-01 08:29:45 tbretz Exp $
+! --------------------------------------------------------------------------
 !
 ! *
@@ -18 +20 @@
 !   Author(s): Thomas Bretz 2/2004 <mailto:tbretz@astro.uni-wuerzburg.de>
 !
-!   Copyright: MAGIC Software Development, 2000-2004
+!   Copyright: MAGIC Software Development, 2000-2006
 !
 !
@@ -47 +49 @@
 #include <TH1.h>
 #include <TEnv.h>
+#include <TPRegexp.h>
 
 #include <TSQLResult.h>
@@ -519 +522 @@
 }
 
-TSQLResult *MSQLServer::GetTables(const char *dbname, const char *wild) /*FOLD00*/
-{
-    return fType==kIsServer && fServ ? fServ->GetTables(dbname, wild) : NULL;
-}
-
-TSQLResult *MSQLServer::GetColumns(const char *dbname, const char *table, const char *wild) /*FOLD00*/
-{
-    return fType==kIsServer && fServ ? fServ->GetColumns(dbname, table, wild) : NULL;
+TSQLResult *MSQLServer::GetTables(const char *wild, const char *dbname) /*FOLD00*/
+{
+    return fType==kIsServer && fServ ? fServ->GetTables(dbname?dbname:fDataBase.Data(), wild) : NULL;
+}
+
+TSQLResult *MSQLServer::GetColumns(const char *table, const char *wild, const char *dbname) /*FOLD00*/
+{
+    return fType==kIsServer && fServ ? fServ->GetColumns(dbname?dbname:fDataBase.Data(), table, wild) : NULL;
 }
 
@@ -604 +607 @@
     }
     else
-        SetBit(kZombie);
+        fType = kIsZombie;
 
     fList.SetOwner();
@@ -749 +752 @@
 }
 
+// --------------------------------------------------------------------------
+//
+// Return the name of the (first) column with a primary key
+//
+TString MSQLServer::GetPrimaryKey(const char *table)
+{
+    TSQLResult *res = GetColumns(table);
+    if (!res)
+        return "";
+
+    TString rc;
+
+    TSQLRow *row = 0;
+    while ((row=res->Next()))
+    {
+        TString key = (*row)[3];
+        if (key!="PRI")
+            continue;
+
+        rc = (*row)[0];
+        break;
+    }
+
+    delete res;
+    return rc;
+}
+
+// --------------------------------------------------------------------------
+//
+// Searches in the text for patterns like "Table.Column". If such a pettern
+// is found the primary key of the table is requested a "LEFT JOIN"
+// with this Table is added ON the identity of the primary key of Table
+// with the given table.
+//
+TString MSQLServer::GetJoins(const char *table, const TString text)
+{
+    Int_t p=0;
+
+    TString mods;
+    TArrayI pos;
+
+    // Find all Table.Column expression. Because also floating point
+    // numbers can contain a dot the result has to be checked carefully
+    TString joins;
+    TPRegexp reg = TPRegexp("\\w+[.]\\w+");
+    while (1)
+    {
+        // Check whether expression is found
+        if (reg.Match(text, mods, p, 130, &pos)==0)
+            break;
+
+        // Get expression from text
+        const TString expr = text(pos[0], pos[1]-pos[0]);
+        p = pos[1];
+
+        if (expr.IsFloat())
+            continue;
+
+        const TString tab = expr(0, expr.First('.'));
+        const TString var = expr(expr.First('.')+1, expr.Length());
+
+        // If the table found is the primary table itself skip it.
+        if (tab==table)
+            continue;
+
+        // If this join has already be set, skip it.
+        if (joins.Contains(Form(" %s ", tab.Data())))
+            continue;
+
+        // Now get the primary key of the table to be joined
+        const TString prim = GetPrimaryKey(tab);
+        if (prim.IsNull())
+            continue;
+
+        joins += Form("LEFT JOIN %s ON %s.%s=%s.%s ", tab.Data(),
+                      table, prim.Data(), tab.Data(), prim.Data());
+    }
+
+    if (!joins.IsNull())
+        joins += " ";
+
+    return joins;
+}
+
 void MSQLServer::RecursiveRemove(TObject *obj)
 {