Bugfixes in sqlsetup

Put every uid columns and associated FK in INTEGER instead of VARCHAR(50)

Database/sqlsetup.py

@@ -5,7 +5,7 @@ from Database.sqlwrapper import SqlWrapper
 class SQLSetup(object): 
 
     def initDb(self, dbconfname = 'default'):
-        db = SqlWrapper(read_db = dbconfname, write_db = dbconfname)
+        db = SqlWrapper(read_db = dbconfname, write_db = dbconfname, alchemy_logs=True)
         tables = self.get_schema()
         db.dropAll()
         db.createAllFromConf(tables)
@@ -14,7 +14,7 @@ class SQLSetup(object):
         tables = []
 
         default_columns = [
-            {"name":"uid",          "type":"VARCHAR(50)", "extra":{"foreignkey":"uids.uid", "nullable":False, "primarykey":True}},
+            {"name":"uid",          "type":"INTEGER", "extra":{"foreignkey":"uids.uid", "nullable":False, "primarykey":True}},
             {"name":"name",         "type":"VARCHAR(50)", "extra":{"nullable":False, "unique":True}},
             {"name":"string",       "type":"TEXT"},
             {"name":"help",         "type":"TEXT"},
@@ -47,7 +47,7 @@ class SQLSetup(object):
         # Table listing the types
         em_type = {"name":"em_type"}
         em_type['columns'] = default_columns + [
-            {"name":"class_id",     "type":"VARCHAR(50)", "extra":{"foreignkey":"em_class.uid", "nullable":False}},
+            {"name":"class_id",     "type":"INTEGER", "extra":{"foreignkey":"em_class.uid", "nullable":False}},
             {"name":"sortcolumn",   "type":"VARCHAR(50)", "extra":{"default":"rank"}},
             {"name":"icon",         "type":"INTEGER"},
         ]
@@ -56,8 +56,8 @@ class SQLSetup(object):
         # relation between types: which type can be a child of another
         em_type_hierarchy = {"name":"em_type_hierarchy"}
         em_type_hierarchy['columns'] = [
-            {"name":"superior_id",    "type":"VARCHAR(50)", "extra":{"foreignkey":"em_type.uid", "nullable":False, "primarykey":True}},
-            {"name":"subordinate_id", "type":"VARCHAR(50)", "extra":{"foreignkey":"em_type.uid", "nullable":False, "primarykey":True}},
+            {"name":"superior_id",    "type":"INTEGER", "extra":{"foreignkey":"em_type.uid", "nullable":False, "primarykey":True}},
+            {"name":"subordinate_id", "type":"INTEGER", "extra":{"foreignkey":"em_type.uid", "nullable":False, "primarykey":True}},
             {"name":"nature",         "type":"VARCHAR(50)"},
         ]
         tables.append(em_type_hierarchy)
@@ -65,17 +65,17 @@ class SQLSetup(object):
        # Table listing the fieldgroups of a class
         em_fieldgroup = {"name":"em_fieldgroup"}
         em_fieldgroup['columns'] = default_columns + [
-            {"name":"class_id",     "type":"VARCHAR(50)", "extra":{"foreignkey":"em_class.uid", "nullable":False}},
+            {"name":"class_id",     "type":"INTEGER", "extra":{"foreignkey":"em_class.uid", "nullable":False}},
         ]
         tables.append(em_fieldgroup)
 
         # Table listing the fields of a fieldgroup
         em_field = {"name":"em_field"}
         em_field['columns'] = default_columns + [
-            {"name":"fieldtype_id",   "type":"VARCHAR(50)", "extra":{"nullable":False}},
-            {"name":"fieldgroup_id",  "type":"VARCHAR(50)", "extra":{"foreignkey":"em_fieldgroup.uid", "nullable":False}},
-            {"name":"rel_to_type_id", "type":"VARCHAR(50)", "extra":{"foreignkey":"em_type.uid", "nullable":False}}, # if relational: type this field refer to
-            {"name":"rel_field_id",   "type":"VARCHAR(50)", "extra":{"foreignkey":"em_type.uid", "nullable":False}}, # if relational: field that specify the rel_to_type_id
+            {"name":"fieldtype_id",   "type":"INTEGER", "extra":{"nullable":False}},
+            {"name":"fieldgroup_id",  "type":"INTEGER", "extra":{"foreignkey":"em_fieldgroup.uid", "nullable":False}},
+            {"name":"rel_to_type_id", "type":"INTEGER", "extra":{"foreignkey":"em_type.uid", "nullable":False}}, # if relational: type this field refer to
+            {"name":"rel_field_id",   "type":"INTEGER", "extra":{"foreignkey":"em_type.uid", "nullable":False}}, # if relational: field that specify the rel_to_type_id
             {"name":"optional",       "type":"BOOLEAN"},
             {"name":"internal",       "type":"BOOLEAN"},
             {"name":"icon",           "type":"INTEGER"},
@@ -85,8 +85,8 @@ class SQLSetup(object):
         # selected field for each type
         em_field_type = {"name":"em_field_type"}
         em_field_type['columns'] = [
-            {"name":"type_id",   "type":"VARCHAR(50)", "extra":{"foreignkey":"em_type.uid", "nullable":False, "primarykey":True}},
-            {"name":"field_id",  "type":"VARCHAR(50)", "extra":{"foreignkey":"em_field.uid", "nullable":False, "primarykey":True}},
+            {"name":"type_id",   "type":"INTEGER", "extra":{"foreignkey":"em_type.uid", "nullable":False, "primarykey":True}},
+            {"name":"field_id",  "type":"INTEGER", "extra":{"foreignkey":"em_field.uid", "nullable":False, "primarykey":True}},
         ]
         tables.append(em_field_type)
 
@@ -94,10 +94,10 @@ class SQLSetup(object):
         objects = {
             "name":"objects",
             "columns":[
-                {"name":"uid",         "type":"VARCHAR(50)", "extra":{"foreignkey":"uids.uid", "nullable":False, "primarykey":True}},
+                {"name":"uid",         "type":"INTEGER", "extra":{"foreignkey":"uids.uid", "nullable":False, "primarykey":True}},
                 {"name":"string",      "type":"VARCHAR(50)"},
-                {"name":"class_id",    "type":"VARCHAR(50)", "extra":{"foreignkey":"em_class.uid"}},
-                {"name":"type_id",     "type":"VARCHAR(50)", "extra":{"foreignkey":"em_type.uid"}},
+                {"name":"class_id",    "type":"INTEGER", "extra":{"foreignkey":"em_class.uid"}},
+                {"name":"type_id",     "type":"INTEGER", "extra":{"foreignkey":"em_type.uid"}},
                 {"name":"date_update", "type":"DATE"},
                 {"name":"date_create", "type":"DATE"},
                 {"name":"history",     "type":"TEXT"}
@@ -110,7 +110,7 @@ class SQLSetup(object):
         files = {
             "name":"files",
             "columns":[
-                {"name":"uid",     "type":"VARCHAR(50)", "extra":{"foreignkey":"uids.uid", "nullable":False, "primarykey":True}},
+                {"name":"uid",     "type":"INTEGER", "extra":{"foreignkey":"uids.uid", "nullable":False, "primarykey":True}},
                 {"name":"field1",  "type":"VARCHAR(50)"}
             ]
         }

Database/sqlwrapper.py

@@ -81,6 +81,10 @@ class SqlWrapper(object):
         logger.debug("New wrapper instance : <"+self.name+" read:"+str(self.r_engine)+" write:"+str(self.w_engine))
         pass
 
+    @classmethod
+    def getEngine(c, ename = 'default', logs = None):
+        return c(read_db = ename, write_db = ename, alchemy_logs = logs).r_engine
+
     @property
     def cfg(self):
         """ Return the SqlWrapper.config dict """
@@ -273,13 +277,10 @@ class SqlWrapper(object):
                     err.append('Missing "'+dbname+'" db configuration')
                 else:
                     db = self.cfg['db'][dbname]
-                    if 'ENGINE' not in db:
-                        err.append('Missing "ENGINE" in database "'+db+'"')
-                    else:
-                        if db['ENGINE'] not in self._engines_cfg:
-                            err.append('Unknown engine "'+db['ENGINE']+'"')
-                        elif db['ENGINE'] != 'sqlite' and 'USER' not in db:
-                            err.append('Missing "User" in configuration of database "'+dbname+'"')
+                    if db['ENGINE'] not in self._engines_cfg:
+                        err.append('Unknown engine "'+db['ENGINE']+'"')
+                    elif db['ENGINE'] != 'sqlite' and 'USER' not in db:
+                        err.append('Missing "User" in configuration of database "'+dbname+'"')
                     if 'NAME' not in db:
                         err.append('Missing "NAME" in database "'+dbname+'"')
                         
@@ -294,7 +295,8 @@ class SqlWrapper(object):
         if not settings.DEBUG:
             logger.critical("Trying to drop all tables but we are not in DEBUG !!!")
             raise RuntimeError("Trying to drop all tables but we are not in DEBUG !!!")
-        meta = sqla.MetaData(bind=self.w_engine, reflect = True)
+        meta = sqla.MetaData(bind=self.w_engine)
+        meta.reflect()
         meta.drop_all()
         pass
 
@@ -310,7 +312,7 @@ class SqlWrapper(object):
             if not isinstance(table, dict):
                 raise TypeError("Excepted a list of dict but got a "+str(type(schema))+" in the list")
             self.createTable(**table)
-
+        
         self.meta_crea.create_all(bind = self.w_engine)
         logger.info("All tables created")
         self.meta_crea = None
@@ -334,14 +336,17 @@ class SqlWrapper(object):
         if not isinstance(name, str):
             raise TypeError("<class str> excepted for table name, but got "+type(name))
 
+        #if not 'mysql_engine' in kw and self.w_engine.dialect.name == 'mysql':
+        #    kw['mysql_engine'] = 'InnoDB'
+
         res = sqla.Table(name, self.meta_crea, **kw)
         for i,col in enumerate(columns):
             res.append_column(self.createColumn(**col))
 
         if crea_now:
             self.meta_crea.create_all(self.w_engine)
+            logger.debug("Table '"+name+"' created")
 
-        #logger.debug("Table '"+name+"' created")
         pass
 
     def createColumn(self, **kwargs):