From 70d447c1f1518b85a4db44dd9c0b4fa526457fa1 Mon Sep 17 00:00:00 2001
From: "mskold@mysql.com" <>
Date: Thu, 24 Nov 2005 16:21:07 +0100
Subject: Moved check of wrong schema version earlier

---
 sql/ha_ndbcluster.cc | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

(limited to 'sql/ha_ndbcluster.cc')

diff --git a/sql/ha_ndbcluster.cc b/sql/ha_ndbcluster.cc
index 6760208488f..e06559dc593 100644
--- a/sql/ha_ndbcluster.cc
+++ b/sql/ha_ndbcluster.cc
@@ -3285,12 +3285,7 @@ int ha_ndbcluster::external_lock(THD *thd, int lock_type)
         DBUG_PRINT("info", ("Table schema version: %d", 
                             tab->getObjectVersion()));
       }
-      if (m_table != (void *)tab)
-      {
-        m_table= (void *)tab;
-        m_table_version = tab->getObjectVersion();
-      }
-      else if (m_table_version < tab->getObjectVersion())
+      if (m_table_version < tab->getObjectVersion())
       {
         /*
           The table has been altered, caller has to retry
@@ -3298,6 +3293,13 @@ int ha_ndbcluster::external_lock(THD *thd, int lock_type)
         NdbError err= ndb->getNdbError(NDB_INVALID_SCHEMA_OBJECT);
         DBUG_RETURN(ndb_to_mysql_error(&err));
       }
+      if (m_table != (void *)tab)
+      {
+        m_table= (void *)tab;
+        m_table_version = tab->getObjectVersion();
+        if (!(my_errno= build_index_list(ndb, table, ILBP_OPEN)))
+          DBUG_RETURN(my_errno);
+      }
       m_table_info= tab_info;
     }
     no_uncommitted_rows_init(thd);
-- 
cgit v1.2.1