Merge branch 'develop-1.2' into MCOL-1822-c

dbcon/joblist/limitedorderby.cpp

@@ -77,8 +77,6 @@ void LimitedOrderBy::initialize(const RowGroup& rg, const JobInfo& jobInfo)
         map<uint32_t, uint32_t>::iterator j = keyToIndexMap.find(i->first);
         idbassert(j != keyToIndexMap.end());
 
-        // TODO Ordering direction in CSEP differs from
-        // internal direction representation. This behavior should be fixed
         fOrderByCond.push_back(IdbSortSpec(j->second, i->second));
     }
 
@@ -86,16 +84,14 @@ void LimitedOrderBy::initialize(const RowGroup& rg, const JobInfo& jobInfo)
     fStart = jobInfo.limitStart;
     fCount = jobInfo.limitCount;
 
-//	fMemSize = (fStart + fCount) * rg.getRowSize();
-
     IdbOrderBy::initialize(rg);
 }
 
-
+// This must return a proper number of key columns and
+// not just a column count.
 uint64_t LimitedOrderBy::getKeyLength() const
 {
-    //return (fRow0.getSize() - 2);
-    return fRow0.getColumnCount();
+    return fOrderByCond.size();
 }
 
 

dbcon/mysql/ha_calpont.cpp

@@ -1231,11 +1231,14 @@ void check_walk(const Item* item, void* arg)
  *  logical OR in the filter predicates
  *  Impossible WHERE
  *  Impossible HAVING
- * Valid queries with the last two crashes the server if processed.
+ * and there is either GROUP BY or aggregation function
+ * exists at the top level.
+ * Valid queries with the last two crashes the server if
+ * processed.
  * Details are in server/sql/group_by_handler.h
  * PARAMETERS:
- *    thd - THD pointer.
- *    query - Query structure, that describes the pushdowned query.
+ *    thd - THD pointer
+ *    query - Query structure LFM in group_by_handler.h
  * RETURN:
  *    group_by_handler if success
  *    NULL in other case
@@ -1254,15 +1257,22 @@ create_calpont_group_by_handler(THD* thd, Query* query)
         && ( query->group_by || select_lex->with_sum_func ) )
     {
         bool unsupported_feature = false;
+        // revisit SELECT_LEX for all units
+        for(TABLE_LIST* tl = query->from; !unsupported_feature && tl; tl = tl->next_global)
+        {
+            select_lex = tl->select_lex;
+            // Correlation subquery. Comming soon so fail on this yet.
+            unsupported_feature = select_lex->is_correlated;
+
             // Impossible HAVING or WHERE
-        if ( ( query->having && select_lex->having_value == Item::COND_FALSE )
+            if ( ( !unsupported_feature && query->having && select_lex->having_value == Item::COND_FALSE )
                 || ( select_lex->cond_count > 0
                     && select_lex->cond_value == Item::COND_FALSE ) )
             {
                 unsupported_feature = true;
             }
 
-        // Unsupported conditions check.
+            // Unsupported JOIN conditions
             if ( !unsupported_feature )
             {
                 JOIN *join = select_lex->join;
@@ -1276,8 +1286,20 @@ create_calpont_group_by_handler(THD* thd, Query* query)
                 {
                     icp->traverse_cond(check_walk, &unsupported_feature, Item::POSTFIX);
                 }
+
+                // Optimizer could move some join conditions into where
+                if (select_lex->where != 0)
+                    icp = reinterpret_cast<Item_cond*>(select_lex->where);
+
+                if ( unsupported_feature == false
+                    && icp )
+                {
+                    icp->traverse_cond(check_walk, &unsupported_feature, Item::POSTFIX);
                 }
 
+            }
+        } // unsupported features check ends here
+
         if ( !unsupported_feature )
         {
             handler = new ha_calpont_group_by_handler(thd, query);

oamapps/mcsadmin/mcsadmin.cpp

@@ -5404,7 +5404,14 @@ int processCommand(string* arguments)
 
                             for ( ; pt1 != (*pt).hostConfigList.end() ; pt1++)
                             {
-                                string ipAddr = (*pt1).IPAddr;
+                                /* MCOL-1607.  IPAddr may be a host name here b/c it is read straight
+                                from the config file. */
+                                string tmphost = oam.getIPAddress(pt1->IPAddr);
+                                string ipAddr;
+                                if (tmphost.empty())
+                                    ipAddr = pt1->IPAddr;
+                                else
+                                    ipAddr = tmphost;
                                 string hostname = (*pt1).HostName;
                                 string nicID = oam.itoa((*pt1).NicID);
 

utils/windowfunction/idborderby.cpp

@@ -1,5 +1,5 @@
 /* Copyright (C) 2014 InfiniDB, Inc.
-   Copyright (c) 2019 MariaDB Corporation
+   Copyright (C) 2019 MariaDB Corporation
 
    This program is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License
@@ -20,7 +20,6 @@
 
 
 #include <iostream>
-//#define NDEBUG
 #include <cassert>
 #include <string>
 #include <stack>
@@ -507,7 +506,6 @@ uint64_t IdbOrderBy::Hasher::operator()(const Row::Pointer& p) const
     row.setPointer(p);
     // MCOL-1829 Row::h uses colcount as an array idx down a callstack.
     uint64_t ret = row.hash();
-    //cout << "hash(): returning " << ret << " for row: " << row.toString() << endl;
     return ret;
 }
 
@@ -516,11 +514,8 @@ bool IdbOrderBy::Eq::operator()(const Row::Pointer& d1, const Row::Pointer& d2)
     Row& r1 = ts->row1, &r2 = ts->row2;
     r1.setPointer(d1);
     r2.setPointer(d2);
-    // MCOL-1829 Row::equals uses 2nd argument as container size boundary
-    // so it must be column count - 1.
-    bool ret = r1.equals(r2, colCount - 1);
-    //cout << "equals(): returning " << (int) ret << " for r1: " << r1.toString() << " r2: " << r2.toString()
-    //	<< endl;
+    // MCOL-1829 Row::equals uses 2nd argument as key columns container size boundary
+    bool ret = r1.equals(r2, colCount);
 
     return ret;
 }